python标准库学习—multiprocessing模块

qianqianling

多进程模块
该模块包含几个重要的类：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])            通过连接，发送字节数据缓冲区