From 2f2516749615da866e96d8d24e499b7ecbb63a3e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 23 六月 2025 12:28:52 +0800
Subject: [PATCH] 默认交易模式变更/真实下单位置计算位置修改
---
test/test_mul_queue.py | 14 ++++++++++++--
1 files changed, 12 insertions(+), 2 deletions(-)
diff --git a/test/test_mul_queue.py b/test/test_mul_queue.py
index d8e6a15..6ec86f6 100644
--- a/test/test_mul_queue.py
+++ b/test/test_mul_queue.py
@@ -29,9 +29,19 @@
except Exception as e:
logging.exception(e)
-
if __name__ == "__main__":
- q = multiprocessing.Queue()
+ q = multiprocessing.Queue(maxsize=1024)
+ while True:
+ try:
+ val = q.get_nowait()
+ print(val)
+ except:
+ time.sleep(0.005)
+ q.put_nowait("123123")
+ print("鍑洪敊")
+
+if __name__ == "__main__1":
+ 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,))
--
Gitblit v1.8.0