- with ThreadPoolExecutor(max_workers=NUM_CONCURRENT) as executor:
- futures = {executor.submit(send_request, idx, url, data, headers) for idx, data in enumerate(data_list , 1)}
- concurrent.futures.wait(futures, return_when=concurrent.futures.FIRST_EXCEPTION)