Según los desarrolladores de Qt no se recomienda derivar directamente de QThread y sobreescribir sus métodos tal y como estas haciendo. Aunque esta práctica esta bastante extendida, existen razones para evitarla en lo posible. Hay muchas alternativas pero quizás la más directa es usar moveToThread
junto a una subclase de QObject
que actuará como worker.
Recordar que se pueden y se deben usar señales para comunicar los hilos y que nunca se debe modificar de forma directa un widget desde un hilo. La aplición gráfica solo debe ser dibujada y modificada desde el hilo principal. Si desde un hilo secundario hay que actualizar algún componete de la interfaz se usaran señales u cualquier otro método que sea thread-safe(como colas).
Por otro lado recordar que QThread
no se ejecuta en un hilo independiente en si mismo, solo su método run
lo hace. QThread
solo es un contenedor, hay que tener cuidado con esto, cualquier método bloqueante no llamado de forma directa por run
bloqueará la interfaz.
Un ejemplo de una aplicación completa usando Qthread
sin usar una subclase de este:
import sys
import time
from PyQt5.QtWidgets import QApplication, QPushButton, QMainWindow, QLabel
from PyQt5.QtCore import QObject, QThread, QMutex, pyqtSignal, QRect
class Worker(QObject):
candado = QMutex()
resultado = pyqtSignal(str)
iniciado = pyqtSignal()
terminado = pyqtSignal(bool)
def __init__(self):
super(Worker, self).__init__()
self._trabajando = False
self._abortar = False
def iniciar(self):
self.candado.lock()
self._trabajando = True
self._abortar = False
self.candado.unlock()
self.iniciado.emit()
def abortar(self):
self.candado.lock()
if self._trabajando:
self._abortar = True
self.candado.unlock()
def procesar(self):
for n in range(60):
self.candado.lock()
abortar = self._abortar
self.candado.unlock()
self.resultado.emit('Contador desde hilo: {}'.format(n) )
time.sleep(0.5)
if abortar:
self.resultado.emit('Trabajo en hilo abortado')
break
else:
self.resultado.emit('Trabajo completado')
self.candado.lock()
self._trabajando = False
self.candado.unlock()
self.terminado.emit(True)
class App(QMainWindow):
def __init__(self):
super().__init__()
self.title = 'Ejemplo QThread'
self.left = 100
self.top = 100
self.width = 400
self.height = 300
self.setWindowTitle(self.title)
self.setGeometry(self.left, self.top, self.width, self.height)
boton_iniciar = QPushButton('Iniciar', self)
boton_iniciar.move(100,120)
boton_iniciar.clicked.connect(self.iniciar_hilo)
boton_detener = QPushButton('Detener', self)
boton_detener.move(210,120)
boton_detener.clicked.connect(self.detener_hilo)
self.etiqueta = QLabel(self)
self.etiqueta.setGeometry(QRect(140, 180, 400, 50))
self.etiqueta.setText('-------------------------')
self.hilo = QThread()
self.worker = Worker()
self.worker.moveToThread(self.hilo)
self.worker.resultado.connect(self.actualizar_etiqueta)
self.worker.iniciado.connect(self.hilo.start)
self.hilo.started.connect(self.worker.procesar)
self.worker.terminado.connect(self.hilo.quit)
def iniciar_hilo(self):
self.worker.iniciar()
def detener_hilo(self):
self.worker.abortar()
def actualizar_etiqueta(self, datos):
self.etiqueta.setText(datos)
if __name__ == '__main__':
app = QApplication(sys.argv)
ventana = App()
ventana.show()
sys.exit(app.exec_())
La aplicacion mustra una interfaz con dos botones y un label. Un botón permite lanzar un hilo, el otro lo detiene. El label muestra la información procesada en el hilo.
El proceso que se ejecuta en el hilo es solo un ejemplo simple, un contador de 0 a 59 con medio segundo de espera entre cada número.
El proceso se puede detener en cualquier momento. Se usa Qt5 (pyqt5) pero la idea es válida par Qt4 (pyqt4), solo habría que cambiar algunas cosas como el string que retorna la señal resultado
desde el hilo que debería ser un QString
.
Se usa un candado para modificar y acceder a las variables de control en el hilo. Posiblemente no sea necesario en este caso en el que, si no me equivoco son operaciones atómicas, no obstante no es mala práctica proteger las variables, memoria, ficheros, etc compartidos entre hilos.
Captura de la app funcionado: