python_分散式進程中遇到的問題

看文檔學習分散式進程中遇到了一下問題，文檔裡面例題是python2.X，我用的python3.x,就出現了一下莫名奇妙的問題，最終版代碼先呈上：

taskManager.py

 1 # coding:utf-8
 2 # taskManager.py  for  windows  伺服器端
 3 
 4 import queue
 5 from multiprocessing.managers import BaseManager
 6 from multiprocessing import freeze_support
 7 # 任務個數
 8 task_number = 10
 9 # 定義收發隊列
10 task_queue = queue.Queue(task_number);
11 result_queue = queue.Queue(task_number);
12 def get_task():
13     return task_queue
14 def get_result():
15     return result_queue
16 #創建類似的QueueManager:
17 class QueueManager(BaseManager):
18     pass
19 def win_run():
20     # Windows 下綁定調用介面不能使用lambda,所以只能先定義函數再綁定
21     QueueManager.register('get_task_queue',callable = get_task)
22     QueueManager.register('get_result_queue',callable=get_result)
23     #綁定埠並設置驗證口令，windows下需要填寫IP地址，Linux下不填預設為本地 ip地址為本地ip地址
24     manager = QueueManager(address = ('192.xxx.xx.xxx',8001),authkey =b'qiye')
25     # 啟動
26     manager.start()
27     try:
28         # 通過網路獲取任務隊列和結果隊列
29         task = manager.get_task_queue()
30         result = manager.get_result_queue()
31         #添加任務
32         for url in ["ImageUrl_"+str(i) for i in range(10)]:
33             print('put task %s ...'%url)
34             task.put(url)
35         print('try get result...')
36         for i in range(10):
37             print('result is %s' %result.get(timeout=10))
38     except:
39         print('Manager error')
40     finally:
41         # 一定要關閉，否則會報管道未關閉的錯誤
42         manager.shutdown()
43 
44 if __name__=='__main__':
45     # Windows 下多進程可能會有問題，添加這句可以緩解
46     freeze_support()
47     win_run()

taskWorker.py

 1 # coding:utf-8
 2 import time
 3 from multiprocessing.managers import BaseManager
 4 # 創建類似的 QueueManager:
 5 class QueueManager(BaseManager):
 6     pass
 7 #第一步： 使用QueueManager註冊用於獲取Queue的方法名稱
 8 QueueManager.register('get_task_queue')
 9 QueueManager.register('get_result_queue')
10 #第二步：連接到伺服器:
11 server_addr = '192.xxx.xx.xxx'
12 print('Connect to server %s...'%server_addr)
13 #埠和驗證口令註意保持與伺服器進程保持一致：
14 m = QueueManager(address=(server_addr,8001),authkey=b'qiye')
15 #從網路連接
16 m.connect()
17 #第三部：獲取Queue的對象：
18 task = m.get_task_queue()
19 result = m.get_result_queue()
20 #第四步：從task隊列獲取任務，並把結果寫入result隊列：
21 while(not task.empty()):
22     image_url = task.get(True,timeout = 5)
23     print('run task download %s ...'%image_url)
24     time.sleep(1)
25     result.put('%s--->success'%image_url)
26 #處理結束
27 print('worker exit.')

先運行 taskManager.py 伺服器端代碼，再快速運行 taskWorker.py 客戶端代碼 運行結果依次如下：