python - 获取worker返回的数据

Question

如何获取worker返回的数据？

import multiprocessing

def worker():

      """worker function"""
      return 'DATA'

if __name__ == '__main__':

      jobs = []
      for i in range(5):
          p = multiprocessing.Process(target=worker)
          print p
          jobs.append(p)
          p.start()

输出:

DATA
DATA
DATA
DATA
DATA

Answer 1

您可以创建一个工作人员池并传入一些数据进行处理:

import multiprocessing

def worker(item):
    return item ** 2

if __name__ == '__main__':
    pool = multiprocessing.Pool(5)

    for result in pool.imap_unordered(worker, range(30)):
        print result