# -*- coding: utf-8  -*-
# -*- Author: WangHW -*-
#方式一
from multiprocessing import Process
import time
import osdef task(name):print('%s is running...'%name)print('子进程的id为:',os.getpid())print('子进程的父进程的id为:',os.getppid())time.sleep(3)print('%s is done'%name)if __name__ == '__main__':#Process(target=task, kwargs={'name':'子进程1'})#得到一个对象p = Process(target=task,args=('子进程1',))#start仅仅只是给操作系统发送了一个信号，发完信号以后父进程不会等子进程#是完全独立的两个进程
    p.start()print('主进程')print('主进程的id为:',os.getpid())print('主进程的父进程id为:',os.getppid())

# -*- coding: utf-8  -*-
# -*- Author: WangHW -*-from multiprocessing import Process
import time#用类的继承方式实现
class MyProcessing(Process):def __init__(self,name):super().__init__()self.name = name#注意名字必须叫rundef run(self):print('%s is running......'%self.name)time.sleep(3)print('%s is done...'%self.name)if __name__ == '__main__':p = MyProcessing('进程1')p.start()print('主进程')

# -*- coding: utf-8  -*-
# -*- Author: WangHW -*-
from multiprocessing import Process
import time
import osdef task(name,n):print('%s is running...'%name)time.sleep(n)print('%s is done...'% name)if __name__ == '__main__':start_time = time.time()# for i in range(5,8):#     p = Process(target=task,args=('p%s'%(i+1),i))#     p.start()#p.join()p1 = Process(target=task,args=('p1',5))p2 = Process(target=task,args=('p2',2))p3 = Process(target=task,args=('p3',3))#start仅仅是向操作系统发出信号，具体谁先执行不一定，由操作系统决定
    p1.start()p2.start()p3.start()#保证有序,看着像“串行”，但实际上还是并行:最后一行的运行时间可以验证
    p1.join()p2.join()p3.join()print('主进程开启，id为:',os.getpid())#打印出来的结果可知，程序仍然是并发执行的，不是串行执行的print('运行时间:',time.time()-start_time)

# -*- coding: utf-8  -*-
# -*- Author: WangHW -*-
from multiprocessing import Process,Lock
import json
import time#查票
def search(name):time.sleep(1)with open('whw.json','r') as f:ticket_dict =  json.load(f)print('<%s>查看到余票为:<%s>'%(name,ticket_dict['count']))#买票
def get(name):time.sleep(1)f = open('whw.json','r')ticket_dict =  json.load(f)print('<%s>查看到余票还剩余:<%s>'%(name,ticket_dict['count']))if ticket_dict['count'] > 0:ticket_dict['count'] -= 1print('<%s>购票成功！' % name)time.sleep(1)else:print('余票不足~购票失败')f.close()#保存f_new = open('whw.json','w')json.dump(ticket_dict,f_new)f_new.close()def task(name,mutex):search(name)#在购票前加锁
    mutex.acquire()get(name)#释放锁
    mutex.release()if __name__ == '__main__':mutex = Lock()for i in range(5):p = Process(target=task,args=('路人%s'%(i+1),mutex))p.start()

# -*- coding: utf-8  -*-
# -*- Author: WangHW -*-
from multiprocessing import Queue#队列中不应该放大文件，发的只是精简的消息
#可以不指定大小，但最终受限于内存的大小
q = Queue(3)
q.put('hello')
q.put({'a':1})
q.put(3333333)
#判断一下队列满没有
print(q.full())
#取出来~先进先出
print(q.get())
print(q.get())
print(q.get())

# -*- coding: utf-8  -*-
# -*- Author: WangHW -*-
from multiprocessing import Process,Queue
import timedef producer(q):for i in range(5):res = '包子%s'%itime.sleep(0.5)print('生产者生产了%s'%res)q.put(res)def consumer(q):while 1:res = q.get()if res is None:breaktime.sleep(1)print('消费者吃了%s'%res)if __name__ == '__main__':q = Queue()p1 = Process(target=producer,args=(q,))p2 = Process(target=producer,args=(q,))c1 = Process(target=consumer,args=(q,))c2 = Process(target=consumer,args=(q,))p1.start()p2.start()c1.start()c2.start()p1.join()p2.join()#有两个消费者，需要最后put两次None
    q.put(None)q.put(None)#print('主进程'.center(20,'*'))

# -*- coding: utf-8  -*-
# -*- Author: WangHW -*-
from multiprocessing import Process,JoinableQueue
import timedef producer(q):for i in range(5):res = '包子%s'%itime.sleep(0.5)print('生产者生产了%s'%res)q.put(res)q.join()def consumer(q):while 1:res = q.get()if res is None:breaktime.sleep(1)print('消费者吃了%s'%res)q.task_done()if __name__ == '__main__':q = JoinableQueue()p1 = Process(target=producer,args=(q,))p2 = Process(target=producer,args=(q,))c1 = Process(target=consumer,args=(q,))c2 = Process(target=consumer,args=(q,))#将消费者进程设置为守护进程，随着主程序一起消除c1.daemon = Truec2.daemon = Truep1.start()p2.start()c1.start()c2.start()p1.join()p2.join()