import multiprocessing
|
import queue
|
import time
|
|
__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__":
|
p1, p2 = multiprocessing.Pipe()
|
# L1订阅数据
|
progress1 = multiprocessing.Process(target=lambda: test_process_1(p1))
|
progress2 = multiprocessing.Process(target=lambda: test_process_2(p2))
|
progress1.start()
|
progress2.start()
|
|
input()
|
