Python/PySide : How can i destroy a terminated thread object?

Question

我想实现一个按钮来停止带有进程的线程，它可以工作但不像预期的那样:我无法删除线程对象。 (编辑: 对线程对象的引用似乎已被删除，但信号不会通过删除线程对象自动断开连接，无论如何我都可以通过信号访问它。)

我有一个带有类 thread_worker 的模块和一个作为进程运行的用于复杂处理的函数:

from PySide.QtCore import *
from PySide.QtGui import *
import multiprocessing as mp
import time

# this function runs as a process
def complex_processing(queue):
    # do something
    ...

class thread_worker(QThread):
    message_signal = Signal(str)
    stop_thread_signal = Signal()

    def __init__(self, prozessID, sleepTime, parent=None):
        super(ThreadProzessWorker, self).__init__(parent)
        self.queue = mp.Queue()
        self.process = mp.Process(target=complex_processing, args=(self.queue,))
        self.timeStamp = int(time.time())

    def run(self):
        self.process.start()
        self.process.join()

    @Slot()
    def stop_process_and_thread(self):
        if self.isRunning():
            self.message_signal.emit("Thread %d is running!" % self.timeStamp)
            if self.process.is_alive():
                self.process.terminate()
                self.process.join()      
            self.stop_thread_signal.emit()   
            #self.terminate() # does it works at this place?       
        else:
            self.message_signal.emit("Thread %d is not running!" % self.timeStamp)

我的应用程序中有两个按钮用于创建/运行和终止线程对象。

...
...
# Buttons
self.button_start_thread = QPushButton("Start Thread")
self.button_start_thread.clicked.connect(self.start_thread)
self.button_stop_thread = QPushButton("Stop Thread")
...
...
@Slot()
def start_thread(self):
    self.new_thread = thread_worker(self)
    self.button_stop_thread.clicked.connect(self.new_thread.stop_process_and_thread)
    self.new_thread.stop_thread_signal.connect(self.stop_thread)
    self.new_thread.message_signal.connect(self.print_message)
....
....
@Slot()
def stop_thread(self):
    self.new_thread.terminate()
    #self.button_stop_thread.disconnect(self.new_thread)
    del(self.new_thread)

@Slot(str)
def print_message(self, message):
    print(message)
...
...

如果我启动和停止第一个线程 - 它工作正常并终止，但如果我再次点击“停止”按钮，输出为:

Thread 1422117088 is not running!

我不明白:对象self.new_thread 是否被del(self.new_thread) 删除了？如果它被删除，我如何访问该对象？如果我再次启动并停止一个新线程，输出为:

Thread 1422117088 is not running!  # not expected, the thread object is deleted!
Thread 1422117211 is running!      # expected

现在我再做一次(开始和停止)，输出是:

Thread 1422117088 is not running!   # not expected, the thread object is deleted!
Thread 1422117211 is not running!   # not expected, the thread object is deleted!
Thread 1422117471 is running!       # expected

等等……

第一个问题:我不明白为什么不删除旧线程？为什么我可以访问它们？我认为这不好:如果后台有太多线程(未删除的对象)，我的应用程序有时会崩溃。

第二个问题:我不明白为什么如果我删除对象 self.new_thread 信号没有断开？我不想手动断开信号:如果我有很多信号，我可能会忘记断开某些信号。

第三个问题:我选择这种方式来停止一个进程的线程。有没有其他方法可以更好地做到这一点？

更新:

线程对象似乎被销毁了:

del(self.new_thread)
print(self.new_thread)
Output: AttributeError: 'MainWindow' object has no attribute 'new_thread'

但是我的信号没有断开!？ Here被描述为:“当所涉及的任何一个对象被销毁时，信号槽连接将被删除。”它在我的代码中不起作用。

Answer 1

你是对的，你的问题是你的对象没有被删除。您只删除引用 self.new_thread。问题出在这一行:

self.new_thread = thread_worker(self)

这是因为线程的父self还活着。只要 parent 还活着，对象 self.new_thread 就不会被销毁。尝试这样的事情:

self.threadParent = QObject()
self.new_thread = thread_worker(self.threadParent)

现在您还删除了父级 self.threadParent:

self.new_thread.terminate()
del(self.new_thread)
del(self.threadParent)

你的信号现在应该断开了。

您不需要以下行，因为对象 self.new_thread 在您发出信号 stop_thread_signal 后已被删除:

#self.terminate() # does it works at this place?