摘要：連接帶遠程管理器對象，該對象的地址在構(gòu)造函數(shù)中支出。在當前進程中運行管理器服務(wù)器。啟動一個單的子進程，并在該子進程中啟動管理器服務(wù)器。如果無法序列號對象將引發(fā)異常。

上一篇文章：Python進程專題6：共享數(shù)據(jù)與同步
下一篇文章：Python進程專題8：分布集群的消息傳遞

進程不支持共享對象，上面描述的創(chuàng)建共享值和數(shù)組，但都是指定的特殊類型，對高級的Python對象（如：字典、列表、用戶自定義類的實例）不起作用。
還好multiprocessing模塊提供了一種使用共享對象的途徑：單前提是這些對象運行在所謂的【管理器】的控制之下。
管理器是獨立的子進程，其中存在真實的對象，并以服務(wù)器的形式運行，其他進程通過使用代理訪問共享對象，這些
代理作為管理器服務(wù)器的客戶端而運行。

m=Manager():在一個獨立的進程中創(chuàng)建運行的管理器，返回值是SyncManager（定義在multiprocess.managersa模塊中）類的實例。
m可以創(chuàng)建共享對象

m.Array(typecode,sequence)

在服務(wù)器上創(chuàng)建共享的Array實例并返回可以訪問它的代理。

m.BoundedSemaphore(value)

在服務(wù)器上創(chuàng)建共享的threading.BoundedSemphore實例，并返回可訪問它的代理。

m.Condition(lock)

在服務(wù)器上創(chuàng)建共享的threading.Condition實例，并返回可訪問它的代理。
lock是m.Lock()或m.Rlock()方法創(chuàng)建的代理實例

m.dict(args)

在服務(wù)器上創(chuàng)建共享的dict（字典）實例，并返回可以訪問它的代理。

m.Event()

在服務(wù)器上創(chuàng)建共享的thread.Event實例，并返回可以訪問它的代理。

m.list(sequence)

在服務(wù)器上創(chuàng)建共享的list實例，并返回可以訪問它的代理。

m.Lock

子服務(wù)器上創(chuàng)建共享的threading.Lock實例，并返回可訪問它的代理。

m.Namespace()

在服務(wù)器創(chuàng)建共享的namespace對象，并返回可以訪問它的代理。
namespace就是一個類似于Python模塊的對象。例如：如果n是一個命名空間代理，那么可以使用(.)賦值和讀取屬性，
例如：n.name=value 或value=n.name。但name的名稱十分重要，如果name以字母開頭，那么這個值就是管理器所擁有的共享對象的一部分，
所有其它進程均可訪問它，如果name以下劃線開頭，那么它只是代理對象的一部分，并不是共享。

m.Queue()

在服務(wù)器上創(chuàng)建共享的Queue.Queue對象，并返回可訪問它的代理。

m.RLock()

在服務(wù)器上創(chuàng)建共享的threading.Rlick對象，并返回可訪問它的代理。

m.Semaphore(value)

在服務(wù)器上創(chuàng)建共享的threading.Semaphore對象，并返回可訪問它的代理。

m.value(typecode,value)

在服務(wù)器上創(chuàng)建一個共享的Value對象，并返回可訪問它的代理。

實例1使用管理者創(chuàng)建一個在進程中共享的字典：

代碼：

#使用管理器創(chuàng)建一個在進程間共享的字典

import multiprocessing
import time

def watch(dict,event):
    while True:
        event.wait()
        print(dict)
        event.clear()


if __name__=="__main__":
    #實例化一個管理器
    m=multiprocessing.Manager()
    #在服務(wù)器上創(chuàng)建一個共享的字典，并返回可以調(diào)用它的代理
    dict=m.dict()
    #在服務(wù)器上創(chuàng)建一個共享的Event
    event=m.Event()

    #啟動監(jiān)視字典的進程
    p=multiprocessing.Process(target=watch,args=(dict,event,))
    #設(shè)置為后臺進程，隨主進程的銷毀而銷毀，該后臺進程無法創(chuàng)建新的線程
    p.daemon=True
    p.start()

    #更新字典并通知監(jiān)聽者
    dict["name"]="mark"
    event.set()
    time.sleep(3)

    # 更新字典并通知監(jiān)聽者
    dict["age"] = 18
    event.set()
    time.sleep(3)


    #終止進程和管理器
    p.terminate()

    m.shutdown()

運行結(jié)果：

如果想要共享用戶自定義類的實例，則必須創(chuàng)建自定義管理器對象，為此，需要創(chuàng)建一個繼承自BaseManager類的類，
其中BaseManager類定義在multiprocessing.managers子模塊中。

語法：

managers.BaseManager(address,authkey):用戶自定對象創(chuàng)建管理器服務(wù)器的基類。
address是一個可選的元組（hostname,port），用于指定服務(wù)器的網(wǎng)絡(luò)地址。如果忽略此參數(shù)，操作系統(tǒng)將簡單
的分配一個對應(yīng)于某些空閑端口號的地址。
authkey是一個字符串，用于對連接到服務(wù)器的客戶端身份進行驗證。如果忽略此參數(shù)，將是喲個current_process().authkey的值。

假設(shè)myclass是一個繼承自BaseManager的類，可以使用以下類方法來創(chuàng)建用于返回代理給共享對象的方法。

myclass.register(typeid,callable,proxytype,exposed,method_to_typeid,create_method):使用管理器類注冊一種新的數(shù)據(jù)類型。

typeid:一個字符串，用于命名特殊類型的共享對象。這個字符串應(yīng)該是有效的Python標識符。

callable:創(chuàng)建或返回要共享的實例的可調(diào)用對象。

proxytype:一個類，負責提供客戶端中藥使用的代理對象的實現(xiàn)，通常這些類是默認生成的，因此一般設(shè)置為None。
exposed:共享對象上方法名的序列，它將會公開給代理對象，如果省略此參數(shù)，將使用proxytype_exposed的值，
如果proxytype_expose未定義，序列將包含所有的公共方法（所有不以下劃線_開頭的可調(diào)用方法）。

method_to_typeid:從方法名稱到類型IDS的映射，這里的IDS用于指定哪些方法應(yīng)該使用代理對象返回他們的結(jié)果，
如果某個方法在這個映射中找不到，將復制和返回它的返回值，如果method_to_typeid為None，將使用proxytype_method_to_typeid_的值。

create_method:一個布爾標志，用于指定是否在mgclass中創(chuàng)建名為typeid的方法，默認值為True。

從BaseManager類派生的管理器的實例m必須手動啟動才能運行。

屬性于常用方法

繼承自BaseProxy的類的實例具有以下方法：

proxy._callmethod(name,args,kwargs):調(diào)用代理引用對象上的方法name。

proxy._getvalue():返回調(diào)用者中引用對象的副本，如果這次調(diào)用是在另一個進程中，
那么引用對象將被序列化，發(fā)送給調(diào)用者，然后再進行反序列化。如果無法序列號對象將引發(fā)異常。

代碼：

#繼承BaseManager類，實現(xiàn)自定義對象的共享，利用代理公開屬性與方法
import multiprocessing
from multiprocessing.managers import  BaseManager
from multiprocessing.managers import  BaseProxy

#普通需要共享的類，代理無法通過(.)這種形式直接訪問屬性
class MyClass():
    def __init__(self,value):
        self.name=value

    def __repr__(self):
        return "MyClass(%s)"%self.name

    def getName(self):
        return self.name
    def setName(self,value):
        self.name=value

    def __add__(self,valuye):
        self.name+=valuye
        return self

#通過自定義繼承BaseProxy來實現(xiàn)代理，從而正確的公開__add__方法，并使用特性(property)公開name屬性。
#BaseProxy來來自multiprocessing.managers模塊
class MyClassProxy(BaseProxy):
    #referent上公開的所有方法列表
    _exxposed_=["__add__","getName","setName"]
    #實現(xiàn)代理的公共結(jié)接口
    def __add__(self, value):
        self._callmethod("__add__",(value,))
        return self
    @property
    def name(self):
        return self._callmethod("getName",())
    @name.setter
    def name(self,value):
        self._callmethod("setName",(value,))


    def __repr__(self):
        return "MyClass(%s)"%self.name

    def getName(self):
        return self.name
    def setName(self,value):
        self.name=value

    def __add__(self,valuye):
        self.name+=valuye
        return self

class MyManager(BaseManager):
    pass

#不使用代理
#MyManager.register("MyClass",MyClass)
#使用代理
MyManager.register("MyClass",MyClass,proxytype=MyClassProxy)

if __name__=="__main__":
    m=MyManager()
    m.start()

    #創(chuàng)建托管對象,此時知識創(chuàng)建了一個實例代理，無法直接訪問屬性，必須使用函數(shù)來訪問
    #代理無法訪問特殊方法和下劃線(_)開頭的所有方法。
    a=m.MyClass("mark")
    print(a)
    print(a.getName())

    #不使用代理，下面兩條語句會異常
    a.__add__("帥哥")
    print(a.name)

    #print(a.name)
    #a.__add__("帥哥")

結(jié)果：

MyClass(mark)
mark
mark帥哥