python进程利用queue实现进程间的通信

"""
思路
1-准备两个进程
2-准备一个队列,一个进程向队列中定稿数据,然后把列队中的数据传递到另一个进程
3-另外一个进程读取数据
"""
import queue
import multiprocessing
import time
#写入数据到队列的函数
def queue_witer(queque):

    for i in range(10):
        if queue.full():
            print("写入已经满了")
            break
        queue.put(i)
    print("写入成功.....",i,"个数据")
    time.sleep(0.5)

#读取队列数据的函数
def queue_read(queue):
    while True :
        if queue.qsize()==0:
            print("队列已经完成")
            break
        value= queue.get()
        print("数据读取完成",value)


#创建一个空的队列

if __name__ == '__main__':
    queue = multiprocessing.Queue(5)

    #创建两个进程,分别写入数据和读数据
    mult_write = multiprocessing.Process(target=queue_witer,args=(queue,))
    mult_read = multiprocessing.Process(target=queue_read,args=(queue,))
    mult_write.start()
    mult_write.join()
    mult_read.start()
标签: python
  • blogger

版权所有:oldboy ---- 《python进程利用queue实现进程间的通信
本文地址:http://www.bokeren.cc/post-182.html
除非注明,文章均为 《悠然生活的平淡博客-博客人linux运维之家》 原创转载请注明本文地址,谢谢。


相关推荐

你肿么看?

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。