Chinaunix首页 | 论坛 | 博客
  • 博客访问: 657470
  • 博文数量: 87
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 2022
  • 用 户 组: 普通用户
  • 注册时间: 2014-04-23 11:16
个人简介

西邮大三狗!!!

文章分类

全部博文(87)

文章存档

2015年(47)

2014年(40)

分类: 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])            通过连接,发送字节数据缓冲区








阅读(3654) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~