默认交易模式变更/真实下单位置计算位置修改

Administrator

17 分钟以前 2f2516749615da866e96d8d24e499b7ecbb63a3e

 test/test_mul_queue.py

@@ -29,9 +29,19 @@
        except Exception as e:
            logging.exception(e)


if __name__ == "__main__":
    q = multiprocessing.Queue()
    q = multiprocessing.Queue(maxsize=1024)
    while True:
        try:
            val = q.get_nowait()
            print(val)
        except:
            time.sleep(0.005)
            q.put_nowait("123123")
            print("出错")

if __name__ == "__main__1":
    q = multiprocessing.Queue(maxsize=1024)
    p1 = multiprocessing.Process(target=run_process1, args=(q,))
    p2 = multiprocessing.Process(target=run_process2, args=(q,))
    p3 = multiprocessing.Process(target=run_process3, args=(q,))