1. ホーム
  2. python

[解決済み] PyQtのQThreadを使ったバックグラウンドスレッド

2023-06-14 22:35:08

質問

私は、PyQtで書いたguiを介して、使用している無線機とのインタフェースをとるプログラムを持っています。 明らかに、ラジオの主な機能の1つはデータを送信することですが、これを継続的に行うために、私は書き込みをループする必要があり、これはguiがハングする原因となります。私はスレッドを扱ったことがないので、これらのハングアップを取り除くために QCoreApplication.processEvents(). しかし、ラジオは送信の間にスリープする必要があるので、これらのスリープがどれくらい続くかに基づいて、guiはまだハングします。

QThread を使用してこれを修正する簡単な方法はありますか? 私は PyQt でマルチスレッドを実装する方法についてのチュートリアルを探しましたが、それらのほとんどはサーバーのセットアップを扱い、私が必要とするよりもはるかに高度なものでした。 私は正直なところ、スレッドが実行されている間に何かを更新する必要すらありません。

どのように解決するのですか?

スレッドを処理する3つの異なる簡単な方法を示す小さな例を作成しました。あなたの問題に対する正しいアプローチを見つける助けになればと思います。

import sys
import time

from PyQt5.QtCore import (QCoreApplication, QObject, QRunnable, QThread,
                          QThreadPool, pyqtSignal)


# Subclassing QThread
# http://qt-project.org/doc/latest/qthread.html
class AThread(QThread):

    def run(self):
        count = 0
        while count < 5:
            time.sleep(1)
            print("A Increasing")
            count += 1

# Subclassing QObject and using moveToThread
# http://blog.qt.digia.com/blog/2007/07/05/qthreads-no-longer-abstract
class SomeObject(QObject):

    finished = pyqtSignal()

    def long_running(self):
        count = 0
        while count < 5:
            time.sleep(1)
            print("B Increasing")
            count += 1
        self.finished.emit()

# Using a QRunnable
# http://qt-project.org/doc/latest/qthreadpool.html
# Note that a QRunnable isn't a subclass of QObject and therefore does
# not provide signals and slots.
class Runnable(QRunnable):

    def run(self):
        count = 0
        app = QCoreApplication.instance()
        while count < 5:
            print("C Increasing")
            time.sleep(1)
            count += 1
        app.quit()


def using_q_thread():
    app = QCoreApplication([])
    thread = AThread()
    thread.finished.connect(app.exit)
    thread.start()
    sys.exit(app.exec_())

def using_move_to_thread():
    app = QCoreApplication([])
    objThread = QThread()
    obj = SomeObject()
    obj.moveToThread(objThread)
    obj.finished.connect(objThread.quit)
    objThread.started.connect(obj.long_running)
    objThread.finished.connect(app.exit)
    objThread.start()
    sys.exit(app.exec_())

def using_q_runnable():
    app = QCoreApplication([])
    runnable = Runnable()
    QThreadPool.globalInstance().start(runnable)
    sys.exit(app.exec_())

if __name__ == "__main__":
    #using_q_thread()
    #using_move_to_thread()
    using_q_runnable()