python 线程与进程

wcq15759797758

一.单进程单线程

1. import time
   
2. def work(n):
   
3.     print(f'{n}打电话')
   
4.     time.sleep(2)
   
5.     print(f'{n}电话结束')
   
6. uesrlist = ['刘德华','张学友','梁朝伟']
   
7. for i in uesrlist:
   
8.     work(i)

复制代码

二.多进程

1. from multiprocessing import Process
   
2. import time,os
   
3. 
   
4. uesrlist = ['刘德华','张学友','梁朝伟']
   
5. 
   
6. def work(n):
   
7.     print(f'{n}打电话,进程号为:{os.getpid()}')
   
8.     time.sleep(2)
   
9.     print(f'{n}电话结束,进程号为:{os.getpid()}')
   
10. 
    
11. def pol():
    
12.     plist = []
    
13.     for item in uesrlist:
    
14.         #循环创建进程   target 当前要执行的函数
    
15.         p = Process(target=work,args=(item,))
    
16.         #启动进程
    
17.         p.start()
    
18.         #把进程加入到列表当中
    
19.         plist.append(p)
    
20.     #阻塞终止进程的执行
    
21.     [i.join() for i in plist]
    
22. 
    
23. if __name__ == '__main__':
    
24.     pol()

复制代码

三.多线程

1. import time ,os
   
2. import threading
   
3. 
   
4. uesrlist = ['刘德华','张学友','梁朝伟']
   
5. 
   
6. def work(n):
   
7.     print(f'{n}打电话,进程号为:{os.getpid()},线程号为:{threading.current_thread()}')
   
8.     time.sleep(2)
   
9.     print(f'{n}电话结束,进程号为:{os.getpid()},线程号为:{threading.current_thread()}')
   
10. 
    
11. def pol():
    
12.     plist = []
    
13.     for item in uesrlist:
    
14.         #循环创建线程    target 当前要执行的函数
    
15.         p = threading.Thread(target=work,args=(item,))
    
16.         #生成线程
    
17.         p.start()
    
18.         #把进程加入到列表当中
    
19.         plist.append(p)
    
20.     #阻塞终止线程的执行
    
21.     [i.join() for i in plist]
    
22. 
    
23. if __name__ == '__main__':
    
24.     pol()

复制代码

四.线程池

1. import time
   
2. import threading
   
3. from concurrent.futures import ThreadPoolExecutor
   
4. 
   
5. uesrlist = ['刘德华','张学友','梁朝伟','周杰伦','苏炳添']
   
6. 
   
7. def work(n):
   
8.     print(f'{n}打电话,线程号为:{threading.current_thread()}')
   
9.     time.sleep(2)
   
10.     print(f'{n}电话结束,线程号为:{threading.current_thread()}')
    
11. 
    
12. def pol():
    
13.     # 1 . 创建线程池
    
14.     pool = ThreadPoolExecutor(max_workers=3)
    
15.     # 2 . 循环指派任务 和  参数
    
16.     [pool.submit(work,user) for user in uesrlist]
    
17.     # 3 . 关闭线程池
    
18.     pool.shutdown
    
19. 
    
20. if __name__ == '__main__':
    
21.     pol()

复制代码

hornwong

感谢分享！

超级玛尼哄

学习学习

小超超超

鸬鹚鸟

感激不尽

Kayko

waixiong

谢谢

fxj2002

龖釋

学习