1 from multiprocessing import Process
 2 import time
 3 
 4 
 5 def test(name):
 6     print(‘%s is running‘%name)
 7     time.sleep(3)
 8     print(‘%s is over‘%name)
 9 
10 """
11 windows创建进程会将代码以模块的方式 从上往下执行一遍
12 linux会直接将代码完完整整的拷贝一份
13 
14 
15 windows创建进程一定要在if __name__ == ‘__main__‘:代码块内创建  否则报错
16 """
17 if __name__ == ‘__main__‘:
18     p = Process(target=test,args=(‘egon‘,))  # 创建一个进程对象
19     p.start()  # 告诉操作系统帮你创建一个进程
20     print(‘主‘)

 1 from multiprocessing import Process
 2 import time
 3 
 4 
 5 class MyProcess(Process):
 6     def __init__(self,name):
 7         super().__init__()
 8         self.name = name
 9 
10     def run(self):
11         print(‘%s is running‘ % self.name)
12         time.sleep(3)
13         print(‘%s is over‘ % self.name)
14 
15 
16 if __name__ == ‘__main__‘:
17     p = MyProcess(‘egon‘)
18     p.start()
19     print(‘主‘)

 1 from multiprocessing import Process
 2 import time
 3 
 4 def test(name,i):
 5     print(‘%s is running‘%name)
 6     time.sleep(i)
 7     print(‘%s is over‘%name)
 8 if __name__ == ‘__main__‘:
 9     p_list = []
10     # for i in range(3):
11     #     p = Process(target=test,args=(‘进程%s‘%i,i))
12     #     p.start()
13     #     p_list.append(p)
14     # for p in p_list:
15     #     p.join()
16     p = Process(target=test,args=(‘egon‘,1))
17     p1 = Process(target=test,args=(‘kevin‘,2))
18     p2 = Process(target=test,args=(‘jason‘,3))
19     start_time = time.time()
20     p.start()  # 仅仅是告诉操作系统帮你创建一个进程 至于这个进程什么时候创  操作系统随机决定
21     p1.start()
22     p2.start()
23     p2.join()
24     p.join()
25     p1.join()
26 
27     # 主进程代码等待子进程运行结束 才继续运行
28     # p.join()  # 主进程代码等待子进程运行结束
29     print(‘主‘)
30     print(time.time() - start_time)

 1 from multiprocessing import Process,current_process
 2 import os
 3 import time
 4 
 5 
 6 def test(name):
 7     # print(‘%s is running‘%name,current_process().pid)
 8     print(‘%s is running‘%name,‘子进程%s‘%os.getpid(),‘父进程%s‘%os.getppid())
 9     time.sleep(3)
10     print(‘%s is over‘%name)
11 
12 
13 if __name__ == ‘__main__‘:
14     p = Process(target=test,args=(‘egon‘,))
15     p.start()
16     p.terminate()  # 杀死当前进程  其实是告诉操作系统帮你杀死一个进程
17     time.sleep(0.1)
18     print(p.is_alive())  # 判断进程是否存活
19     # print(‘主‘,current_process().pid)
20     print(‘主‘,os.getpid(),‘主主进程:%s‘%os.getppid())

 1 from multiprocessing import Process
 2 import time
 3 
 4 
 5 money = 100
 6 
 7 def test():
 8     global money
 9     money = 99999999
10 
11 
12 if __name__ == ‘__main__‘:
13     p = Process(target=test)
14     p.start()
15     p.join()
16     print(money)

 1 from multiprocessing import Process
 2 import time
 3 
 4 
 5 def test(name):
 6     print(‘%s总管正常活着‘%name)
 7     time.sleep(3)
 8     print(‘%s总管正常死亡‘%name)
 9 
10 
11 if __name__ == ‘__main__‘:
12     p = Process(target=test,args=(‘egon‘,))
13     p.daemon = True  # 将该进程设置为守护进程   这一句话必须放在start语句之前 否则报错
14     p.start()
15     time.sleep(0.1)
16     print(‘皇帝jason寿正终寝‘)

 1 from multiprocessing import Process,Lock
 2 import time
 3 import json
 4 
 5 # 查票
 6 def search(i):
 7     with open(‘data‘,‘r‘,encoding=‘utf-8‘) as f:
 8         data = f.read()
 9     t_d = json.loads(data)
10     print(‘用户%s查询余票为:%s‘%(i,t_d.get(‘ticket‘)))
11 
12 # 买票
13 def buy(i):
14     with open(‘data‘,‘r‘,encoding=‘utf-8‘) as f:
15         data = f.read()
16     t_d = json.loads(data)
17     time.sleep(1)
18     if t_d.get(‘ticket‘) > 0:
19         # 票数减一
20         t_d[‘ticket‘] -= 1
21         # 更新票数
22         with open(‘data‘,‘w‘,encoding=‘utf-8‘) as f:
23             json.dump(t_d,f)
24         print(‘用户%s抢票成功‘%i)
25     else:
26         print(‘没票了‘)
27 
28 
29 def run(i,mutex):
30     search(i)
31     mutex.acquire()  # 抢锁  只要有人抢到了锁 其他人必须等待该人释放锁
32     buy(i)
33     mutex.release()  # 释放锁
34 
35 
36 if __name__ == ‘__main__‘:
37     mutex = Lock()  # 生成了一把锁
38     for i in range(10):
39         p = Process(target=run,args=(i,mutex))
40         p.start()