进程池

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()