多重处理是否创建类的副本?

2024-10-16 20:53:45 发布

您现在位置:Python中文网/ 问答频道 /正文

我在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不会在其他任何地方实例化。你知道吗

提前谢谢


Tags: inselfidforrangemultiprocessingresultsnum