Как обнаружить исключения в concurrent.futures в Python3?

Вот решение. Я не уверен, что тебе это нравится, но я не могу придумать ничего другого. Я изменил ваш код, чтобы он работал.

from concurrent.futures import ThreadPoolExecutor
import time

quit = False

def pri():
    print("Hello World!!!")

def start():
    while quit is not True:
        time.sleep(1)
        pri()

try:
    pool = ThreadPoolExecutor(max_workers=3)
    pool.submit(start)

    while quit is not True:
        print("hei")
        time.sleep(1)
except KeyboardInterrupt:
    quit = True

Вот пункты:

1. #P3#

   #P4# #P5#

   #P6#

   pool = ThreadPoolExecutor(max_workers=3)
   pool.submit(start)
   

2. Основной поток должен выполнять «работу», чтобы иметь возможность перехватывать Ctrl+C. Таким образом, вы не можете просто оставить основной поток и выйти, самый простой способ - запустить бесконечный цикл

3. Теперь, когда у вас есть цикл, работающий в основном потоке, когда вы нажмете CTRL+C, программа войдет в блок except KeyboardInterrupt и установит quit=True. Затем ваш рабочий поток может выйти.

Строго говоря, это всего лишь обходной путь. Мне кажется, что другого пути для этого быть не может.

Изменить
Я не уверен, что вас беспокоит, но вы можете без проблем поймать исключение в другом потоке:

import socket
import time
from concurrent.futures import ThreadPoolExecutor 
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

def con():
    try:
        raise socket.gaierror
        main()
    except socket.gaierror:
        print("gaierror occurred")
        err()

def err():
    print("err invoked")
    time.sleep(1)
    con()

def main():
    s.send("[+] Hello")

with ThreadPoolExecutor(3) as exe:
    exe.submit(con)

Выход

gaierror occurred
err invoked
gaierror occurred
err invoked
gaierror occurred
err invoked
gaierror occurred
...

Слишком поздно на вечеринку, но, может быть, это поможет кому-то еще...

Я почти уверен, что на исходный вопрос на самом деле не было ответа. Люди зациклились на том факте, что пользователь 5327424 использовал прерывание клавиатуры для возбуждения исключения, когда дело было в том, что исключение (как бы оно ни было вызвано) не было возбуждено. Например:

import concurrent.futures


def main():
    numbers = range(10)

    with concurrent.futures.ThreadPoolExecutor() as executor:
        results = {executor.submit(raise_my_exception, number): number for number in numbers}


def raise_my_exception(number):
    print('Proof that this function is getting called. %s' % number)
    raise Exception('This never sees the light of day...')


main()

Когда приведенный выше пример кода будет выполнен, вы увидите текст внутри оператора печати, отображаемый на экране, но вы никогда не увидите исключение. Это связано с тем, что результаты каждого потока хранятся в объекте results. Вам нужно повторить этот объект, чтобы добраться до ваших исключений. В следующем примере показано, как получить доступ к результатам.

import concurrent.futures


def main():
    numbers = range(10)

    with concurrent.futures.ThreadPoolExecutor() as executor:
        results = {executor.submit(raise_my_exception, number): number for number in numbers}

    for result in results:
        # This will cause the exception to be raised (but only the first one)
        print(result.result())


def raise_my_exception(number):
    print('Proof that this function is getting called. %s' % number)
    raise Exception('This will be raised once the results are iterated.')


main()

Я не уверен, нравится мне такое поведение или нет, но оно позволяет полностью выполнять потоки, независимо от исключений, возникающих внутри отдельных потоков.