import multiprocessing
|
import queue
|
import threading
|
import time
|
|
from huaxin_client import l2_data_manager
|
from log_module import async_log_util
|
from log_module.log import logger_debug
|
|
__queue = queue.Queue()
|
|
|
def read(pipe):
|
while True:
|
if not __queue.empty():
|
val = __queue.get(block=False)
|
if val:
|
print("read:", val)
|
|
|
def write(pipe):
|
while True:
|
__queue.put_nowait("123")
|
time.sleep(1)
|
break
|
|
|
if __name__ == "__main__":
|
p1, p2 = multiprocessing.Pipe()
|
t1 = threading.Thread(target=lambda: write(p1), daemon=True)
|
t1.start()
|
print("是否alive：", t1.is_alive())
|
|
threading.Thread(target=lambda: read(p2), daemon=True).start()
|
while True:
|
print("是否alive：", t1.is_alive())
|
time.sleep(1)
|
input()
|
