import logging
|
import multiprocessing
|
import time
|
|
|
def run_process1(queue: multiprocessing.Queue):
|
while True:
|
try:
|
queue.put_nowait("process1")
|
time.sleep(1)
|
except Exception as e:
|
logging.exception(e)
|
|
|
def run_process2(queue: multiprocessing.Queue):
|
while True:
|
try:
|
queue.put_nowait("process2")
|
time.sleep(1)
|
except Exception as e:
|
logging.exception(e)
|
|
|
def run_process3(queue: multiprocessing.Queue):
|
while True:
|
try:
|
print(queue.get())
|
time.sleep(0.001)
|
except Exception as e:
|
logging.exception(e)
|
|
if __name__ == "__main__":
|
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,))
|
p1.start()
|
p2.start()
|
p3.start()
|
|
while True:
|
time.sleep(0.1)
|
