from multiprocessing import Lock,Process,Pipe
import time
def shuo(lock,sn,name):
lock.acquire()
sn.send("xj")
for i in range(10):
print(i)
time.sleep(0.1)
print(name)
lock.release()
if name=="main":
lock=Lock()
pr,sn=Pipe()
print("start")
for j in range(5):
p=Process(target=shuo,args=(lock,pr,"gx"))
p.start()
time.sleep(7)
print(sn.recv())
print("stop")
那年今日34
from multiprocessing import Lock,Process,Pipe import time
def shuo(lock,sn,name): lock.acquire() sn.send("xj") for i in range(10): print(i) time.sleep(0.1) print(name) lock.release() if name=="main": lock=Lock() pr,sn=Pipe() print("start") for j in range(5): p=Process(target=shuo,args=(lock,pr,"gx")) p.start() time.sleep(7) print(sn.recv()) print("stop")