高度抽象的多线程与多进程库

thread.py

"""
多进程示例
"""
import time
from multiprocessing import Pool


def run(fn):
    time.sleep(1)
    print(fn)


if __name__ == "__main__":
    testFL = range(30)
    pool = Pool(5)  # 可以同时跑N个进程
    pool.map(run, testFL)
    pool.close()
    pool.join()
    
    
"""
多线程
"""
import requests
from multiprocessing.dummy import Pool as ThreadPool

urls = [
  'https://www.baidu.com/?1',
  'https://www.baidu.com/?1',
  'https://www.baidu.com/?1',
  'https://www.baidu.com/?1',
  'https://www.baidu.com/?1',
  'https://www.baidu.com/?1',
  'https://www.baidu.com/?1',
]


pool = ThreadPool(10)
results = pool.map(requests.get, urls)
pool.close()
pool.join()