# -*- coding: utf-8 -*- from concurrent.futures import ThreadPoolExecutor, wait pool_executor = ThreadPoolExecutor(max_workers=20)