我在Python中使用多处理来运行许多任务。你知道吗
我是这样做的:
tasks = multiprocessing.JoinableQueue()
results = multiprocessing.Queue()
# Start consumers
num_consumers = multiprocessing.cpu_count() * 2
consumers = [ Consumer(tasks, results) for _ in range(num_consumers) ]
for w in consumers:
w.start()
然后我有一个属性“Colony”,它有一个蚂蚁列表,所有的蚂蚁都初始化在__init__
for ant in self.colony.ants:
tasks.put(ant)
num_tasks += 1
问题是,当我运行所有任务(即方法__call__
)时,每个ant都会被调用。
我返回self
,比较时:
# We wait now for all the ants to finish
tasks.join()
results_list = list()
for _ in range(num_tasks):
results_list.append(results.get())
print (id(results_list[0]),results_list[0].id)
print(id(self.colony.ants[0]),self.colony.ants[0].id)
我得到了
(33524112, 0) (33005072, 0)
所以它是同一个蚂蚁,但是在消费者调用它之后,它会创建一个自己的副本?或者我错过了什么。 ant不会在其他任何地方实例化。你知道吗
提前谢谢
目前没有回答
相关问题 更多 >
编程相关推荐