day 13 通过Queue实现多进程简单通信 about python-100-days HOT 2 OPEN

import os
from multiprocessing import Process, Queue, set_start_method, get_start_method
from time import sleep


def sub_task(string, q):
    a = q.get()
    sleep(0.01)
    while a < 10:
        if q.empty():
            q.put(a + 1)
            sleep(0.01)
            print(string, end='', flush=True)
            a = q.get()
    if q.empty():
        q.put(a + 1)
        sleep(0.1)


def main():
    set_start_method("spawn")

    q = Queue()
    q.put(0)
    p1 = Process(target=sub_task, args=('Ping', q))
    p2 = Process(target=sub_task, args=('Pong', q))

    # 启动进程
    p1.start()
    p2.start()

    # 等待进程完成
    p1.join()
    p2.join()

    print("\nProcesses completed.")


if __name__ == '__main__':
    main()