如何在Python中使类成员进程安全

Z时代
2024-01-10
分类：问答

我正在做一些类的任务，它通过迭代器产生多个进程来确保每个入口被处理一次。代码是这样的：如何在Python中使类成员进程安全

import multiprocessing as mp 
Class MyClass(): 
    def __init__(): 
     self.index=[blabla] 
     self.iterator=0 
     self.workers=[mp.Process(target=self.worker, args=(self.lock, args) for i in range(10)] 
    def worker(self, lock, args): 
     # I intend to use lock to make only one subprocs read index 
     # list until iterator goes to next 
     while some_condition: 
      lock.acquire() 
      now_item=self.index[self.iterator] 
      self._next_iter() 
      lock.release() 
      ...# do something on now_item 
    def._next_iter(self): 
     #do some checks and +1 on iterator