Python进程间通信用法实例

yipeiwu_com5年前Python基础

本文实例讲述了Python进程间通信用法。分享给大家供大家参考。具体如下:

#!/usr/bin/env python
# -*- coding=utf-8 -*-
import multiprocessing
def counsumer(input_q):
  while True:
    item = input_q.get()
    #处理项目
    print item #此处替换为有用的工作
    #发出信号通知任务完成
    input_q.task_done()
def producer(sequence,output_q):
  for item in sequence:
    #将项目放入队列
    output_q.put(item)
#建立进程
if __name__ == '__main__':
  q = multiprocessing.JoinableQueue()#创建可连接的共享进程队列
  cons_q = multiprocessing.Process(target=counsumer,args=(q,))
  cons_q.daemon = True
  cons_q.start()
  sequence = [1,2,3,4]
  producer(sequence,q)
  q.join()
  print 'success'

希望本文所述对大家的Python程序设计有所帮助。

相关文章

Python中将变量按行写入txt文本中的方法

Python中将变量按行写入txt文本中的方法

先看一个简单的例子:将变量写入txt文本中 f = open('E:/test.txt','w') f.write('hello world!') Out[3]: 12 f.c...

Python ValueError: invalid literal for int() with base 10 实用解决方法

今天在写爬虫程序的时候由于要翻页,做除法分页的时候出现了 复制代码 代码如下: totalCount = '100' totalPage = int(totalCount)/20 Va...

python中的二维列表实例详解

1. 使用输入值初始化列表 nums = [] rows = eval(input("请输入行数:")) columns = eval(input("请输入列数:")) for ro...

python实现手机通讯录搜索功能

本文实例为大家分享了python通过输入联系人首字母查询联系人的具体代码,供大家参考,具体内容如下 # -*- coding:utf-8 -*- # 练习2: # 模拟手机通讯录...

python重试装饰器示例

利用python 写一些网络服务的时候,当网络状况不好,或者资源占用过多,任务拥塞的情况下,总会抛出一些异常,当前任务就被终止了,可以很好的利用@装饰器,写一个重试的装饰器,这样比较py...