Реализация интерфейса с потоками

import tkinter as tk
from tkinter import ttk
from tkinter.scrolledtext import ScrolledText
import random
import threading
import queue
import time
 
class MainApp:
    def __init__(self, root):
        self.root = root
 
        self.buffer_queue = queue.Queue()
        self.producer_thread = None
        self.consumer_thread = None
        self.producer_thread_paused = False
        self.consumer_thread_paused = False
 
        self.style = ttk.Style()
        self.style.theme_use('classic')
        self.create_widgets()
 
    def create_widgets(self):
        task_label = tk.Label(self.root, text="С помощью семафорных примитивов организовать работу параллельных вычислительных потоков.\n"
                                               "Первый поток создает строку L произвольной длины с произвольным количеством букв «А» и «С», остальное - символы « ».\n"
                                               "Второй поток подсчитывает количество символов « » в строке L и выводит различные сообщения в зависимости от того, четное это количество или нет.", bg="pink", relief="groove")
        task_label.grid(row=0, column=0, columnspan=5)
 
        # Окно производителя
        self.producer_text = ScrolledText(self.root, width=40, height=20, borderwidth=2, relief="solid")
        self.producer_text.grid(row=1, column=0)
 
        # Окно потребителя
        self.consumer_text = ScrolledText(self.root, width=40, height=20, borderwidth=2, relief="solid")
        self.consumer_text.grid(row=1, column=1)
 
        # Кнопка Старт
        self.start_button = tk.Button(self.root, text="Старт", command=self.start_threads, bg="green")
        self.start_button.grid(row=2, column=0)
 
        # Кнопка Стоп
        self.stop_button = tk.Button(self.root, text="Стоп", command=self.stop_threads, bg="red")
        self.stop_button.grid(row=2, column=1)
 
        self.pause_producer_button = tk.Button(self.root, text="Пауза производителя", command=self.toggle_producer_pause, bg="grey")
        self.pause_producer_button.grid(row=2, column=2)
 
        self.pause_consumer_button = tk.Button(self.root, text="Пауза потребителя", command=self.toggle_consumer_pause, bg="grey")
        self.pause_consumer_button.grid(row=2, column=3)
 
        # Надписи для скорости производителя и потребителя
        self.producer_speed_label = tk.Label(self.root, text="Скорость производителя:")
        self.producer_speed_label.grid(row=1, column=2)
 
        self.consumer_speed_label = tk.Label(self.root, text="Скорость потребителя:")
        self.consumer_speed_label.grid(row=1, column=4)
 
        # Создание ползунков для регулирования скорости производителя и потребителя
        self.producer_speed_slider = ttk.Scale(self.root, from_=1, to=1000, orient="vertical")
        self.producer_speed_slider.set(500)
        self.producer_speed_slider.grid(row=1, column=3)
 
        self.consumer_speed_slider = ttk.Scale(self.root, from_=1, to=1000, orient="vertical")
        self.consumer_speed_slider.set(500)
        self.consumer_speed_slider.grid(row=1, column=5)
 
 
    def start_threads(self):
        if self.producer_thread is None or not self.producer_thread.is_alive():
            self.producer_thread = threading.Thread(target=self.produce_loop)
            self.producer_thread.start()
 
        if self.consumer_thread is None or not self.consumer_thread.is_alive():
            self.consumer_thread = threading.Thread(target=self.consume_loop)
            self.consumer_thread.start()
 
    def stop_threads(self):
        self.root.quit()
 
    def toggle_producer_pause(self):
        self.producer_thread_paused = not self.producer_thread_paused
        if self.producer_thread_paused:
            self.pause_producer_button.config(text="Продолжить производителя")
        else:
            self.pause_producer_button.config(text="Пауза производителя")
 
    def toggle_consumer_pause(self):
        self.consumer_thread_paused = not self.consumer_thread_paused
        if self.consumer_thread_paused:
            self.pause_consumer_button.config(text="Продолжить потребителя")
        else:
            self.pause_consumer_button.config(text="Пауза потребителя")
 
    def produce_loop(self):
        producer_line_count = 1  # Счетчик строк для потока производителя
        while True:
            if not self.producer_thread_paused:
                produced_string = self.produce()
                self.buffer_queue.put(produced_string)
                self.update_producer_text(producer_line_count, produced_string)
                producer_line_count += 1  # Увеличиваем счетчик строк
                time.sleep(self.producer_speed_slider.get() / 1000)
 
    def update_producer_text(self, line_count, produced_string):
        produced_string_with_number = f"{line_count}. {produced_string}"  # Добавляем номер строки
        self.producer_text.insert(tk.END, produced_string_with_number + '\n')
        self.producer_text.see(tk.END)  # Прокручиваем вниз
 
    def produce(self):
        length = random.randint(1, 10)
        letters = ['A', 'C', '_']
        chars = [random.choice(letters) for _ in range(length)]
        remaining_length = 10 - length
        chars.extend([' '] * remaining_length)
        produced_string = ''.join(chars)
        return produced_string
 
    def consume_loop(self):
        consumer_line_count = 1  # Счетчик строк для потока потребителя
        while True:
            if not self.consumer_thread_paused:
                consumed_string = self.buffer_queue.get()
                underscore_count = consumed_string.count('_')
                count_string = f"Количество символов \"_\" в строке: {underscore_count}\n"
                parity_string = "Количество символов \"_\" четное\n" if underscore_count % 2 == 0 else "Количество символов \"_\" нечетное\n"
                self.update_consumer_text(consumer_line_count, consumed_string, count_string, parity_string)
                consumer_line_count += 1  # Увеличиваем счетчик строк
                time.sleep(self.consumer_speed_slider.get() / 1000)
 
    def update_consumer_text(self, line_count, consumed_string, count_string, parity_string):
        consumed_string_with_number = f"{line_count}. {consumed_string}"  # Добавляем номер строки
        self.consumer_text.insert(tk.END, consumed_string_with_number + '\n')
        self.consumer_text.insert(tk.END, count_string)
        self.consumer_text.insert(tk.END, parity_string)
        self.consumer_text.see(tk.END)  # Прокручиваем вниз
 
 
if __name__ == "__main__":
    root = tk.Tk()
    app = MainApp(root)
    root.mainloop()