如何等待所有BackgroundWorker完成并合并结果及传参等技术问题

问题背景 #

你通过以下VB.NET代码动态创建BackgroundWorker，但遇到两个实际问题：

1. 能否将val作为参数传递给WorkerDoWork方法？
2. 如何检查所有后台进程的完成状态，并合并各进程返回的结果集？

你的代码片段：

For Each val In clientdict.Values.Distinct
    ' deal with it.
    NumWorkers = NumWorkers + 1
    'MessageBox.Show(NumWorkers.ToString)
    ReDim Workers(NumWorkers)
    Workers(NumWorkers) = New BackgroundWorker
    Workers(NumWorkers)... ' 后续代码未完成

问题1：传递val给WorkerDoWork方法 #

当然可以！BackgroundWorker自带参数传递机制，直接按以下步骤实现就行：

1. 创建Worker实例后，绑定它的DoWork事件处理方法；
2. 调用RunWorkerAsync(val)启动任务时，把val作为参数传入；
3. 在DoWork事件方法里，通过e.Argument获取这个参数。

修改后的代码示例：

' 先定义DoWork事件处理方法
Private Sub WorkerDoWork(sender As Object, e As DoWorkEventArgs)
    ' 根据实际类型转换val，比如CType(e.Argument, String)或你的自定义类型
    Dim currentVal = e.Argument 
    ' 这里执行你的后台任务逻辑
    ' ...
    ' 如果需要返回结果，给e.Result赋值
    e.Result = ProcessedResultFromVal
End Sub

' 你的循环代码修改
For Each val In clientdict.Values.Distinct
    NumWorkers = NumWorkers + 1
    ' 用Preserve保留数组中已有的Worker实例，不然之前创建的会丢失
    ReDim Preserve Workers(NumWorkers) 
    Dim worker As New BackgroundWorker()
    worker.WorkerReportsProgress = False ' 根据需求调整
    worker.WorkerSupportsCancellation = False ' 根据需求调整
    ' 绑定DoWork事件
    AddHandler worker.DoWork, AddressOf WorkerDoWork
    ' 启动任务并传入val参数
    worker.RunWorkerAsync(val)
    Workers(NumWorkers) = worker
Next

问题2：跟踪所有任务完成状态并合并结果 #

要实现这个需求，你需要三个核心部分：

• 一个计数器记录已完成的任务数；
• 一个线程安全的集合存储结果（避免多线程写入冲突）；
• 绑定每个Worker的RunWorkerCompleted事件，在回调里更新状态，当计数器归零时触发合并逻辑。

完整实现示例：

' 类级别的变量，用来跨方法跟踪状态和存储结果
Private completedWorkerCount As Integer = 0
' 替换YourResultType为你的实际结果类型，比如DataTable、自定义类等
Private workerResults As New ConcurrentBag(Of YourResultType) 

' 定义RunWorkerCompleted事件处理方法
Private Sub WorkerCompleted(sender As Object, e As RunWorkerCompletedEventArgs)
    ' 先处理任务异常或取消的情况
    If e.Error IsNot Nothing Then
        MessageBox.Show($"任务出错：{e.Error.Message}")
    ElseIf e.Cancelled Then
        MessageBox.Show("任务已取消")
    Else
        ' 把正常返回的结果加入集合
        If e.Result IsNot Nothing Then
            workerResults.Add(CType(e.Result, YourResultType))
        End If
    End If

    ' 更新完成计数器
    completedWorkerCount += 1

    ' 检查是否所有任务都完成了
    If completedWorkerCount = NumWorkers Then
        ' 所有任务完成，执行结果合并逻辑
        MergeAndProcessResults(workerResults)
        ' 重置状态，以备后续任务使用
        completedWorkerCount = 0
        workerResults = New ConcurrentBag(Of YourResultType)
    End If
End Sub

' 自定义的结果合并方法，根据你的业务逻辑实现
Private Sub MergeAndProcessResults(results As ConcurrentBag(Of YourResultType))
    ' 这里写合并结果的代码，比如遍历集合整合数据、写入数据库等
    For Each result In results
        ' 处理单个结果
        ' ...
    Next
    MessageBox.Show("所有后台任务已完成，结果合并完毕！")
End Sub

' 你的循环代码更新（加上RunWorkerCompleted事件绑定）
For Each val In clientdict.Values.Distinct
    NumWorkers = NumWorkers + 1
    ReDim Preserve Workers(NumWorkers)
    Dim worker As New BackgroundWorker()
    worker.WorkerReportsProgress = False
    worker.WorkerSupportsCancellation = False
    AddHandler worker.DoWork, AddressOf WorkerDoWork
    ' 绑定完成事件
    AddHandler worker.RunWorkerCompleted, AddressOf WorkerCompleted
    worker.RunWorkerAsync(val)
    Workers(NumWorkers) = worker
Next

关键注意点： #

• 必须用ReDim Preserve来保留数组中已有的Worker实例，否则之前创建的Worker会被清空；
• ConcurrentBag是.NET自带的线程安全集合，适合多线程场景下添加元素；
• 记得把代码中的YourValType和YourResultType替换成你实际使用的类型。

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