我对Python还比较新，但是已经能够运行一个相当有用的程序来处理大量数据。我可以使用另一个Python脚本依次调用程序来连续运行多个数据集，但我想创建一个GUI并使用多线程使其他人可以在不知道所有编程细节的情况下使用它。我成功地创建了GUI，并可以使用信号和插槽进行双向数据馈送。我遇到的问题是使用相同函数创建多个线程。
我做了一些研究，发现该函数需要是线程安全的，不幸的是，我的函数不是线程安全的，因为我正在使用scipy中的curve_fit()，它不是线程安全的。所以，根据我在这个论坛和其他论坛上阅读到的内容，我应该使用mutex.lock()，但是当调用curve_fit()时，我会得到“SystemError: null argument to internal routine”。
以下是一些示例代码，以演示我所做的事情：
在另一个文件中，我有一个作为线程调用的主函数：
我做了一些研究，发现该函数需要是线程安全的，不幸的是，我的函数不是线程安全的，因为我正在使用scipy中的curve_fit()，它不是线程安全的。所以，根据我在这个论坛和其他论坛上阅读到的内容，我应该使用mutex.lock()，但是当调用curve_fit()时，我会得到“SystemError: null argument to internal routine”。
以下是一些示例代码，以演示我所做的事情：
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'，然后崩溃并显示上述系统错误。
我做错了什么？我需要使用单独的进程而不是Qthreads吗？我是否误解了线程的工作方式？我希望它们在独立的变量空间中运行。