Краткий ответ

Исключение сохраняется внутри объекта Future и не выбрасывается непосредственно в вызывающем потоке. Оно станет видимым только при вызове result() или exception(); если Future никто не проверит, ошибка обычно останется незамеченной.

Исторический контекст

ThreadPoolExecutor появился как высокоуровневая абстракция над потоками: разработчику не нужно вручную управлять жизненным циклом потоков, очередью задач и передачей результатов. Объект Future решает задачу представления результата работы, которая завершится позже, включая успешное значение, исключение или отмену.

Такой подход отделяет момент отправки функции в пул от момента получения результата. Это позволяет единообразно работать с задачами в потоках и процессах.

Постановка проблемы

В обычном threading.Thread необработанное исключение рабочей функции приводит к сообщению об ошибке в потоке. В ThreadPoolExecutor поведение другое: исполнитель перехватывает исключение и записывает его в Future.

Если вызывающий код не проверяет Future, сервис может продолжить работу так, будто задача завершилась успешно. Это особенно опасно для фоновых задач: ошибка не обязательно попадёт в лог или мониторинг автоматически.

Подробное решение

При вызове submit пул помещает вызываемый объект в очередь. Рабочий поток выполняет его внутри внутренней обёртки, которая разделяет два результата: обычное возвращаемое значение записывается через set_result, а исключение — через set_exception.

Метод future.result() блокирует вызывающий поток, если работа ещё не завершена. После завершения он возвращает значение либо повторно выбрасывает сохранённое исключение в потоке, вызвавшем result().

Метод future.exception() также ждёт завершения, но возвращает сам объект исключения вместо его выбрасывания. Если Future отменён, оба метода сигнализируют об отмене соответствующим исключением CancelledError.

from concurrent.futures import ThreadPoolExecutor


def fail():
    raise ValueError("ошибка задачи")

with ThreadPoolExecutor(max_workers=1) as pool:
    future = pool.submit(fail)
    try:
        future.result()
    except ValueError as error:
        print(error)

В примере рабочий поток не передаёт исключение напрямую основному потоку. Исключение извлекается только в момент вызова result().

Важно отличать это от автоматического логирования необработанного исключения в asyncio Task: для Future из concurrent.futures полагаться на аналогичное предупреждение нельзя. Поэтому результат фоновой задачи нужно явно проверять, передавать через callback или интегрировать с системой мониторинга.

Вызов future.cancel() отменяет задачу только до начала выполнения. Уже выполняющуюся функцию он не прерывает, поэтому проверка исключений не заменяет механизм остановки самой рабочей функции.

Ситуация из практики

Сервис отправляет в пул потоков несколько операций записи во внешнюю систему и не ждёт их результаты. Возможны такие варианты:

Игнорировать Future. Это не блокирует основной поток, но ошибки записи могут быть полностью потеряны.
Для каждой задачи сразу вызывать result(). Ошибки становятся видны, однако вызывающий поток может блокироваться и терять преимущества фонового выполнения.
Зарегистрировать callback через add_done_callback. Основной поток не блокируется, а callback может проверить exception() и отправить ошибку в журнал или систему мониторинга.

Для фоновых операций обычно выбирают callback или отдельный слой сбора Future. В нём фиксируют исключения, метрики и идентификаторы операций, не заставляя основной поток синхронно ждать каждую задачу.

Что кандидаты часто упускают

Поглощает ли ThreadPoolExecutor исключение навсегда?

Нет. Он сохраняет исключение в Future вместе с трассировкой, а result() повторно выбрасывает его в вызывающем потоке. Поэтому ошибка не исчезает, но без обращения к Future приложение может о ней не узнать.

Где выполняется код обработки исключения после вызова result()?

Обработчик try/except, окружающий result(), выполняется в потоке, который вызвал этот метод, а не в рабочем потоке пула. Рабочий поток только выполняет функцию и сохраняет её результат или исключение.

Можно ли считать завершённый без исключения Future доказательством успешной бизнес-операции?

Нет. Future сообщает, что вызываемая Python-функция завершилась без исключения. Она могла вернуть значение, означающее отказ внешней системы, частичный результат или логическую ошибку, поэтому бизнес-результат нужно дополнительно проверять.