import multiprocessing
|
import queue
|
import time
|
|
from l2.cancel_buy_strategy import LCancelRateManager
|
|
__queue = queue.Queue()
|
|
|
def add_data(msg):
|
time.sleep(1)
|
start_time = time.time()
|
__queue.put({"msg": msg})
|
end_time = time.time()
|
if end_time - start_time > 0.002:
|
print("加入日志耗时")
|
|
|
def test_process_1(pipe):
|
while True:
|
for i in range(10):
|
pipe.send_bytes(f"hello world:{i}".encode("utf-8"))
|
time.sleep(1)
|
|
|
def test_process_2(pipe):
|
while True:
|
results = pipe.recv_bytes()
|
if results:
|
print("接受到内容：", results)
|
|
|
if __name__ == "__main__":
|
code = "000333"
|
LCancelRateManager.set_block_limit_up_count(code, 100)
|
LCancelRateManager.set_big_num_deal_rate(code, 10)
|
print(LCancelRateManager.get_cancel_rate(code))
|
