自动加想接口

Administrator

2025-08-15 d2a4dd9c837f8df2a19e58f7fb4c81a91c114b67

 test/test_mul_queue.py

@@ -30,7 +30,7 @@
            logging.exception(e)

if __name__ == "__main__":
    q = multiprocessing.Queue()
    q = multiprocessing.Queue(maxsize=1024)
    while True:
        try:
            val = q.get_nowait()
@@ -41,7 +41,7 @@
            print("出错")

if __name__ == "__main__1":
    q = multiprocessing.Queue()
    q = multiprocessing.Queue(maxsize=1024)
    p1 = multiprocessing.Process(target=run_process1, args=(q,))
    p2 = multiprocessing.Process(target=run_process2, args=(q,))
    p3 = multiprocessing.Process(target=run_process3, args=(q,))