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

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

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

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

m.Array(typecode,sequence)

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

m.BoundedSemaphore(value)

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

m.Condition(lock)

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

m.dict(args)

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

m.Event()

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

m.list(sequence)

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

m.Lock

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

m.Namespace()

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

實(shí)例1使用管理者創(chuàng)建一個(gè)在進(jìn)程中共享的字典：

代碼：

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

import multiprocessing
import time

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


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

    #啟動監(jiān)視字典的進(jìn)程
    p=multiprocessing.Process(target=watch,args=(dict,event,))
    #設(shè)置為后臺進(jìn)程，隨主進(jìn)程的銷毀而銷毀，該后臺進(jìn)程無法創(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)


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

    m.shutdown()

運(yùn)行結(jié)果：

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

語法：

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

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

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

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

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

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

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

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

從BaseManager類派生的管理器的實(shí)例m必須手動啟動才能運(yùn)行。

屬性于常用方法

繼承自BaseProxy的類的實(shí)例具有以下方法：

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

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

代碼：

#繼承BaseManager類，實(shí)現(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來實(shí)現(xiàn)代理，從而正確的公開__add__方法，并使用特性(property)公開name屬性。
#BaseProxy來來自multiprocessing.managers模塊
class MyClassProxy(BaseProxy):
    #referent上公開的所有方法列表
    _exxposed_=["__add__","getName","setName"]
    #實(shí)現(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)建托管對象,此時(shí)知識創(chuàng)建了一個(gè)實(shí)例代理，無法直接訪問屬性，必須使用函數(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帥哥