天天看点

Python学习笔记之:线程、进程、进程池的基本创建和使用1.线程 threading.Thread()2. 进程 multiprocessing.Process()3. 进程池:

1.线程 threading.Thread()

import threading

th1 = threading.Thread(target=函数名,args=(参数1,参数2,....))
th1.start()
           
注意:如果只有一个参数写成如下形式

2. 进程 multiprocessing.Process()

import multiprocessing

process = multiprocessing.Process(target=函数名,args=(参数1,参数2,....))
process.start()

           

3. 进程池:

import multiprocessing

pool = multiprocessing.Pool(6)
pool.apply(target=函数名,args=(参数1,参数2,....))		#同步的方式进行进程处理
pool.apply_async(target=函数名,args=(参数1,参数2,....))	#异步的方式进行进程处理
pool.close()   #进程池不再接受新的任务
pool.join()     #主进程要等待进程池中的进程结束后才能退出
           

必须对 Pool 先调用close()方法才能join。

进程池中使用异步方式进行才需要使用 close 和 join

继续阅读