1

ここでワーカーから返されたデータを取得するにはどうすればよいですか??

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
4

1 に答える 1

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
于 2013-04-19T07:38:00.890 に答える