9

マルチプロセッシング プール内の各プロセスで cProfile.runctx() を実行して、ソース内のマルチプロセッシングのボトルネックが何であるかを把握しようとしています。これが私がやろうとしていることの簡単な例です:

from multiprocessing import Pool
import cProfile

def square(i):
    return i*i

def square_wrapper(i):
    cProfile.runctx("result = square(i)",
        globals(), locals(), "file_"+str(i))
    # NameError happens here - 'result' is not defined.
    return result

if __name__ == "__main__":
    pool = Pool(8)
    results = pool.map_async(square_wrapper, range(15)).get(99999)
    print results

残念ながら、プロファイラーで "result = square(i)" を実行しようとしても、それが呼び出されたスコープ内の 'result' には影響しません。ここでやろうとしていることをどのように達成できますか?

4

1 に答える 1

8

これを試して：

def square_wrapper(i):
    result = [None]
    cProfile.runctx("result[0] = square(i)", globals(), locals(), "file_%d" % i)
    return result[0]
于 2009-09-12T10:54:16.580 に答える