您的位置:首页 > 编程语言 > Python开发

multiprocessing在python中的高级应用-托管对象

2015-08-30 22:47 656 查看
继上一篇,介绍的multiprocessing在python中的高级应用-共享数据与同步,此篇的主要内容主要介绍托管对象。

和线程不同,进程不支持共享对象。尽管可以像前面所述那样创建共享值和数组,但这对更高级的python对象(如字典、列表或用户定义类的实例)不起作用。但是multiprocessing模块确实提供了一种使用共享对象的途径,但前提是他们运行在所谓的管理器的控制之下。管理器是独立的子进程,其中存在真实的对象,并以服务器的形式运行。其他进程通过使用代理访问共享对象,这些代理作为管理器服务器的客户端运行。

使用简单托管对象的最直观方式是使用Manager()函数。

Manager()

在一个单独的进程中创建运行的管理器。返回值是SyncManager类型的实例,SyncManager类型定义在multiprocessing.managers模块中。

Manager()函数返回的SyncManager的实例m具有一系列方法,可用于创建共享对象并返回用于访问这些共享对象的代理。通常,可以创建一个管理器,并在启动任何新进程之前使用这些方法创建共享对象。这些已定义的方法如下:

m.Array(typecode, sequence)

在服务器上创建共享的Array实例并返回可访问它的代理。

m.BoundSemaphore( [value] )

在服务器上创建共享的threading.BoundedSemaphore实例,并返回可访问它的代理。

m.Condition( [ lock] )

在服务器上创建共享的threading.Condition实例,并返回可访问它的代理。lock是m.Lock()或m.RLock()方法创建的代理实例。

m.dict( [ args] )

在服务器上创建共享的dict实例,并返回可访问它的代理。此方法的参数与内置函数dict()中的参数相同。

m.Event( )

在服务器上创建共享的threading.Event 实例,并返回可访问它的代理。

m.list( [ sequence] )

在服务器上创建共享的list实例,并返回可访问它的代理。此方法的参数与内置函数list()中相同。

m.Lock()

在服务器上创建共享的threading.Lock实例,并返回可访问它的代理。

m.Namespace()

在服务器上创建共享的namespace对象,并返回可访问它的代理。namespace就是一个类似于python模块的对象。例如,如果n是一个命名空间代理,那么可以使用(.)赋值和读取属性,比如n.name=value或value=n.name。但name的名称十分重要。如果name以字母开头,那么这个值就是管理器所拥有的共享对象的一部分,所有其他进程均可访问它。如果name以下划线开头,那么它只是代理对象的一部分,并不是共享的。

m.Queue()

在服务器上创建共享的Queue.Queue对象,并返回可访问它的代理。

m.RLock()

在服务器上创建共享的threading.RLock对象,并返回可访问它的代理。

m.Semaphore( [ value] )

在服务器上创建共享的threading.Semaphore对象,并返回可访问的代理。

m.Value(typecode, value)

在服务器上创建一个共享的value对象,并返回可访问它的代理。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: