PySide超入門【第23回】QThreadで学ぶマルチスレッド処理と非同期プログラミング入門

from PySide6.QtWidgets import QApplication, QWidget, QLabel, QVBoxLayout, QPushButton
from PySide6.QtCore import QThread, Signal
import sys, time

# Workerクラス（別スレッドで動く処理）
class Worker(QThread):
    progress = Signal(int)  # メインスレッドへ進捗を通知

    def run(self):
        for i in range(1, 6):
            time.sleep(1)  # 重たい処理の代わり
            self.progress.emit(i)  # 結果を通知

# メインウィンドウ
class Window(QWidget):
    def __init__(self):
        super().__init__()
        self.setWindowTitle("QThreadの基本")
        self.resize(300, 200)

        self.label = QLabel("待機中…", self)
        self.button = QPushButton("開始", self)

        layout = QVBoxLayout()
        layout.addWidget(self.label)
        layout.addWidget(self.button)
        self.setLayout(layout)

        self.button.clicked.connect(self.start_thread)

    def start_thread(self):
        self.thread = Worker()
        self.thread.progress.connect(self.update_label)
        self.thread.start()

    def update_label(self, value):
        self.label.setText(f"カウント: {value}")

app = QApplication(sys.argv)
window = Window()
window.show()
sys.exit(app.exec())

thread = Worker() # Workerは別で定義したサブクラス
thread.start()  # run() が別スレッドで実行される

class Worker(QThread):
    def run(self):
        print("重たい処理を実行中…")

# 重たい処理を実行中…

thread.quit()

def __init__(self):
    self.terminate_button = QPushButton("強制終了", self)
    layout.addWidget(self.terminate_button)
    self.setLayout(layout)
    self.terminate_button.clicked.connect(self.terminate_thread)

def terminate_thread(self):
    self.thread.terminate()

self.thread.start()
self.thread.wait()  # スレッドが終わるまでここで止まる

self.thread = Worker()
self.thread.start()
print(self.thread.isRunning())  # True が返る

# True

self.thread = Worker()
self.thread.start()
self.thread.wait()
print(self.thread.isFinished())  # True が返る

# True

self.thread.start()
print(QThread.currentThread())  # 現在のスレッドを取得

# <PySide6.QtCore.QThread(0x23c1df97500, name = "Qt mainThread") at 0x0000023C1E5C4180>

class Worker(QThread):
    def run(self):
        print("処理1")
        QThread.msleep(500)  # 0.5秒スリープ
        print("処理2")
        print('重たい処理を実行中...')

# 処理1
# 処理2
# 重たい処理を実行中...

class Worker(QThread):
    def run(self):
        print("処理1")
        QThread.msleep(500)  # 0.5秒スリープ
        print("処理2")
        QThread.sleep(2)  # 2秒停止
        print('重たい処理を実行中...')

# 処理1
# 処理2
# 重たい処理を実行中...

class Worker(QThread):
    def run(self):
        print("高速処理")
        QThread.usleep(100)  # 100マイクロ秒停止

# 高速処理

self.thread = Worker()
self.thread.setPriority(QThread.HighestPriority)
self.thread.start()

print(self.thread.priority())]
# Priority.InheritPriority

self.thread = Worker()
self.thread.finished.connect(lambda: print("スレッドが終了しました"))
self.thread.start()

# スレッドが終了しました

self.thread = Worker()
self.thread.started.connect(lambda: print("スレッドが開始しました"))
self.thread.start()

# スレッドが開始しました