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()