介绍

进程彼此之间互相隔离,要实现进程间通信(IPC),multiprocessing模块支持两种形式:队列和管道,这两种方式都是使用消息传递的

Queue是多进程安全的队列,可以使用Queue实现多进程之间的数据传递。

主要方法介绍

q.put方法用以插入数据到队列中。
q.get方法可以从队列读取并且删除一个元素。

队列的使用

  1. from multiprocessing import Process,Queue
  2. q=Queue(3)
  3. #put ,get ,put_nowait,get_nowait,full,empty
  4. q.put(1)
  5. q.put(2)
  6. q.put(3)
  7. print(q.full()) #满了
  8. # q.put(4) #再放就阻塞住了
  9. print(q.get())
  10. print(q.get())
  11. print(q.get())
  12. print(q.empty()) #空了
  13. # print(q.get()) #再取就阻塞住了

进程.gif