Как правильно заблокировать Qthreads в pyqt5 с помощью Python3

Question

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

Я провел некоторое исследование, и кажется, что функция должна быть потокобезопасной, и, к сожалению, моя не потому, что я использую curve_fit() из scipy, которая не является потокобезопасной. Поэтому, основываясь на том, что я прочитал на этом форуме и других, я должен использовать mutex.lock(), но при вызове функции curve_fit()

0:

Вот несколько примеров код для демонстрации того, что я сделал:

import sip 
    sip.setapi('QString', 2) 

    import sys, time 
    from PyQt5 import QtCore, QtGui, uic, QtWidgets 
    from ZthCalculation import ZthObject 

    qtCreatorFile = "PyQtZthUI_01.ui" # Enter file here. 

    Ui_MainWindow, QtBaseClass = uic.loadUiType(qtCreatorFile) 

    #class MyApp(QtGui.QMainWindow, Ui_MainWindow): 
    class MyApp(QtWidgets.QMainWindow, Ui_MainWindow): 
     def __init__(self): 
      super(self.__class__, self).__init__() 
      QtWidgets.QMainWindow.__init__(self) 
      Ui_MainWindow.__init__(self) 
      self.setupUi(self) 
      self.RunButton.clicked.connect(self.RunZthTest) 
    . 
    . 
    . 
     def RunZthTest(self): 
    #create as processes instead of threads??? 
    #   self.Process1 = QtCore.QProcess() 
      self.Thread1 = QtCore.QThread() 
      self.obj1 = ZthObject(self.InputWet1.text(), self.InputDry1.text(), self.Output1.text(), self.side1) 
      self.obj1.moveToThread(self.Thread1) 
      self.Thread1.started.connect(self.obj1.ZthCalculation) 
      self.obj1.textBox.connect(self.updateTextBox1) 
      self.signal1 = self.obj1.finished.connect(self.Thread1.quit) 
      self.Thread1.setObjectName("Thread1") 
      self.Thread1.start() 
      time.sleep(.1) 

      self.Thread2 = QtCore.QThread() 
      self.obj2 = ZthObject(self.InputWet2.text(), self.InputDry2.text(), self.Output2.text(), self.side2) 
      self.obj2.moveToThread(self.Thread2) 
      self.Thread2.started.connect(self.obj2.ZthCalculation) 
      self.obj2.textBox.connect(self.updateTextBox2) 
      self.signal2 = self.obj2.finished.connect(self.Thread2.quit) 
      self.Thread2.setObjectName("Thread2") 
      self.Thread2.start() 
      time.sleep(.1) 

      self.Thread3 = QtCore.QThread() 
      self.obj3 = ZthObject(self.InputWet3.text(), self.InputDry3.text(), self.Output3.text(), self.side3) 
      self.obj3.moveToThread(self.Thread3) 
      self.Thread3.started.connect(self.obj3.ZthCalculation) 
      self.obj3.textBox.connect(self.updateTextBox3) 
      self.signal3 = self.obj3.finished.connect(self.Thread3.quit) 
      self.Thread3.setObjectName("Thread3") 
      self.Thread3.start() 
    . 
    . 
    . 

    if __name__ == "__main__": 
     app = QtWidgets.QApplication(sys.argv) 
     window = MyApp() 
     window.show() 
    # sys.exit(app.exec_()) 
     app.exec_() 

в другом файле, у меня есть основная функция, что я называю как нить:

class ZthObject(QtCore.QObject): 
    killthread = False 
    finished = QtCore.pyqtSignal() 
    textBox = QtCore.pyqtSignal(str) 
    def __init__(self, wetFilePath, dryFilePath, outFilePath, side, parent=None): 
     super(self.__class__, self).__init__() 
     self.wetFilePath = wetFilePath 
     self.dryFilePath = dryFilePath 
     self.outFilePath = outFilePath 
     self.side = side 
     self.mutex = QtCore.QMutex() 
    def cleanup(self): 
     ZthObject.killthread = True 

# def ZthCalculation(self, wetFilePath, dryFilePath, outFilePath, side): 
    def ZthCalculation(self): 
     #calculations here 
. 
. 
. 
     print("waypoint2") 
     self.mutex.lock() 
     popt, pcov = curve_fit(Foster6, timeShort, ZthjcShort, p0 = [Rs, taus]) 
     self.mutex.unlock() 
. 
. 
. 
     self.finished.emit() 

Я могу успешно запустить код только вызывая одну нить, но если я вызываю несколько потоков, то окно вывода выводит «waypoint2» для ea ch thread, затем сбой с системной ошибкой, упомянутой выше.

Что я делаю неправильно? Нужно ли использовать отдельные процессы вместо Qthreads? Я не понимаю, как работают нитки? Я хочу, чтобы они работали в независимых переменных пространствах.

Answer 1

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

В сочетании с тем фактом, что Python GIL предотвращает истинную потоковую передачу (потоковая передача обеспечивает только ускорение скорости в Python, если ваша задача связана с IO, а не с привязкой к процессору), я бы предложил перейти к модели с несколькими процессорами.