python进程使用Queue和Pipe通信-创新互联
背景
当使用多个线程操作任务的时候,如果线程间有需要通信的地方，那么不可避免的要实现到线程间的通信，来互相通知消息，同步任务的执行。
一.通信
1.线程threading共享内存地址，进程与进程Peocess之间相互独立，互不影响（相当于深拷贝）；
2.在线程间通信的时候可以使用Queue模块完成，进程间通信也可以通过Queue完成，但是此Queue并非线程的Queue，进程间通信Queue是将数据 pickle 后传给另一个进程的 Queue，用于父进程与子进程之间的通信或同一父进程的子进程之间通信；
queue
python中的queue模块其实是对数据结构中栈和队列这种数据结构的封装，把抽象的数据结构封装成类的属性和方法
使用Queue线程间通信：
1 2 3 4 5 |
使用Queue进程间通信，适用于多个进程之间通信：
1 2 3 4 5 |
使用Pipe进程间通信，适用于两个进程之间通信（一对一）：
1 2 3 4 5 |
二.python进程间通信Queue/Pipe使用
python提供了多种进程通信的方式，主要Queue和Pipe这两种方式，Queue用于多个进程间实现通信，Pipe用于两个进程的通信；
1.使用Queue进程间通信，Queue包含两个方法：
put()：以插入数据到队列中，他还有两个可选参数：blocked和timeout。详情自行百度
get()：从队列读取并且删除一个元素。同样，他还有两个可选参数：blocked和timeout。详情自行百度
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 |
输出结果：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
2.使用Pipe进程间通信
Pipe常用于两个进程，两个进程分别位于管道的两端 * Pipe方法返回（conn1,conn2）代表一个管道的两个端，Pipe方法有duplex参数，默认为True，即全双工模式，若为FALSE，conn1只负责接收信息，conn2负责发送,Pipe同样也包含两个方法：
send() : 发送信息;
recv() : 接收信息;
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
输出结果：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
三.测试queue.Queue来完成进程间通信能否成功？
当然我们也可以尝试使用线程threading的Queue是否能完成线程间通信，示例代码如下：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
直接异常报错：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 |
另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
网页名称：python进程使用Queue和Pipe通信-创新互联
网页地址：http://scjbc.cn/article/ddgjhg.html
