进程池
import multiprocessing
def fun1(param1, param2):
# ...
pass
pool = multiprocessing.Pool(processes=30)
for num in range(100):
pool.apply_async(get_urls, (num, 123456))
pool.close()
pool.join()
线程池
import multiprocessing
def fun1(param1, param2):
# ...
pass
threadPool = ThreadPoolExecutor(max_workers=30)
for num in range(100):
future = threadPool.submit(fun1, num, 123456)
threadPool.shutdown(wait=True)
锁
from threading import Lock
lock = Lock()
在线程中:
self.lock.acquire()
self.lock.release()
发表回复