QThread多任务调度问询：4线程上限场景下100个任务的执行逻辑

首先明确结论：QThread不会自动识别硬件线程上限，将100个任务调度到4个线程内执行。

你提供的测试代码如下：

import os
import sys
import time
import random
from PySide2 import QtCore, QtGui, QtWidgets


class TaskThread(QtCore.QThread):
    
    finished = QtCore.Signal(object)

    def __init__(self, index):
        super(TaskThread, self).__init__()        
        self._index = index

    def runTask(self, task):
        self._task = task

    def run(self):
        t = random.randint(0,4)
        time.sleep(t)
        self.finished.emit(self._index)


class ExampleDialog(QtWidgets.QDialog):

    def __init__(self):
        super(ExampleDialog, self).__init__()
        
        self.itemModel = QtGui.QStandardItemModel()

        self.uiListView = QtWidgets.QListView()
        self.uiListView.setModel(self.itemModel)

        self.mainLayout = QtWidgets.QVBoxLayout(self)
        self.mainLayout.addWidget(self.uiListView)

        self.populateItems()


    def populateItems(self):
        self.threads = []
        for x in range(100):
            output = 'C:/Users/JokerMartini-Asus/Desktop/Trash/thumbs/IMG_409{}.jpg'.format(x)

            # Item
            item = QtGui.QStandardItem('{}'.format(x))
            item.setData(QtGui.QPixmap(), QtCore.Qt.DecorationRole)
            item.setData(output, QtCore.Qt.UserRole)
            self.itemModel.appendRow(item)

            mIndex = QtCore.QPersistentModelIndex(self.itemModel.indexFromItem(item))
            tt = TaskThread(mIndex)
            
            self.threads.append(tt)
            tt.start()
            tt.finished.connect(self.processFinished)


    def processFinished(self, index):
        if index.isValid():
            model = index.model()
            model.setData(index, '{} updated'.format(index.row()), QtCore.Qt.DisplayRole)


if __name__ == '__main__':
    pass
    app = QtWidgets.QApplication(sys.argv)
    window = ExampleDialog()
    window.resize(300,600)
    window.show()
    window.raise_()
    sys.exit(app.exec_())

该代码中循环100次实例化TaskThread并调用start()，每次调用都会向操作系统申请创建一个独立的原生线程，最终会启动100个线程，不存在自动限流逻辑。

具体原因说明 #

• QThread是Qt对操作系统原生线程的薄封装，本身只负责控制单个线程的生命周期，没有内置任务队列、线程复用的能力，自然也没有自动根据硬件线程数调度批量任务的功能。
• 你设备的4核心限制是操作系统层面的调度规则：操作系统会把100个线程分时分配到4个CPU核心上运行，但这种调度会产生大量的上下文切换开销，额外消耗系统资源，反而会降低批量任务的整体执行效率，甚至可能因为线程数过多触发系统资源限制报错。
• 你的现有代码还存在两个隐含问题：100个QThread实例存储在列表中没有做回收逻辑，任务执行完后资源不会自动释放，会造成内存泄漏；TaskThread中定义的runTask方法没有被调用，_task属性未赋值属于无用代码。

正确实现方案 #

如果你要实现最多4个线程并发执行100个任务的需求，应该使用Qt内置的线程池组件QThreadPool，搭配QRunnable封装任务逻辑，步骤如下：

1. 自定义任务类继承QRunnable，重写run()方法实现你的耗时业务逻辑，把任务完成后的回调通过信号传递回主线程
2. 获取全局线程池实例，设置最大并发数为4：QThreadPool.globalInstance().setMaxThreadCount(4)
3. 循环创建100个任务实例，调用QThreadPool.globalInstance().start(任务实例)提交任务即可

线程池会自动复用空闲线程执行任务，所有任务会在你设置的4个线程上限内调度执行，不需要你手动管理线程的创建、销毁逻辑。如果不想手动封装QRunnable，也可以使用QtConcurrent模块的相关API，更简洁地实现批量任务的并发执行。

内容的提问来源于stack exchange，提问作者JokerMartini