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__":
|
q: queue.Queue = queue.Queue()
|
while True:
|
try:
|
temp = q.get(timeout=10)
|
except:
|
time.sleep(0.02)
|
finally:
|
pass
|
