4

Python 2.7.2 の multiprocessing モジュールを使用していくつかの計算を実行しようとしています。私のコードは次のようなものです：

from multiprocessing import Pool
import sys
sys.setrecursionlimit(10000)
partitions = []
class Partitions:
    parts = {} #My goal is to use this dict to speed
               #up calculations in every process that
               #uses it, without having to build it up
               #from nothing each time
    def __init__(self):
        pass
    def p1(self, k, n):
        if (k,n) in Partitions.parts:
            return Partitions.parts[(k, n)]
        if k>n:
            return 0
        if k==n:
            return 1
        Partitions.parts[(k,n)] = self.p1(k+1, n) + self.p1(k, n-k)
        return Partitions.parts[(k,n)]

    def P(self, n):
        result = 0
        for k in xrange(1,n/2 + 1):
            result += self.p1(k, n-k)
        return 1 + result

p = Partitions()

def log(results):
    if results:
        partitions.extend(results)
    return None

def partWorker(start,stop):
    ps = []
    for n in xrange(start, stop):
        ps.append(((1,n), p.P(n)))
    return ps

def main():
    pool = Pool()
    step = 150
    for i in xrange(0,301,step):
        pool.apply_async(partWorker, (i, i+step), callback = log)

    pool.close()
    pool.join()

    return None

if __name__=="__main__":
    main()

私はこれが初めてで、基本的にこのページのプライムコードの形式をコピーしました: python プライムクランチ: 処理プールは遅いですか? 計算を支援するために、すべて同じ辞書を参照する各コアでプロセスを実行できますか? 現在の動作では、各プロセスが独自の辞書を作成し、狂ったように RAM を食い尽くします。

4

1 に答える 1

1

これがあなたが望むものかどうかはわかりません...しかし、 multiprocessing.Manager （http://docs.python.org/library/multiprocessing.html#sharing-state-between-processes）を見てください。マネージャーを使用すると、プロセス間で辞書を共有できます。

于 2012-04-25T00:54:53.787 に答える