可以寫一個服務程序作為排程者，將任務分佈到其他多個程序中，依靠網路通訊進行管理。

另外值得注意的是，manager和worker兩端建立的例項是相關的，即worker的例項，通過驗證碼和網路IP地址連線到manager即伺服器的例項。

# -*- coding:utf-8 -*-

#taskmanager.py
'''
1.建立佇列，作為共享訊息的通道。 服務程序
任務佇列task_queue作為服務程序傳遞任務給任務程序的通道，而結果佇列result_queue作為任務程序完成任務後回傳給服務程序的通道。
值得注意的是，在【一臺機器上】寫多程序程式時，建立的Queue可以直接拿來用
然而，在分散式多程序環境下，不可以直接新增任務到原始的task_queue，那樣就繞過了Queuemanager的封裝，
必須通過manager.get_task_queue()獲得的【Queue介面】新增任務。
2.把1.中建立的佇列在網路上註冊，暴露給其他程序(主機)，註冊後獲得【網路佇列】(可以認為是1.中佇列的'映像')
3.建立一個物件(Queuemanager(BaseManager))例項manager，繫結埠和驗證碼
4.啟動3.中建立的例項，以便監聽連線(啟動管理 manager，監管資訊通道)
5.通過管理例項的方法獲得通過網路訪問的Queue物件，即再把網路佇列實體化成可以使用的本地佇列(通過本地上傳到網路)
6.建立任務到“本地”佇列中，自動上傳任務到網路佇列中，以供分配給
'''

import random,time,Queue
from multiprocessing.managers import BaseManager

#建立兩個佇列，分別存放任務和結果，它們用來進行程序間通訊，交換物件。換言之，這兩個佇列就是交換物件
task_queue=Queue.Queue()
result_queue=Queue.Queue()

class Queuemanager(BaseManager):
	pass

#把建立的兩個佇列註冊在網路上，利用register方法，callable引數關聯了Queue物件
#typeid is a “type identifier”(型別識別符號) which is used to identify a particular type of shared object. This must be a string.
#callable is a callable used for creating objects for this type identifier.——後者用來建立前者，後者是具體的物件，而前者是利用後者創造出來的“影子”
Queuemanager.register('get_task_queue',callable=lambda:task_queue)
Queuemanager.register('get_result_queue',callable=lambda:result_queue)

#繫結埠5000，設定驗證碼‘abc’。這個相當於物件的初始化
#address is the address on which the manager process listens for new connections
manager=Queuemanager(address=('',5000),authkey='abc')

#啟動管理
manager.get_server().serve_forever()

#通過管理例項的方法獲得通過網路訪問的Queue物件
task=manager.get_task_queue()
result=manager.get_result_queue()

#放幾個任務進去
for i in range(10):
	n=random.randint(0,10000)
	print 'put task %d ...' %n
	task.put(n)   #task是本地佇列

print 'try get result...'
for i in range(10):
	print 'result is %s' %result.get(timeout=10)
	
#關閉管理
manager.shutdown()
 

# taskworker.py

import time, sys, Queue
from multiprocessing.managers import BaseManager

# 建立類似的QueueManager:
class QueueManager(BaseManager):
    pass

# 由於這個QueueManager只從網路上獲取Queue，所以註冊時只提供名字:
QueueManager.register('get_task_queue')
QueueManager.register('get_result_queue')

# 連線到伺服器，也就是執行taskmanager.py的機器:
server_addr = '127.0.0.1'
print('Connect to server %s...' % server_addr)
# 埠和驗證碼注意保持與taskmanager.py設定的完全一致:
m = QueueManager(address=(server_addr, 5000), authkey='abc')
# 從網路連線:
m.connect()
# 獲取Queue的物件:
task = m.get_task_queue()
result = m.get_result_queue()
# 從task佇列取任務,並把結果寫入result佇列:
for i in range(10):
    try:
        n = task.get(timeout=1)
        print('run task %d * %d...' % (n, n))
        r = '%d * %d = %d' % (n, n, n*n)
        time.sleep(1)
        result.put(r)
    except Queue.Empty:
        print('task queue is empty.')
# 處理結束:
print('worker exit.')