0

Python のプール モジュールを使用して簡単なプログラムを作成しようとしています。これが私のコードです：

from multiprocessing import Pool
from multiprocessing.pool import ApplyResult
import time
import os

def unwrap_self_f(arg, **kwarg):
  print 'inside unwrap_self_f'
  return C().f(arg, **kwarg)

class C:
  def f(self, name):
    return 'Inside f..Process id :' + str(os.getpid())

  def run(self):
    print 'Reached inside run..'
    print 'main process id ..', os.getpid()
    pool = Pool(processes=4)
    names = ['frank', 'justin', 'osi', 'thomas']        
    print pool.map(unwrap_self_f, names, 1)               

if __name__ == '__main__':
   print 'Starting....'
   c = C()
   print 'Running....'
   c.run()

このプログラムを実行すると、作成された子プロセスごとに 1 つずつ、4 つの異なるプロセス ID が出力されることを期待していました。選択したチャンクサイズは 1 であるため、リスト内の各項目は個別のプロセスに送られます。

ただし、出力されるプロセスIDは同じです。以下の出力が得られます。

Starting....
Running....
Reached inside run..
main process id .. 1284
['Inside f..Process id :6872', 'Inside f..Process id :6872', 'Inside f..Process id :6872', 'Inside f..Process  id :6872']

ここでどこか間違っていますか？誰でもこれに光を当てることができます。前もって感謝します。

4

0 に答える 0