並行化2 for循環時無法獲取值

Question

我試圖運行以下代碼段，它將數據附加到列表'tests1'和'tests2'。但是當我打印'tests1'和'tests2'時，顯示的列表是空的。這裏有什麼不正確的？

tests1 = [] 
tests2 = [] 

def func1(): 
    for i in range(25,26): 
     tests1.append(test_loader.get_tests(test_prefix=new_paths[i],tags=params.get('tags', None), 
            exclude=params.get('exclude', False))) 

def func2(): 
    for i in range(26,27): 
     tests2.append(test_loader.get_tests(test_prefix=new_paths[i],tags=params.get('tags', None), 
            exclude=params.get('exclude', False))) 


p1 = mp.Process(target=func1) 
p2 = mp.Process(target=func2) 

p1.start() 
p2.start() 
p1.join() 
p2.join() 

print tests1 
print tests2 

Answer 1

工作進程實際上並不共享同一個對象。它被複制（醃製）。

您可以使用multiprocessing.Queue（或通過各種其他方式）在進程之間發送值。看看我的簡單例子（爲了簡單起見，我把你的測試整理成整數）。

from multiprocessing import Process, Queue 

def add_tests1(queue): 
    for i in range(10): 
     queue.put(i) 
    queue.put(None) 

def add_tests2(queue): 
    for i in range(100,110): 
     queue.put(i) 
    queue.put(None) 

def run_tests(queue): 
    while True: 
     test = queue.get() 
     if test is None: 
      break 
     print test 

if __name__ == '__main__': 
    queue1 = Queue() 
    queue2 = Queue() 

    add_1 = Process(target = add_tests1, args = (queue1,)) 
    add_2 = Process(target = add_tests2, args = (queue2,)) 
    run_1 = Process(target = run_tests, args = (queue1,)) 
    run_2 = Process(target = run_tests, args = (queue2,)) 

    add_1.start(); add_2.start(); run_1.start(); run_2.start() 
    add_1.join(); add_2.join(); run_1.join(); run_2.join() 

請注意，父程序也可以訪問隊列。