KeyboardInterrupt несколько потоков одновременно

Question

В настоящее время я работаю с несколькими потоками, чтобы собрать данные и сохранить их в формате JSON. Цикл сбора данных бесконечен. Я хочу иметь возможность завершить все темы с помощью CTRL+C. Поэтому я создал эту простую версию с двумя циклами. Я пробовал разные вещи, но пока не могу заставить его работать. Как я могу использовать "кроме KeyboardInterrupt", чтобы остановить оба цикла одновременно? Или есть лучший вариант?

import threading
from time import sleep

number = 0 
numberino = 10

def background():
    while True:
        if number < 10:
            global number
            number=number+1
            print number
            sleep(1)
        else:
            print "10 seconds are over!"
            break

def foreground():
    while True:
        if numberino > -10:
            global numberino
            numberino=numberino-1
            print numberino
            sleep(1)
        else:
            print "20 seconds are over!"
            break


b = threading.Thread(name='background', target=background)
f = threading.Thread(name='foreground', target=foreground)

b.start()
f.start()

Answer 1

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

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

import threading
from time import sleep

number = 0 
numberino = 10
alive = True

def background():
    global number
    while alive:
        if number < 10:
            number += 1
            print number
            sleep(1)
        else:
            print "10 seconds are over!"
            break

def foreground():
    global numberino
    while alive:
        if numberino > -10:
            numberino -= 1
            print numberino
            sleep(1)
        else:
            print "20 seconds are over!"
            break

b = threading.Thread(name='background', target=background)
f = threading.Thread(name='foreground', target=foreground)

b.start()
f.start()

while alive:
    try:
        sleep(.1)
    except KeyboardInterrupt:
        alive = False

print 'Bye'