import time
from multiprocessing import Processdef task():print("子进程   走起！！！")time.sleep(5)print("子进程  挂掉了")if __name__ == '__main__':print("主进程   走起！！！")p = Process(target=task)p.daemon = True  # 将子进程设置为守护进程
    p.start()time.sleep(3)print("主进程  挂掉了")
# --1）如果设置为守护进程，那么主进程一旦结束，那么子进程立马也结束（代码终止执行）
# --2）如果没有设置为守护进程，那么主进程结束执行完代码之后，子进程还会继续执行子进程里面的代码

import time,random
from multiprocessing import Process,Lockdef task1(lock):lock.acquire()      # 上锁print('任务一  走起')time.sleep(random.randint(0,2))print('任务一  结束')lock.release()      # 解锁def task2(lock):lock.acquire()print('任务二  走起')time.sleep(random.randint(0,2))print('任务二  结束')lock.release()def task3(lock):lock.acquire()print('任务三  走起')time.sleep(random.randint(0,2))print('任务三  结束')lock.release()if __name__ == '__main__':lock = Lock()p1 = Process(target=task1,args=(lock,))p2 = Process(target=task2,args=(lock,))p3 = Process(target=task3,args=(lock,))p1.start()p2.start()p3.start()

from multiprocessing import Manager,Process,Lock
import timedef task(dic,lock):lock.acquire()  # 这里如果不加锁的话，可能出现多个进程刚取出来的值都是100，然后修改完都是99nums = dic["nums"]# time.sleep(2)  # 所有进程拿到100睡2秒，最后修改的数据就是99dic["nums"] = nums - 1lock.release()
if __name__ == '__main__':lock = Lock()m = Manager()    # 创建一个manager对象dic = m.dict({"nums":100})    # 括号里需要的是一个映射关系，帮我们生成一个进程间共享的字典for i in range(5):p = Process(target=task,args=(dic,lock))p.start()time.sleep(10)print(dic["nums"])

from multiprocessing import Queueq = Queue(maxsize=3)  # 创建一个队列，里面的参数表示的是队列的容量，如果不写默认无限大# 存数据 q.put() 放进去
q.put("a")
q.put("b")
q.put("c")
# q.put("d")
# 如果队列里面已经满了，你还继续往里放，他就会进入阻塞状态，一直等到队列有空位置把数据放进去# 取数据 q.get() 拿出来
print(q.get())
print(q.get())
print(q.get())
# print(q.get())
# 同样的，如果队列里面已经空了，你还继续取，它也会进入阻塞状态，一直等到队列里有数据然后取出来

q.get(block=True,timeout=2)
# 里面block参数表示的是是否阻塞，默认True（阻塞）,当设置为False时，并且队列为空时会立马抛出异常
q.put("aaa",block=True,timeout=2)
# 里面block参数表示的是是否阻塞，默认True（阻塞）,当设置为False时，并且队列为满时会立马抛出异常
# timeout 表示的时阻塞的超时时间，超过时间还是没有位置或着空的话就会抛出异常

from multiprocessing import Process,Queue
import time,random
def eater(q):for i in range(5):time.sleep(random.randint(0, 2))food = q.get()print("%s吃完了"%food)def cooker(q):for i in ["包子","骨头","土","面","刀子"]:time.sleep(random.randint(0, 2))q.put(i)print("%s做好了"%i)if __name__ == '__main__':q = Queue()cp = Process(target=cooker,args=(q,))ep = Process(target=eater,args=(q,))cp.start()ep.start()