Chinaunix首页 | 论坛 | 博客
  • 博客访问: 3026426
  • 博文数量: 877
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 6125
  • 用 户 组: 普通用户
  • 注册时间: 2016-11-11 09:12
个人简介

To be a better coder

文章分类

全部博文(877)

文章存档

2022年(1)

2021年(60)

2020年(175)

2019年(207)

2018年(210)

2017年(143)

2016年(81)

分类: LINUX

2019-04-17 15:15:14

[root@localhost /]#
[root@localhost /]# cat zhu.py
#!/bin/python
import multiprocessing
import random
import time
import os
def producer(pipe):
    while True:
        time.sleep(1)
        item = random.randint(1, 10)
        print('process producer product goods:{}'.format(item))
        pipe.send(item)
        time.sleep(1)
def consumer(pipe):
    while True:
        time.sleep(1)
        item = pipe.recv()
        print('process cusumer get goods:{}'.format(item))
        time.sleep(1)
if __name__ == "__main__":
    pipe = multiprocessing.Pipe()
    process_producer = multiprocessing.Process( target=producer, args=(pipe[0],))
    process_consumer = multiprocessing.Process( target=consumer, args=(pipe[1],))
    process_producer.start()
    process_consumer.start()
    process_producer.join()
    process_consumer.join()

[root@localhost /]#

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