python 多进程（十四-3）

深藏阁楼爱情的钟 2023-10-05 20:27 27阅读 0赞

#### 进程通信 > Queue队列 ####

因为多进程是不同的空间，所以无法像多线程一样共享全局变量和资源。但可以使用依赖Queue队列实现哦！！

**消息队列**：简单理解是一个仓库，里面存放多进程共享资源;  
**作用**：可以与不同进程进行交互，达到让更多的进程之间交流，交互的母的；  
**本质**：理解是一个仓库，可以往里面放数据.  
**特性**：拿数据依赖？  
是索引 or 变量名？  
不是，其实是靠的顺序，先进先出，后进后出 （购买火车票排队）  
CBA > 队列(CBA) > CBA

import  multiprocessing
    
    #创建队列对象，不传值,默认空间无限大
    qu=multiprocessing.Queue()
    #创建队列对象，只能放3个数据
    qu=multiprocessing.Queue(3)
    
    # (1) 往队列里面放数据
    qu.put()
    # (2) 查看队列是否满了(满了 返回True)
    qu.full()
    # (3) 从队列里面取数据 >>> 先进先出, 后进后出
    qu.get() # 队列里面如果里面没有数据,,,陷入等待状态....等待其他进程往里面放数据
    qu.get_nowait() # 取值,不等待直接报错
    # 可以做异常处理,,没有值就报错,,捕获异常,,就可以得到队列为空的信息......
    # (4) 判断队列是否为空 (为空，返回True)
    qu.empty()

#创建队列对象，只能放3个数据
    qu=multiprocessing.Queue(3)
    # 往队列里面放数据
    qu.put(100)
    qu.put("mike")
    qu.put(['a','b','c'])
    
    #队列查看
    print(qu.full())
    
    #取数据(先进先出，后进后出)
    print(f'从队列中取出第1个数据：{qu.get()}')
    print(f'从队列中取出第2个数据：{qu.get()}')
    print(f'从队列中取出第3个数据：{qu.get()}')
    
    #队列是否为空
    print(qu.empty())
    
    #队列已空，还要取出数据
    # qu.get() #程序卡住，等待队列里面放数据,有了就继续取值，程序继续往下执行
    
    #判断为空，就不再取数据
    if(qu.empty()==False):
        #队列为空，就抛出异常
        qu.get_nowait()

![20210225151507974.png][]

[20210225151507974.png]: https://img-blog.csdnimg.cn/20210225151507974.png