Python-进程通信（队列实现）

我不是女神ヾ 2023-06-30 02:44 76阅读 0赞

进程通信

进程通信可以通过队列实现。先介绍一下Queue的简单使用。

  1. from queue import Queue,LifoQueue,PriorityQueue
  3. q = Queue(5)
  4. q.put('A')
  5. q.put('B')
  6. q.put('C')
  7. q.put('D')
  8. q.put('E')
  10. if q.full():
  11.     print("队列已满！！！！")
  12. else:
  13.     q.put('F',timeout=2) #如果队列满了，则只能等待；除非有“空地”才能添加成功。
  15. q.get()
  16. q.get()
  17. q.get()
  18. q.get()
  19. q.get()
  20. if q.empty():
  21.     print('队列已空')
  22. else:
  23.     q.get(timeout=2) # 如果队列为空，取元素会阻塞。

输出：

  1. 队列已满！！！！
  2. 队列已空

通过队列实现进程通信

用例：

  1. from multiprocessing import Process,Queue # Queue别导错了！
  2. from time import sleep
  5. def download(q):
  6.     images = ['girl.jpg','boy.jpg','man.jpg']
  7.     for image in images:
  8.         print('正在下载:',image)
  9.         sleep(0.5)
  10.         q.put(image)
  12. def getfile(q):
  13.     while True:
  14.         try:
  15.             file = q.get(timeout = 2)
  16.             print('{} 保存成功！！！'.format(file))
  17.         except:
  18.             print('全部保存完毕！')
  19.             break
  21. if __name__ == '__main__':
  22.     q = Queue(5)
  23.     p1 = Process(target=download,args=(q,))
  24.     p2 = Process(target=getfile, args=(q,))
  26.     p1.start()
  27.     p2.start()
  29.     p1.join()
  30.     p2.join()

输出：

  1. 正在下载: girl.jpg
  2. 正在下载: boy.jpg
  3. girl.jpg 保存成功！！！
  4. 正在下载: man.jpg
  5. boy.jpg 保存成功！！！
  6. man.jpg 保存成功！！！
  7. 全部保存完毕！

发表评论

表情：
评论列表 （有 0 条评论，76人围观）

还没有评论，来说两句吧...

相关阅读

    相关 进程间通信之消息队列

    对于进程我们知道一个进程拥有独立的用户地址空间，在一个进程中的全局变量在另一个进程中是看不到的，那仫进程间是如何通信的呢？在进程与进程间的通信必须要经过内核，在内核中开辟一块缓

    ゞ 浴缸里的玫瑰ゞ 浴缸里的玫瑰/ 0 赞/ 244 阅读