bitWalk's: QThreadPool と QRunnable (2) 〜 PySide6 〜

2024-02-23

QThreadPool と QRunnable (2) 〜 PySide6 〜

PySide (Qt for Python) は、Qt（キュート）の Python バインディングで、GUI などを構築するためのクロスプラットフォームなライブラリです。Linux/X11, macOS および Microsoft Windows をサポートしています。配布ライセンスは LGPL で公開されています。

以前、当ブログで PySide6 の QThreadPool と QRunnable を利用したマルチスレッディングのサンプルを紹介しました^[1]。これは、他サイトで紹介されていたサンプル [2] を自分用に判りやすく書き直したサンプルでした。

その後、意外とマルチスレッディングを必要とする機会が多く、最近の本ブログ記事でも QThreadPool をタイトルにした記事 [3] を掲載しました。しかし、あとで読み返してみるど、タイトルの QThreadPool を使うことよりも、どちらかというと mplfinance モジュールに興味が向くような内容になっていました。

今回は（主に自分自身が）テンプレート的に利用できるシンプルな QThreadPool と QRunnable のサンプルを、備忘録としてまとめました。

下記の OS 環境で動作確認をしています。

	Fedora Workstation 39	x86_64
	Python	3.12.1
	PySide6	6.6.2

サンプルを以下に示しました。

qt_threadpool_2.py

このサンプルの実行例を以下に示しました。

START ボタンをクリックすると、Worker クラスのインスタンスの処理 worker.run() は、QThreadPool クラスのインスタンス self.threadpool の start メソッドで別スレッドで開始されます。

           :
           :
        worker = Worker()
        worker.threadProgress.connect(self.on_status_update)
        worker.threadFinished.connect(self.on_completed)
        self.threadpool.start(worker)

Worker クラスは QRunnable を継承したクラスで、run メソッドを実装します。QRunnable クラスでは Singal を利用できないので、別に QObject クラスを継承した WorkerSignal クラスで必要な Signal を定義しておき、これも Worker クラスが QRunnable と一緒に継承（多重継承）します。

class WorkerSignal(QObject):
    threadFinished = Signal()
    threadProgress = Signal(int)


class Worker(QRunnable, WorkerSignal):
    def __init__(self):
        super().__init__()

    def run(self):
        for i in range(100):
            time.sleep(0.1)
            self.threadProgress.emit(i + 1)
        self.threadFinished.emit()

run メソッドの処理は、テスト用に用意した 0.1 秒の sleep の 100 回ループを開始、ループカウントを self.threadProgress シグナルで毎回 emit します。これを本体のスロットで受け取って QProgressBar のインスタンスの値を更新しています。

ループが終わると self.threadFinished を emit します。

トップへ