python管道_python 多进程之管道实例（模板）

python 多进程之管道实例（模板）

#2012-02-27磁针石

#承接软件自动化实施与培训验证码破解软件破解脚本开发测试和python培训等

#gtalk：ouyangchongwu#gmail.com qq 37391319博客:testing.blog.chinaunix.net

#python qq group:深圳自动化测试python群：113938272

#武冈深圳qq群：66250781 都梁深圳湖南户外群：49494279#参考资料

#!/usr/bin/env python

# -*- coding: utf-8 -*-

import multiprocessing

# 管道消费者.

def consumer(lock,pipe):

output_p, input_p = pipe

input_p.close() # 关闭管道输入口

while True:

lock.acquire()

item = output_p.recv()

lock.release()

if item == None:

break

# 处理部分

lock.acquire()

print(item)

lock.release()

# 管道生产者

def producer(sequence, input_p):

for item in sequence:

# Put the item on the queue

input_p.send(item)

if __name__ == '__main__':

# 进程数、创建管道，锁等

p_num = 2

process = []

(output_p, input_p) = multiprocessing.Pipe()

lock = multiprocessing.Lock()

# 定义消费进程

for i in range(p_num):

t =multiprocessing.Process(target=consumer,args=(lock,(output_p, input_p),))

t.daemon=True

process.append(t)

# 启动消费进程

for i in range(p_num):

process[i].start()

# 关闭输出管道，以往管道填充数据

output_p.close()

sequence = range(100) + [None]*p_num

producer(sequence, input_p)

# 数据填充完毕，打开输入管道

input_p.close()

# 等待结束

for i in range(p_num):

process[i].join()

python管道_python 多进程之管道实例（模板）相关推荐

python 通信模块_python 多进程通信模块
多进程通信方法好多,不一而数.刚才试python封装好嘅多进程通信模块 multiprocessing.connection. 简单测试一下,效率还可以,应该系对socket封装,效率可以达到4krp ...
python信息传送管道_python – 获取返回管道输入的命令
我有这个 Python 3代码存储在pipe.py中,它接受一些管道输入并逐行打印: import sys for i, line in enumerate(sys.stdin): print(&qu ...
python强类型_python动态性强类型用法实例
本文实例分析了python动态性强类型用法.分享给大家供大家参考.具体如下: Python变量声明和定义与C#不同,Python在使用变量之前无须定义它的类型,试着运行下面的例子: i = 12 p ...
neo4j python 算法_python操作neo4j简单实例
一:neo4j是什么 neo4j:Neo4j是一个高性能的,NOSQL图形数据库,有关于更多neo4j的资料出门右拐二:python操作neo4j的实现 python中neo4j的操作可以利用驱动包 ...
excel文件成绩处理python代码_Python处理Excel文件实例代码
因为工作需求,需要审核一部分query内容是否有效,query储存在Excel中,文本内容为页面的Title,而页面的URL以HyperLink的格式关联到每个Cell. 于是本能的想到用Python ...
python多线程和多进程的使用_python多线程与多进程
python多线程与多进程 python多线程 python中提供两个标准库thread和threading用于对线程的支持,python3中已放弃对前者的支持,后者是一种更高层次封装的线程库,接下来 ...
python多线程多进程多协程_python 多进程、多线程、协程
1.python的多线程多线程就是在同一时刻执行多个不同的程序,然而python中的多线程并不能真正的实现并行,这是由于cpython解释器中的GIL(全局解释器锁)捣的鬼,这把锁保证了同一时刻只有 ...
python多进程map比apply快_python 多进程读写 map
要让Python程序实现多进程(multiprocessing),我们先了解操作系统的相关知识. Unix/Linux操作系统提供了一个fork()系统调用,它非常特殊.普通的函数调用,调用一次,返回 ...
熊猫人表情包python 代码_Python实现表情包的代码实例
本文主要介绍了使用Python进行简单图像处理的方法以及Python自动生产表情包的实例,具有很好的参考价值,下面跟着小编一起来看下吧作为一个数据分析师,应该信奉一句话--"一图胜千言&q ...

python管道_python 多进程之管道实例（模板）

python管道_python 多进程之管道实例（模板）相关推荐

最新文章

热门文章