1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
| import json
| import multiprocessing
| import threading
| import time
|
| 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()
|
|
