main.py
@@ -1,5 +1,6 @@ import json import multiprocessing import pickle import threading import time @@ -26,6 +27,7 @@ while True: try: data = queue_l1_w_strategy_r.get() data = pickle.loads(data) if data.get("type") == 'set_target_codes': # [(代码, 时间戳, 价格, 总交易量, 总交易额, 买5, 卖5)] market_data_list = data["data"]["data"]