python使用队列实现进程间通信

代码实现python队列进程间通信

import multiprocessing
import time


# 向队列中写入数据
def job_1(q):
    try:
        n = 1
        while n < 5:
            print("job_1,%d" % n)
            q.put(n)
            time.sleep(1)
            n += 1
    except BaseException:
        print("job_1 error")
    finally:
        print("job_1 end !!!")


# 取出队列中的数据
def job_2(q):
    try:
        n = 1
        while n < 5:
            print("job_2,%d" % q.get())
            time.sleep(1)
            n += 1
    except BaseException:
        print("job_2 error")
    finally:
        print("job_2 end")


if __name__ == '__main__':
    q = multiprocessing.Queue()
    p1 = multiprocessing.Process(target=job_1, args=(q,))
    p2 = multiprocessing.Process(target=job_2, args=(q,))
    p1.start()
    p2.start()
    p1.join()
    p2.join()
    print("over")