Корректное завершение потока

@manibashkas · Регистрация: 06.02.2018

Студворк — интернет-сервис помощи студентам

Добрый день. Пишу программу с использованием pyqt5, всего навсего кликает по заранее введённым координатам и выполняет ещё ряд функций. По нажатию кнопки старт создаётся поток и начинается цикл выполнения заданий. Вопрос как корректно завершить созданный поток? использовал метод terminate(). Цикл останавливался, поток прекращал существование. И всё вроде бы хорошо, но сама ОС периодически выкидывает ошибки о возникшей проблеме в работе программы и последующем её завершении. Как можно корректно завершить поток? пробовал оставлять флаг "стоп", но он то находится за пределами цикла и выполнение действий, соответственно, продолжается. Буду признателен за помощь, указание направления и конструктивную критику приведённого кода.
Поток:

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
class AI(QThread): 
    # create signal
    progressed = pyqtSignal(int)
    stopped = pyqtSignal()
    
    def __init__(self,params):
        super().__init__()
        self.stop_thread = False
        self.stopped.connect(self.__stop_flag)
        self.params = params
        self.cpu_parameters = self.params['CPU_parameters']
        self.symbols = params['Symbols']
        self.progress_bar_step = int(100/len(self.symbols)/int(self.params['CPU_parameters']['Optimizations_qty']))
        self.progress_bar_value = 0
        if self.params['Checkboxes']['OptimTimeLimit'] == False:
            self.params['Spinbox'] = 1000000
        
        self.do = Schedule(self.params)
        
        if self.params['Checkboxes']['OptimalF'] == True:
            self.optimal_f = OptimalFOn(self.params)
        else:
            self.optimal_f = OptimalFOff()
 
    def __stop_flag(self):
        print('time to stop! stopthread = ', self.stop_thread)
        self.stop_thread = True
            
    def __take_out_negative_reports(self):
        report_path = self.params['Report Path']
        non_profit_reports_folder = 'negative_results'
        self.do.take_out_negative_reports(report_path, non_profit_reports_folder)  
        
    def __check_negative_reports(self):
        if self.params['Checkboxes']['ProfitReports'] == True:
            self.__take_out_negative_reports()        
            
    def __change_progress_bar(self):
        self.progress_bar_value += self.progress_bar_step
        self.params['Progress bar'].setValue(self.progress_bar_value - 1)
 
    # optimization actions         
    def __symbol_optimization(self, symbol):
        i = 0
        while i < int(self.params['CPU_parameters']['Optimizations_qty']):
            self.do.optimization()
            if self.do.screenshot():
                self.do.profit_report(symbol, i)
                self.do.on_tester_report(symbol,i)
                self.do.optimiz_with_mark_click(i, symbol)
            else:
                self.do.optimiz_without_mark_click(i, symbol)
            self.__change_progress_bar()
            i+=1
                
    def __make_optimal_f_report(self):
        self.optimal_f.do()
        
    # run thread
    def run(self):
        #while self.stopped.Event() == False:
        #while self.stop_thread == False:
        try:
            for symbol in self.symbols:
                self.progressed.emit(self.__symbol_optimization(symbol))
            self.progressed.emit(self.__make_optimal_f_report())
            self.progressed.emit(self.__check_negative_reports())
        except:
            if self.stop_thread == True:
                return

Поток создаётся в методе start_ai_clicked(), привязанному к кнопке старт, завершить его нужно нажатием кнопки Destroy.

Python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
class Wingman(QMainWindow):
    # click objects 
    objects_list = ['Start', 'OptimizResult','ScreenShot','Drawdown','ProfitResult',
                    'OnTesterResult','UnderArrow','Arrow','BestResult','SwitchModel',
                    'Report','ReportRightClick','Settings', 'OptimizedSymbol','OptimizationMark', 
                    'ExpertProperties', 'MonManType', 'MonManValue']  
    # cpu parameters entry
    check_cpu_dict = {'ProcName': '', 'CheckCPUTimer': '', 'ProcPerc': '', 'CollectingTimer': '', 'Optimizations_qty': ''}    
    # glabal vars
    objects_dict = {} # create dict in the kind: Object: {X-coord: , Y-coord: }
    symbols = [] # enetred symbols
    optimization_type = '' # optimization model
    test_type = '' # test model
    checkboxes = {'OptimalF': '', 'ProfitReports': '', 'OptimTimeLimit': ''}
    limit_hour = ''
    terminal_path = ''
    report_path = ''
    stop_thread = ''
    ai_params = {}
    
    def __init__(self):
        super(Wingman,self).__init__()
        # load clicker interface
        loadUi('wingman.ui',self)
        # Set AI title
        self.setWindowTitle('AI')
        # save/load buttons connect to appropriate methods
        self.Save_params.clicked.connect(self.save_button_clicked)
        self.Load_params.clicked.connect(self.load_button_clicked)
        # create objects parameters: 'click object': X-coord, Y-coord
        self.objects_dict = {name:{'X': '', 'Y': ''} for name in self.objects_list}
        # start ai button connect to optimization's thread
        self.StartAI.clicked.connect(self.start_ai_clicked)
        # destroy ai button connect to stop optimization's thread
        self.DestroyAI.clicked.connect(self.on_finished)   
        
        self.progressBar.setValue(0)
    @pyqtSlot()
    def start_ai_clicked(self):
        self.set_params()
        # create thread
        self.thread = AI(self.ai_params)
        # connect thread with signal
        self.thread.progressed.connect(self.on_progress)
        # connect thread with finished actions
        self.thread.finished.connect(self.on_finished)
        # run thread
        self.thread.start()
            
    def on_finished(self):
        # disconnect slot/signal
        #self.thread.progressed.disconnect(self.on_progress)
        #self.thread.finished.disconnect(self.on_finished)
        # kill thread
        self.thread.stopped.emit()
        #self.stop_thread = True
        #self.thread.terminate()
        #self.thread = None
        
    # thread signal handler    
    def on_progress(self,signal):
        time.sleep(1)
###    
    def save_button_clicked(self):
        # save coordinates and symbols into separete files
        self.get_coordinates()
        self.get_optimized_symbols()
        # create save-data object
        save = SaveData(coordinates=self.objects_dict,symbols= self.symbols)
        # start saving
        save.do()
     
    def load_button_clicked(self):
        # load coordinates and symbols from files
        load = LoadData()
        self.objects_dict = load.load_coordinates()
        self.symbols = load.load_symbols()
        # set data into its place in main window
        self.set_coordinates()
        self.set_symbols()
###        
    def set_coordinates(self):
        for obj in self.objects_dict:
            getattr(self,'{}X'.format(obj)).setText(self.objects_dict[obj]['X'])
            getattr(self,'{}Y'.format(obj)).setText(self.objects_dict[obj]['Y'])      
            
    def set_symbols(self):
        self.Symbols.setText(','.join(self.symbols)) 
        
    def set_params(self):
        self.get_entered_data()
        self.ai_params = {'Coordinates': self.objects_dict, 'CPU_parameters': self.check_cpu_dict,
                          'Optimization Type': self.optimization_type, 'Test Type': self.test_type,
                          'Symbols': self.symbols, 'Checkboxes': self.checkboxes, 'Spinbox': self.limit_hour,
                          'Progress bar': self.progressBar, 'Terminal Path': self.terminal_path,
                          'Report Path': self.report_path}
###      
    def keyPressEvent(self, event):
        # insert coordinates into empty space in series from top to bottom in 'coordinates' field
        if event.key() == QtCore.Qt.Key_Return:
            self.insert_by_cursor_hover()   
            
    def insert_by_cursor_hover(self):
        x_coord_for_paste, y_coord_for_paste = win32api.GetCursorPos()
        
        for obj in self.objects_dict:
            if getattr(self,'{}X'.format(obj)).text() == '': 
                getattr(self,'{}X'.format(obj)).setText('{}'.format(x_coord_for_paste))
                getattr(self,'{}Y'.format(obj)).setText('{}'.format(y_coord_for_paste))
                break  
###                 
    def get_entered_data(self):
        # get data from main window
        self.get_coordinates()
        self.get_optimized_symbols()
        self.get_cpu_parameters()
        self.get_optimization_type()
        self.get_test_type()
        self.get_checkboxes_state()
        self.get_spinbox_value()   
        self.get_path()
        
    def get_coordinates(self):
        for obj in self.objects_dict:
            self.objects_dict[obj]['X'] = getattr(self,'{}X'.format(obj)).text()
            self.objects_dict[obj]['Y'] = getattr(self,'{}Y'.format(obj)).text() 
    
    def get_optimized_symbols(self):
        self.symbols = self.Symbols.toPlainText().split(',')
        
    def get_cpu_parameters(self):
        for name in self.check_cpu_dict:
            self.check_cpu_dict[name] = getattr(self,name).text()     
            
    def get_optimization_type(self):
        self.optimization_type = self.OptimizeBy.currentText()
    
    def get_test_type(self):
        self.test_type = self.TestBy.currentText()
        
    def get_checkboxes_state(self):
        self.checkboxes['OptimalF'] = self.OptimalF.isChecked()
        self.checkboxes['ProfitReports'] = self.ProfitReports.isChecked()
        self.checkboxes['OptimTimeLimit'] = self.OptimTimeLimit.isChecked()
        
    def get_spinbox_value(self):
        self.limit_hour = self.LimitHours.value()
        
    def get_path(self):
        self.terminal_path = r'{}'.format(self.TerminalPath.text())
        self.report_path = r'{}'.format(self.ReportPath.text())
 
if __name__ == '__main__':
    app = QtCore.QCoreApplication.instance()
    if app is None:
        app = QApplication(sys.argv)
    ex = Wingman()
    ex.show()
    app.exec_()

Новые блоги и статьи Все статьи Все блоги /
Модель микоризы: классовый агентный подход anaschu 02.01.2026 Раньше это было два гриба и бактерия. Теперь три гриба, растение. И на уровне агентов добавится между грибами или бактериями взаимодействий. До того я пробовал подход через многомерные массивы,. . .	Учёным и волонтёрам проекта «Einstein@home» удалось обнаружить четыре гамма-лучевых пульсара в джете Млечного Пути Programma_Boinc 01.01.2026 Учёным и волонтёрам проекта «Einstein@home» удалось обнаружить четыре гамма-лучевых пульсара в джете Млечного Пути Сочетание глобально распределённой вычислительной мощности и инновационных. . .	Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Programma_Boinc 28.12.2025 Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Налог на собак: https:/ / ********/ gallery/ V06K53e Финансовый отчет в Excel: https:/ / ********/ gallery/ bKBkQFf Пост отсюда. . .	Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США. Programma_Boinc 26.12.2025 Нашел на реддите интересную статью под названием Anyone know where to get a free Desktop or Laptop? Ниже её машинный перевод. После долгих разбирательств я наконец-то вернула себе. . .	Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка. Programma_Boinc 23.12.2025 Рецензия / Мнение/ Перевод Нашел на реддите интересную статью под названием The Thinkpad X220 Tablet is the best budget school laptop period . Ниже её машинный перевод. Thinkpad X220 Tablet —. . .
PhpStorm 2025.3: WSL Terminal всегда стартует в ~ and_y87 14.12.2025 PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .	Как объединить две одинаковые БД Access с разными данными VikBal 11.12.2025 Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.	Новый ноутбук volvo 07.12.2025 Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro	Музыка, написанная Искусственным Интеллектом volvo 04.12.2025 Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .	От async/await к виртуальным потокам в Python IndentationError 23.11.2025 Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .