zoukankan      html  css  js  c++  java
  • 进程间通信之——队列Queue

    队列是先进先出。

    from multiprocessing import Queue
    
    q = Queue(6)  # 队列容纳上限
    
    q.put(1)  # 放到队列里面
    q.put(2)
    q.put(3)
    q.put(4)
    q.put(5)
    q.put(6)
    print(q.full())  # 检测队列是否满了
    print(q.get())
    print(q.get())  # 从队列中取数据
    print(q.get())
    print(q.get())
    print(q.get())
    print(q.get())
    print(q.empty())  # 检测队列是否空了
    try:
        q.get_nowait()  # 从队列中取数据且不阻塞,如果队列是空的就会报错。
    except:
        print('队列已空')

    进程间通信:

    from multiprocessing import Process
    from multiprocessing import Queue
    
    def func1(q):
        q.put('hello2')  # 子进程1中往队列里放置两次数据
        q.put('hello1')
    
    def func2(q):
        print(q.get())  # 子进程2从队列里得到一个数据
    
    
    
    if __name__ == '__main__':
        q = Queue()
        p = Process(target=func1, args=(q,))
        p.start()
        print(q.get())  # 主进程从数据中获取一个数据
        p = Process(target=func2, args=(q,))
        p.start()

    这样就实现了子进程与主进程,子进程与子进程之间的通信了。

  • 相关阅读:
    基础编程练习题第一波
    TYVJ 1541 八数码
    NOIP 2014 寻找道路
    NOIP2014 解方程
    POJ 3213 矩阵乘法(优化)
    POJ 1523 Tarjan求割点
    POJ 3237 树链剖分+线段树
    SPOJ 375 树链剖分
    NOIP 2012 T2 国王游戏 (贪心+高精)
    POJ 1364 差分约束
  • 原文地址:https://www.cnblogs.com/aaronthon/p/9826606.html
Copyright © 2011-2022 走看看