import threading
import time
import sys
# Функция, выполняемая в каждом потоке
def worker(counter, speed):
    while not stop_event.is_set():
        counter[0] += 1
        print(f"Thread {speed}: Counter = {counter[0]}")
        time.sleep(1 / speed)
# Создаем счетчики и событие для остановки потоков
counter1 = [0]
counter2 = [0]
counter3 = [0]
stop_event = threading.Event()
# Создаем и запускаем потоки
thread1 = threading.Thread(target=worker, args=(counter1, 1))
thread2 = threading.Thread(target=worker, args=(counter2, 2))
thread3 = threading.Thread(target=worker, args=(counter3, 3))
thread1.start()
thread2.start()
thread3.start()
# Ожидаем нажатия клавиши 'q' для остановки
try:
    while True:
        if sys.stdin.read(1) == 'q':
            stop_event.set()
            break
except KeyboardInterrupt:
    pass
# Дожидаемся завершения потоков
thread1.join()
thread2.join()
thread3.join()
print("All threads have stopped.")