python自帶的線程池和進程池

#python自帶的線程池
from multiprocessing.pool import ThreadPool #注意ThreadPool不在threading模塊下
from multiprocessing import Pool #導入進程池

def func(*args,**kwargs):
    print(args,kwargs)

pool=ThreadPool(2)
#pool=Pool(2) ##進程池
pool.apply_async(func,args=(1,2),kwds={})  #注意這里是kwds,不是kwargs

pool.close() #在join之前，必須要close一下，不允許再提交任務了，關閉提交任務的通道
pool.join()

###特別注意，進程池和線程池是在Linux上的東西，上面的代碼要想在win上運行，可用如下方法（只是一小部分兼容）：
if __name__=='__main__':
    pool = ThreadPool(2)
    pool.apply_async(func, args=(1, 2), kwds={})
    pool.close()
    pool.join()