| 123456789101112131415161718 |
- import multiprocessing
- from trans.ExecParam import ExecParam
- class Axis0DataImpl(object):
- def __init__(self, id, process_count, now_count, exec_param: ExecParam, save_db=True):
- self.id = id
- self.process_count = process_count
- self.now_count = now_count
- self.exec_param = exec_param
- self.save_db = save_db
- self.lock_map = dict()
- for i in range(1000):
- self.lock_map[i] = multiprocessing.Manager().Lock()
- self.lock = multiprocessing.Manager().Lock()
- self.field_dict = multiprocessing.Manager().dict()
|
