From 1b3d994efcba0236537f3aac3088658bcdbfd761 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 22 十一月 2024 13:19:39 +0800
Subject: [PATCH] 设置队列元素最大个数
---
main.py | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/main.py b/main.py
index 1a98d6f..386fd0f 100644
--- a/main.py
+++ b/main.py
@@ -80,16 +80,16 @@
log.close_print()
# L2璇诲叾浠栧啓
- queue_other_w_l2_r = multiprocessing.Queue()
+ queue_other_w_l2_r = multiprocessing.Queue(maxsize=1000)
# l1
- queue_l1_w_strategy_r = multiprocessing.Queue()
- queue_l1_r_strategy_w = multiprocessing.Queue()
+ queue_l1_w_strategy_r = multiprocessing.Queue(maxsize=1000)
+ queue_l1_r_strategy_w = multiprocessing.Queue(maxsize=1000)
# 浜ゆ槗璇荤瓥鐣ュ啓
- queue_strategy_w_trade_r = multiprocessing.Queue()
- queue_strategy_w_trade_r_for_read = multiprocessing.Queue()
+ queue_strategy_w_trade_r = multiprocessing.Queue(maxsize=1000)
+ queue_strategy_w_trade_r_for_read = multiprocessing.Queue(maxsize=1000)
# 绛栫暐璇讳氦鏄撳啓
- queue_strategy_r_trade_w = multiprocessing.Queue()
+ queue_strategy_r_trade_w = multiprocessing.Queue(maxsize=1000)
# 涓嬪崟,鎾ゅ崟ipc鍦板潃
order_ipc_addr, cancel_order_ipc_addr = "ipc://trade_order.ipc", "ipc://trade_cancel_order.ipc"
--
Gitblit v1.8.0