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