如何向QThreadPool的Worker传递参数与回调函数？

你的报错根源是TestWorker的run方法会以关键字参数progress_callback自动传递回调，但你的任务函数（或封装函数）没有声明接收这个参数。以下是两种直接可行的解决方案：

方案1：修改split_csv直接接收回调参数 #

如果split_csv本身需要更新进度，直接给它加上progress_callback参数（设默认值不影响原有调用）：

def split_csv(size, contracts_path, total_contracts, progress_callback=None):
    # 原有CSV拆分逻辑
    for i in range(total_contracts):
        # 执行拆分步骤
        ...
        # 需要更新进度时调用回调（假设progress_callback是带emit方法的信号）
        if progress_callback:
            progress_callback.emit(int((i+1)/total_contracts * 100))

然后用functools.partial绑定自定义参数，传递给TestWorker：

from functools import partial
from PyQt5.QtCore import QThreadPool, QRunnable

# 假设你的TestWorker实现如下
class TestWorker(QRunnable):
    def __init__(self, func):
        super().__init__()
        self.func = func

    def run(self):
        # 内部创建进度回调信号并以关键字参数传递
        from PyQt5.QtCore import pyqtSignal, QObject
        class ProgressEmitter(QObject):
            progress = pyqtSignal(int)
        emitter = ProgressEmitter()
        # 这里假设你会把emitter.progress信号连接到GUI进度条
        self.func(progress_callback=emitter)

# 绑定参数并启动任务
your_size = 1000
your_contracts_path = "./contracts.csv"
your_total = 500

worker = TestWorker(
    partial(
        split_csv,
        size=your_size,
        contracts_path=your_contracts_path,
        total_contracts=your_total
    )
)
QThreadPool.globalInstance().start(worker)

方案2：封装中间函数处理回调与自定义参数 #

如果不想修改原split_csv函数，写一个中间函数专门接收progress_callback，再调用原函数：

# 原split_csv函数（无progress_callback参数）
def split_csv(size, contracts_path, total_contracts):
    # 原有拆分逻辑
    ...

# 封装的中间函数，接收progress_callback和自定义参数
def run_split(progress_callback, size, contracts_path, total_contracts):
    # 在这里处理进度更新逻辑
    for i in range(total_contracts):
        split_csv(size, contracts_path, total_contracts)
        progress_callback.emit(int((i+1)/total_contracts * 100))

然后用lambda或partial传递参数：

用lambda的方式： #

worker = TestWorker(
    lambda progress_callback: run_split(
        progress_callback,
        size=your_size,
        contracts_path=your_contracts_path,
        total_contracts=your_total
    )
)
QThreadPool.globalInstance().start(worker)

用partial的方式（更安全，避免循环中变量捕获问题）： #

worker = TestWorker(
    partial(
        run_split,
        size=your_size,
        contracts_path=your_contracts_path,
        total_contracts=your_total
    )
)
QThreadPool.globalInstance().start(worker)

关键注意点： #

• 确保你的任务函数（不管是原函数还是封装函数）能接收progress_callback关键字参数，这是TestWorker的run方法自动传递的。
• 如果用lambda绑定参数，注意在循环创建多个worker时，要避免变量被后期赋值覆盖的问题，此时用functools.partial更可靠。

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