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