from multiprocessing import  Process,Queue
import time,randomdef producer(name,food,p):for i in range(3):res='%s%s'%(food,i)time.sleep(random.randint(1,3))print('%s生产了%s'%(name,res))p.put(res)def customer(name,p):while True:res=p.get()if res is None:break#判断消费者是否消费完，如果消费完，就会取到NONEtime.sleep(random.randint(1,3))print('%s吃了%s'%(name,res))if __name__ == '__main__':p=Queue()p1=Process(target=producer,args=('1','葱油拌屎',p,))p2 = Process(target=producer, args=('2', '手抓屎', p,))p3 = Process(target=producer, args=('3', '飘香拌屎', p,))c1=Process(target=customer,args=('姚晓锋',p,))c2 = Process(target=customer, args=('阿飞', p,))p1.start()p2.start()p3.start()c1.start()c2.start()p1.join()p2.join()p3.join()#说明此时生产者已经生产完了p.put(None)#有几个消费者就加上几个NONE
    p.put(None)c1.join()c2.join()print('主')

from multiprocessing import  Process,JoinableQueue
import time,randomdef producer(name,food,p):for i in range(3):res='%s%s'%(food,i)time.sleep(random.randint(1,3))print('%s生产了%s'%(name,res))p.put(res)def customer(name,p):while True:res=p.get()time.sleep(random.randint(1,3))print('%s吃了%s'%(name,res))if __name__ == '__main__':p=JoinableQueue()p1=Process(target=producer,args=('1','葱油拌屎',p,))p2 = Process(target=producer, args=('2', '手抓屎', p,))p3 = Process(target=producer, args=('3', '飘香拌屎', p,))c1=Process(target=customer,args=('姚晓锋',p,))c2 = Process(target=customer, args=('阿飞', p,))c1.daemon=Truec2.daemon=Truep1.start()p2.start()p3.start()c1.start()c2.start()p1.join()p2.join()p3.join()p.join()#主进程等待队列里为空#一旦队列为空，说明消费者取完了队列，消费者没有价值了print('主')

from threading import Thread
import timedef task(name):print('%s is running'%name)time.sleep(3)print('%s is done'%name)if __name__ == '__main__':p=Thread(target=task,args=('yxf',))p.start()print('主')

from threading import Thread
import timeclass Mythread(Thread):def __init__(self,name):super().__init__()self.name=namedef run(self):print('%s is running'%self.name)time.sleep(3)print('%s is done'%self.name)if __name__ == '__main__':p=Mythread('egon')p.start()print('主')

from threading import Thread,current_thread,active_countn=100
def task():global nn=0print('子进程n=',n,current_thread())if __name__ == '__main__':p1=Thread(target=task,)p1.start()print(active_count())p1.join()print(active_count())print('主进程n=',n,current_thread())

from threading import Thread
import time
def foo():print(123)time.sleep(1)print("end123")def bar():print(456)time.sleep(3)print("end456")if __name__ == '__main__':t1=Thread(target=foo)t2=Thread(target=bar)t1.daemon=Truet1.start()t2.start()print("main-------")

from threading import Thread,Lock
import timemutex=Lock()
n=100
def task():global nmutex.acquire()temp=ntime.sleep(0.1)n=temp-1mutex.release()if __name__ == '__main__':t_l=[]for i in range(100):t=Thread(target=task)t_l.append(t)t.start()for t in t_l:t.join()print(n)