多线程 multiprocessing 的几个小例子

import multiprocessing as multip,time
from multiprocessing import Process,Pipe,Event,Condition,Lock,Pool,Value,Array

def pipe1(pipe):
    pipe.send(‘hello‘)
    print(‘p1.recv1‘,pipe.recv())
    pipe.send(‘what is your name??‘)
    print(‘p1.recv2‘,pipe.recv())

def pipe2(pipe):
    print(‘p2.recv1‘,pipe.recv())
    pipe.send(‘hello,too‘)
    print(‘p2.recv2‘,pipe.recv())
    pipe.send(‘i do not tell you!!‘)

if __name__==‘__main__‘:
    pipe=Pipe()

    p1=Process(target=pipe1,args=(pipe[0],))
    p2=Process(target=pipe2,args=(pipe[1],))

    p1.start()
    p2.start()
    #p1.join()
    #p2.join()

    print(‘主程序结束运行‘)

def event1(e):
    print(‘event1 开始运行：‘)
    e.wait()
    print(‘event1 等待结束：‘)

def event2(e,t):
    print(‘event2 开始运行：‘)
    e.wait(t)
    print(‘event2 等待超时结束：‘)
    e.set()

if __name__==‘__main__‘:

    e=Event()

    p1=Process(target=event1,args=(e,))
    p2=Process(target=event2,args=(e,4))
    
    p1.start()
    p2.start()

    time.sleep(3)
    print(‘主程序运行结束！‘)

def cond1(cond):
    with cond:
        print(‘cond1 开始运行‘,multip.current_process().name)
        cond.wait()
        print(‘cond1 等待结束‘,multip.current_process().name)

def cond2_notify(cond):
    with cond:
        print(‘cond2 开始运行‘,multip.current_process().name)
        cond.notify_all()#notify() 只通知一个等待的condition
        print(‘cond2 notifyall结束‘,multip.current_process().name)

if __name__==‘__main__‘:

    con=Condition()

    p1=Process(target=cond1,args=(con,))
    p2=Process(target=cond1,args=(con,))
    p3=Process(target=cond2_notify,args=(con,))
    
    p1.start()
    p2.start()
    time.sleep(4)
    p3.start()

    time.sleep(3)
    print(‘主程序运行结束！‘)

def func(lock):
#def func():
    lock.acquire()
    print(‘进程锁之后开始运行：‘,multip.current_process().name)
    time.sleep(2)
    print(‘下面释放进程锁：‘,multip.current_process().name)
    lock.release()

if __name__==‘__main__‘:

    lock=Lock()
    for i in range(10):
        p1=Process(target=func,args=(lock,))
        p1.start()
    
    time.sleep(3)
    print(‘主程序运行结束！‘)

def func(n):
    time.sleep(0.2)
    return n**2
if __name__==‘__main__‘:
    pool=Pool(3)
    ll=list(range(10))
    result=pool.map(func,ll)
    print(‘result:‘,result)