PyQtは非QThreadのメインスレッドをウェイクします

Question

私は、自分のコントロール下にないスレッドから呼び出されたコールバックを介して外部ソースから情報を受け取り、QThreadではないPyQtアプリケーションを持っています。このような情報をポーリングせずにメインスレッドに渡す正しい方法は何ですか？特に、新しいデータの到着時にメインスレッド（または別のQThread）を起動できるように、Qtシグナルを出したいと思います。

Answer 1

信号のデフォルトの接続タイプは、ドキュメントは、このように記述Qt.AutoConnectionある：

の信号を受信 オブジェクトとは異なるスレッドから出射された場合、信号は次のように動作し、キューイングされQt :: QueuedConnection。 それ以外の場合は、スロットが直接呼び出され、 Qt :: DirectConnectionとして動作します。接続のタイプは、 信号が放出されたときに決定されます。

ので、信号を発する前に、Qtは、単にそれをキューイングするかどうかを決定する前に、送信者と受信者の現在スレッドの親和性を比較します。重要ではない元のスレッドが最初に開始された方法。ここで

はPythonのワーカースレッドを使用して、簡単なデモです：

import sys, time, threading 
from PyQt4 import QtCore, QtGui 

class Worker(object): 
    def __init__(self, callback): 
     self._callback = callback 
     self._thread = None 

    def active(self): 
     return self._thread is not None and self._thread.is_alive() 

    def start(self): 
     self._thread = threading.Thread(target=self.work, name='Worker') 
     self._thread.start() 

    def work(self): 
     print('work: [%s]' % threading.current_thread().name) 
     for x in range(5): 
      time.sleep(1) 
      self._callback(str(x)) 

class Window(QtGui.QPushButton): 
    dataReceived = QtCore.pyqtSignal(str) 

    def __init__(self): 
     super(Window, self).__init__('Start') 
     self.clicked.connect(self.start) 
     self.dataReceived.connect(self.receive) 
     self.worker = Worker(self.callback) 

    def receive(self, data): 
     print('received: %s [%s]' % (data, threading.current_thread().name)) 

    def callback(self, data): 
     print('callback: %s [%s]' % (data, threading.current_thread().name)) 
     self.dataReceived.emit(data) 

    def start(self): 
     if self.worker.active(): 
      print('still active...') 
     else: 
      print('start: [%s]' % threading.current_thread().name) 
      self.worker.start() 

if __name__ == '__main__': 

    app = QtGui.QApplication(sys.argv) 
    window = Window() 
    window.show() 
    print('show: [%s]' % threading.current_thread().name) 
    sys.exit(app.exec_()) 

典型的な出力：

$ python test.py 
show: [MainThread] 
start: [MainThread] 
work: [Worker] 
callback: 0 [Worker] 
received: 0 [MainThread] 
still active... 
callback: 1 [Worker] 
received: 1 [MainThread] 
still active... 
callback: 2 [Worker] 
received: 2 [MainThread] 
still active... 
callback: 3 [Worker] 
received: 3 [MainThread] 
callback: 4 [Worker] 
received: 4 [MainThread] 

Answer 2

外部デバイスやライブラリをポーリングするのと同じ方法で処理します。コールバックを処理する別のワーカースレッドを作成し、メインのGUIスレッドに信号を送信します。

class Worker(QObject): 

    data_ready = pyqtSignal(object, object) 

    def callback(self, *args, **kwargs): 
     self.data_ready.emit(args, kwargs) 


class Window(...) 

    def __init__(self): 
     ... 
     self.worker = Worker(self) 
     # Connect worker callback function to your external library 
     library.register_callback(self.worker.callback) #?? 
     ... 

     # Mover worker to thread and connect signal 
     self.thread = QThread(self) 
     self.worker.data_ready.connect(self.handle_data) 
     self.worker.moveToThread(self.thread) 
     self.thread.start() 

    @pyqtSlot(object, object) 
    def handle_data(self, args, kwargs): 
     # do something with data