相关博文
- ·
- ·
- ·
- ·
- ·
- ·
- ·
- ·
- ·
- ·
分类： python/ruby
2015-06-08 13:02:56
多进程模块
该模块包含几个重要的类：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]) 通过连接，发送字节数据缓冲区
给主人留下些什么吧！~~