Тайм-аут работает правильно в обоих случаях.concurrent.futures._base.TimeoutError
повышается через 5 секунд (= указанное значение времени ожидания) после вызова list(res)
.Однако при использовании диспетчера контекста (оператор with
) вызывается метод __exit__
диспетчера контекста.В этом случае он будет ожидать завершения всех потоков, прежде чем покинуть контекст и (повторно) вывести исходную ошибку.
Это можно продемонстрировать, перехватив и зарегистрировав исключение в нужных местах:
import concurrent
import logging
import time
from concurrent import futures
MAX_WORKERS = 20
def download_one(c):
logging.info('download_one(%s)' % str(c))
time.sleep(10) # Note: reduced to 10 seconds
def sub(executor):
try:
futures = executor.map(download_one, [1,2,3,4], timeout=5)
except concurrent.futures._base.TimeoutError:
logging.info('map timed out!') # this is never logged
raise
try:
results = list(futures)
except concurrent.futures._base.TimeoutError:
logging.info('list timed out!') # here it happens!
raise
logging.info(results)
logging.info('sub done')
return len(result)
def download_many1(): # without context manager
logging.info('download_many1')
executor = futures.ThreadPoolExecutor(MAX_WORKERS)
return sub(executor)
def download_many2(): # with context manager
logging.info('download_many2')
with futures.ThreadPoolExecutor(MAX_WORKERS) as executor:
return sub(executor)
logging.basicConfig(level=logging.DEBUG, format='%(asctime)-15s %(message)s')
logging.info('start 1')
try:
download_many1()
except concurrent.futures._base.TimeoutError:
logging.info('timeout!')
finally:
logging.info('1 finished\n')
logging.info('start 2')
try:
download_many2()
except concurrent.futures._base.TimeoutError:
logging.info('timeout!')
finally:
logging.info('2 finished\n')
Это выводит:
2019-04-27 21:17:20,578 start 1
2019-04-27 21:17:20,578 download_many1
2019-04-27 21:17:20,578 download_one(1)
2019-04-27 21:17:20,578 download_one(2)
2019-04-27 21:17:20,578 download_one(3)
2019-04-27 21:17:20,578 download_one(4)
2019-04-27 21:17:25,593 list timed out! # actual timeout after 5 seconds
2019-04-27 21:17:25,593 timeout! # the timeout you see at the same time
2019-04-27 21:17:25,593 1 finished
2019-04-27 21:17:25,593 start 2
2019-04-27 21:17:25,593 download_many2
2019-04-27 21:17:25,593 download_one(1)
2019-04-27 21:17:25,593 download_one(2)
2019-04-27 21:17:25,593 download_one(3)
2019-04-27 21:17:25,593 download_one(4)
2019-04-27 21:17:30,610 list timed out! # actual timeout after 5 seconds
2019-04-27 21:17:35,608 timeout! # the timeout you see 5 seconds later!!
2019-04-27 21:17:35,608 2 finished