python标准库学习—multiprocessing模块

多进程模块

该模块包含几个重要的类：Process Queue Pipe

Process类

Process([group [,target [,name] [,args] [,kwargs]]])

group默认为none target为可调用对象 args为传递给target的参数(元组)

Process实例的方法如下：

p.is_alive()   如果p运行，返回True

p.join()        等待p终止

p.run()         进程启动时运行的方法

p.start()        启动进程(运行代表进程的子进程，并调用该子进程中的run方法)

p.terminate()       强制终止进程

p.exitcode    进程的整数退出代码

p.name         进程的名称

p.pid            进程的整数进程ID

Queue类

Queue([maxsize])   maxsize是队列中允许最大的项数，省略的话代表没有大小限制

进程间通信，两种形式：管道和队列(消息传递实现)

实例方法如下：

p.cancel_join_thread()        不会在进程退出时自动连接后台进程，可以防止join_thread()方法阻塞

p.close()           关闭队列，防止队列中加入更多数据

p.empty()         如果p为空，则返回True

p.full()              p已满，返回True

p.get([block] [,timeout])     返回p中的一个项目，如果为空，则阻塞timeout，在指定的阻塞时间内没有项目返回则引发Queue.empty异常

p.task_done()   使用此方法表明p.get()返回的项目已被正确处理

p.join_thread()   连接后台线程。此方法使用于调用p.close()方法之后，等待所有队列项被消耗

p.put(item,[block],[timeout])      将item放入队列。如果队列已满，此方法将阻塞到有空间可用为止 

p.qsize()           返回队列中项目的正确数量

p.join()              生产者使用此方法发出信号，直到队列中的所有项目均被处理

Pipe类

Pipe([duplex])

在进程间创建一条管道，并返回元组(conn1,conn2)，表示管道的两端connection对象。默认情况管道是双向的，如果将duplex置为false,则conn1用于接收，conn2用于发送。必须在创建和启动使用管道的Process对象之间调用Pipe()方法

实例方法如下：

c.close()            关闭连接。

c.fileno()           返回连接所使用的整数文件描述符

c.poll()               如果连接上数据可用，返回True

c.recv()               接收c.send()方法返回的对象，如果另一端关闭，再也不存在任何数据引发EOFError异常

c.send(obj)        通过连接发送对象，obj是与序列化兼容的任意对象

c.recv_bytes([maxlength])            接收c.send_bytes()方法发送的一条完整的字节消息

c.send_bytes(buffer,[offset],[size])            通过连接，发送字节数据缓冲区