Как реализовать многопоточность qt5 в python?

1
2
3
4
5
6
7
8

from PyQt5.QtCore import QThread

class MyThread(QThread):
    def __init__(self):
        super().__init__()

    def run(self):
        # здесь должен быть код, который выполнится в отдельном потоке

1
2
3
4
5
6
7
8
9

from PyQt5.QtCore import QThread

class MyThread(QThread):
    def __init__(self):
        super().__init__()

    def run(self):
        for i in range(10):
            print(i)

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

from PyQt5.QtCore import QThread

class MyThread(QThread):
    def __init__(self):
        super().__init__()

    def run(self):
        for i in range(10):
            print(i)

my_thread = MyThread()   # создаем объект класса
my_thread.start()        # запускаем поток

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

from PyQt5.QtCore import QThread, pyqtSignal

class MyThread(QThread):
    num_signal = pyqtSignal(int)

    def __init__(self):
        super().__init__()

    def run(self):
        for i in range(10):
            self.num_signal.emit(i)

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

from PyQt5.QtWidgets import QApplication, QLabel, QVBoxLayout, QWidget
from PyQt5.QtCore import Qt, pyqtSlot

class MyWidget(QWidget):
    def __init__(self):
        super().__init__()

        layout = QVBoxLayout()
        self.label = QLabel("Waiting for number...")
        layout.addWidget(self.label)

        self.thread = MyThread()             # создаем объект класса MyThread
        self.thread.num_signal.connect(self.on_num_signal)   # подключаем сигнал к слоту
        self.thread.start()                  # запускаем поток

        self.setLayout(layout)

    @pyqtSlot(int)
    def on_num_signal(self, num):
        self.label.setText(f"Got number: {num}")

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17

from PyQt5.QtWidgets import QApplication
from PyQt5.QtCore import Qt
from PyQt5.QtConcurrent import QtConcurrent

def my_function(param):
    return param * 2

def on_finished(result):
    print("Result:", result)

if __name__ == "__main__":
    app = QApplication([])

    future = QtConcurrent.run(my_function, 42)
    future.resultReadyAt.connect(on_finished)

    app.exec_()