手把手带你了解python多进程,多线程

这篇文章主要介绍了python多线程与多进程及其区别详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

说明

相应的学习视频见链接,本文只对重点进行总结。

请添加图片描述

请添加图片描述

多进程

重点(只要看下面代码的main函数即可)

1.创建

2.如何开守护进程

3.多进程,开销大,用for循环调用多个进程时,后台cpu一下就上去了

 import time import multiprocessing import os def dance(who,num): print("dance父进程:{}".format(os.getppid())) for i in range(1,num+1): print("进行编号:{}――――{}跳舞。。。{}".format(os.getpid(),who,i)) time.sleep(0.5) def sing(num): print("sing父进程:{}".format(os.getppid())) for i in range(1,num+1): print("进行编号:{}----唱歌。。。{}".format(os.getpid(),i)) time.sleep(0.5) def work(): for i in range(10): print("工作中。。。") time.sleep(0.2) if __name__ == '__main__': # print("main主进程{}".format(os.getpid())) start= time.time() #1 进程的创建与启动 # # 1.1创建进程对象,注意dance不能加括号 # # dance_process = multiprocessing.Process(target=dance)#1.无参数 # dance_process=multiprocessing.Process(target=dance,args=("lin",3))#2.以args=元祖方式 # sing_process = multiprocessing.Process(target=sing,kwargs={"num":3})#3.以kwargs={}字典方式 # # 1.2启动进程 # dance_process.start() # sing_process.start() #2.默认-主进程和子进程是分开的,主进程只要1s就可以完成,子进程要2s,主进程会等所有子进程执行完,再退出 # 2.1子守护主进程,当主一但完成,子就断开(如qq一关闭,所有聊天窗口就没了).daemon=True work_process = multiprocessing.Process(target=work,daemon=True) work_process.start() time.sleep(1) print("主进程完成了!")#主进程和子进程是分开的,主进程只要1s就可以完成,子进程要2s,主进程会等所有子进程执行完,再退出 print("main主进程花费时长:",time.time()-start) # 

多线程

请添加图片描述

重点

1.创建

2.守护线程

3.线程安全问题(多人抢票,会抢到同一张)

 import time import os import threading def dance(num): for i in range(num): print("进程编号:{},线程编号:{}――――跳舞。。。".format(os.getpid(),threading.current_thread())) time.sleep(1) def sing(count): for i in range(count): print("进程编号:{},线程编号:{}----唱歌。。。".format(os.getpid(),threading.current_thread())) time.sleep(1) def task(): time.sleep(1) thread=threading.current_thread() print(thread) if __name__ == '__main__': # start=time.time() # # sing_thread =threading.Thread(target=dance,args=(3,),daemon=True)#设置成守护主线程 # sing_thread = threading.Thread(target=dance, args=(3,)) # dance_thread = threading.Thread(target=sing,kwargs={"count":3}) # # sing_thread.start() # dance_thread.start() # # time.sleep(1) # print("进程编号:{}主线程结束...用时{}".format(os.getpid(),(time.time()-start))) for i in range(10):#多线程之间执行是无序的,由cpu调度 sub_thread = threading.Thread(target=task) sub_thread.start() 

线程安全

由于线程直接是无序进行的,且他们共享同一个进程的全部资源,所以会产生线程安全问题(比如多人在线抢票,买到同一张)

请添加图片描述
请添加图片描述

#下面代码在没有lock锁时,会卖出0票,加上lock就正常

 import threading import time lock =threading.Lock() class Sum_tickets: def __init__(self,tickets): self.tickets=tickets def window(sum_tickets): while True: with lock: if sum_tickets.tickets>0: time.sleep(0.2) print(threading.current_thread().name,"取票{}".format(sum_tickets.tickets)) sum_tickets.tickets-=1 else: break if __name__ == '__main__': sum_tickets=Sum_tickets(10) sub_thread1 = threading.Thread(name="窗口1",target=window,args=(sum_tickets,)) sub_thread2 = threading.Thread(name="窗口2",target=window,args=(sum_tickets,)) sub_thread1.start() sub_thread2.start() 

高并发拷贝(多进程,多线程)

 import os import multiprocessing import threading import time def copy_file(file_name,source_dir,dest_dir): source_path = source_dir+"/"+file_name dest_path =dest_dir+"/"+file_name print("当前进程为:{}".format(os.getpid())) with open(source_path,"rb") as source_file: with open(dest_path,"wb") as dest_file: while True: data=source_file.read(1024) if data: dest_file.write(data) else: break pass if __name__ == '__main__': source_dir=r'C:\Users\Administrator\Desktop\注意力' dest_dir=r'C:\Users\Administrator\Desktop\test' start = time.time() try: os.mkdir(dest_dir) except: print("目标文件已存在") file_list

以上就是手把手带你了解python多进程,多线程的详细内容,更多请关注0133技术站其它相关文章!

赞(0) 打赏
未经允许不得转载:0133技术站首页 » python