import json
|
import multiprocessing
|
import threading
|
import time
|
|
from huaxin_client import l1_client_for_trade
|
|
if __name__ == "__main__":
|
def test_sub():
|
time.sleep(10)
|
queue_l1_trade_r_strategy_w.put_nowait(
|
json.dumps({"type": "set_target_codes", "data": ["603990"]}))
|
|
def read_data():
|
while True:
|
val = queue_l1_trade_w_strategy_r.get()
|
print(val)
|
|
queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w = multiprocessing.Queue(), multiprocessing.Queue()
|
threading.Thread(target=test_sub, daemon=True).start()
|
threading.Thread(target=read_data, daemon=True).start()
|
l1_client_for_trade.run(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w)
|
