10

multiprocessing モジュールの manager.dict() のネストされた辞書のキーを更新しようとしていますが、更新できません。値を更新せず、エラーもスローしません。

コード：

import time
import random
from multiprocessing import Pool, Manager

def spammer_task(d, token, repeat):
    success = 0
    fail = 0
    while success+fail<repeat:
        time.sleep(random.random()*2.0)
        if (random.random()*100)>98.0:
            fail+=1
        else:
            success+=1
        d[token] = {
            'status': 'ongoing',
            'fail': fail,
            'success': success,
            'repeat': repeat
        }
    print d[token]['status']
    d[token]['status'] = 'complete'
    return

p = Pool()
m = Manager()
d = m.dict()

p.apply_async(spammer_task (d, 'abc', 5))
print d

出力：

進行中

{'abc': {'ステータス': '進行中'、'失敗': 0、'繰り返し': 5、'成功': 5}}

while ループが終了するとすぐに、d['abc']['status'] = complete になるはずです。しかし、最終的な印刷では、ステータスが「進行中」のみとして印刷されます。

4

2 に答える 2

13

理由はわかりませんが、Manager DictProxy オブジェクトは、ネストされた部分の変更を処理できないようです。このコードは機能します：

import time
import random
from multiprocessing import Pool, Manager

def spammer_task(d, token, repeat):
    success = 0
    fail = 0
    while success+fail<repeat:
        time.sleep(random.random()*2.0)
        if (random.random()*100)>98.0:
            fail+=1
        else:
            success+=1
        d[token] = {
            'status': 'ongoing',
            'fail': fail,
            'success': success,
            'repeat': repeat,
        }
    print d[token]['status']
    foo = d[token]
    foo['status'] = 'complete'
    d[token] = foo
    return

p = Pool()
m = Manager()
d = m.dict()

p.apply_async(spammer_task(d, 'abc', 5))
print d
于 2016-05-29T13:24:19.267 に答える
4

この問題は以下のコードごとに残っているようです:

import multiprocessing, sys;

if __name__ == '__main__':

print(sys.version);

mpd = multiprocessing.Manager().dict();
mpd['prcss'] = {'q' : 'queue_1', 'ctlg' : 'ctlg_1' };

# update 1 - doesn't work!
mpd['prcss'].update( { 'name': 'concfun_1'} );
print('Result of failed update 1:', mpd['prcss']);

# update 2 - doesn't work!
mpd['prcss']['name'] = 'concfun_1';
print('Result of failed update 2:', mpd['prcss']);

# update 3 - works!
mpd_prcss = mpd['prcss'];
mpd_prcss['name'] = 'concfun_1';
mpd['prcss'] = mpd_prcss;
print('Result of successful update 3:', mpd['prcss']);

出力：

3.6.1 (v3.6.1:69c0db5、2017 年 3 月 21 日、17:54:52) [MSC v.1900 32 ビット (Intel)]

失敗した更新の結果 1: {'q': 'queue_1', 'ctlg': 'ctlg_1'}

失敗した更新の結果 2: {'q': 'queue_1', 'ctlg': 'ctlg_1'}

正常な更新の結果 3: {'q': 'queue_1', 'ctlg': 'ctlg_1', 'name': 'concfun_1'}

于 2018-02-06T15:11:57.417 に答える