Python进程间通信用法实例

yipeiwu_com6年前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 TCP通信客户端服务端代码实例

这篇文章主要介绍了Python TCP通信客户端服务端代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 TCP客户端: im...

python 多进程队列数据处理详解

我就废话不多说了,直接上代码吧! # -*- coding:utf8 -*- import paho.mqtt.client as mqtt from multiprocessing...

基于python requests库中的代理实例讲解

直接上代码: #request代理(proxy) """ 1.启动代理服务器Heroku,相当于aliyun 2.在主机1080端口启动Socks 服务 3.将请求转发到1080端口...

Python实现购物系统(示例讲解)

Python实现购物系统(示例讲解)

要求: 用户入口 1、商品信息存在文件里 2、已购商品,余额记录。 商家入口 可以添加商品,修改商品价格 Code: 商家入口: # Author:P J J import os...

python中redis的安装和使用

python下redis安装 用python操作redis数据库,先下载redis-py模块下载地址https://github.com/andymccurdy/redis-py she...