标签：lease 返回 其他 bye sea name 回收 tick app
多道技术
1.空间上的复用: 多个程序共用一套计算机硬件
2.时间上的复用: 切换+保存状态
1.当一个程序遇到IO操作,操作系统会剥夺该程序的cpu执行权限(提高了cpu的利用率 并且也不影响程序的执行效率)
2.当一个程序长时间占用cpu 操作系统也会剥夺该程序的cpu执行权限(降低了程序的执行效率)
并发:看起来像同时运行的就可以
并行:真正意义上的同时执行
单核的计算机能不能实现并行,但是可以实现并发
同步异步:表示的是任务的提交方式
同步:任务提交之后 原地等待的任务的执行并拿到返回结果才走 期间不做任何事(程序层面的 表现就是卡住了)
异步:任务提交之后 不再原地等待 而是继续执行下一行代码(结果是要的 但是是用过其他方式 获取)
阻塞非阻塞:表示的程序的运行状态
阻塞:阻塞态
非阻塞:就绪态 运行态
创建进程的两种方式
# 创建进程会将代码以模块的方式从上往下执行一遍 方式一 from multiprocessing import Process import time def test(name): print(‘%s‘%name) time.sleep(1) print(‘hi‘) if __name__ == ‘__main__‘: #在创建进程时,在if __name__ == ‘__main__‘:内创建 p = Process(target=test,args=(‘egon‘,)) #创建一个进程对象 p.start() #告诉操作系统,要创建一个进程 time.sleep(1) print(‘hello‘) 方式二 from multiprocessing import Process import time class MyClass(Process): def __init__(self,name): super().__init__() self.name = name def test(self): print(‘%s‘%self.name) time.sleep(1) print(‘hi‘) if __name__ == ‘__main__‘: p = MyClass(‘egon‘) p.start() p.test() print(‘gun‘)
join方法是先执行完子程序之后. 在执行主程序
from multiprocessing import Process import time def test(name,i): time.sleep(i) print(‘hello‘) if __name__ == ‘__main__‘: # p_list = [] # for i in range(3): # p = Process(target=test,args=(‘进程‘,i)) # p.start() # p_list.append(p) # for p in p_list: # p.join() # print(‘gun‘) p = Process(target=test,args=(‘egon‘,1)) p1 = Process(target=test,args=(‘jason‘,2)) start_time = time.time() p.start() p1.start() p.join() p1.join() print(‘hi‘) print(time.time()-start_time)
进程对象的其他方法
from multiprocessing import Process,current_process import os import time def test(name): print(‘%s‘%name,current_process().pid,‘子进程%s‘%os.getpid(),‘父进程%s‘%os.getppid()) time.sleep(2) print(‘hello‘) if __name__ == ‘__main__‘: p = Process(target=test,args=(‘egon‘,)) p.start() time.sleep(1) p.terminate() # 杀死当前进程,本质是让操作系统帮你去杀死一个进程 time.sleep(1) print(p.is_alive()) # 判断进程是否存活 print(‘gun‘)
僵尸进程与孤儿进程
父进程回收子进程资源的两种方式
1.join方法
2.父进程正常死亡
所有的进程都会步入僵尸进程
孤儿进程
子进程没死 父进程意外死亡
针对linux会有儿童福利院(init) 如果父进程意外死亡他所创建的子进程都会被福利院收养
守护进程
from multiprocessing import Process import time def test(name): print(‘%s‘%name) time.sleep(1) print(‘%s‘%name) if __name__ == ‘__main__‘: p = Process(target=test,args=(‘egon‘,)) p.daemon = True # 将该进程设置为守护进程 p.start() time.sleep(1) print(‘bye‘)
互斥锁
当多个进程操作同一份数据的时候 会造成数据的错乱
这个时候必须加锁处理
将并发变成串行
虽然降低了效率但是提高了数据的安全
注意:
1.锁不要轻易使用 容易造成死锁现象
2.只在处理数据的部分加锁 不要在全局加锁
锁必须在主进程中产生 交给子进程去使用
from multiprocessing import Process,Lock import time import json def search(i): with open(‘data‘,‘r‘,encoding=‘utf-8‘)as f: data = f.read() t_d = json.loads(data) print(‘用户%s查询余票%s‘%(i,t_d.get(‘ticket‘))) def buy(i): with open(‘data‘,‘r‘,encoding=‘utf-8‘)as f: data = f.read() t_d = json.loads(data) time.sleep(1) if t_d.get(‘ticket‘) > 0: t_d[‘ticket‘] -= 1 with open(‘data‘,‘w‘,encoding=‘utf-8‘)as f: json.dump(t_d,f) print(‘抢票成功‘) else: print(‘没票了‘) def run(i,mutex): search(i) mutex.acquire() # 抢锁 buy(i) mutex.release() #释放锁 if __name__ == ‘__main__‘: mutex = Lock() #生成一把锁 for i in range(10): p = Process(target=run,args=(i,mutex)) p.start() data文本文档 {"ticket": 0}
标签：lease 返回 其他 bye sea name 回收 tick app
原文地址：https://www.cnblogs.com/zrh-960906/p/11329407.html
