zeromq集成测试

Administrator

2024-02-27 0e7328284f9be3cf7f86e740addf7531c8ac9839

zeromq集成测试

 test/test_pyzmq.py

@@ -16,7 +16,7 @@

def create_server():
    context = zmq.Context()
    for i in range(50):
    for i in range(5):
        threading.Thread(target=lambda: __create_server(context, 10000 + i), daemon=True).start()


@@ -42,7 +42,7 @@
    time.sleep(5)
    context = zmq.Context()
    while True:
        for i in range(50):
        for i in range(5):
            threading.Thread(target=lambda: send_data(context, i), daemon=True).start()
        time.sleep(5)
    input()