在 Windows 服务中使用 TPL 处理多线程（概念）

Question

我有一个 vb.net 服务，它需要一些线程来分别处理每个函数调用并避免时间消耗。

我有 2 个函数需要实现线程：

在问我的问题之前，这是我的两个功能：

1- LaunchTasks() ：如果任务启动良好，则计算此任务的“NextRunDate”，否则跳过它。

'Dim oThread As Threading.Thread
For Each oRow As DataRow In oDatatable.Rows
    Dim oCLASSE_Task As New CLASSE_Task
    If oCLASSE_Task.Load(oRow.Item("Mytask")) Then

        'oThread = New Threading.Thread(AddressOf oTask.launchSteps)
        'oThread.Priority = Threading.ThreadPriority.Normal
        'oThread.Start()

        Dim oThread = System.Threading.Tasks.Task(Of Boolean).Factory.StartNew(Function() oCLASSE_Task.launchSteps())

    End If
Next
' Need to wait until all threads finish

2- 计算运行日期（）

'It's called for each object in CLASSE_Task

'Dim oThread As Threading.Thread
For Each oRow As DataRow In oDatatable.Rows
    Dim oCLASSE_Task As New CLASSE_Task
    If oCLASSE_Task.Load(oRow.Item("Mytask")) Then

        Dim oThreadTask = System.Threading.Tasks.Task(Of Boolean).Factory.StartNew(Function() oCLASSE_Task.calculateNextRunDate())

        'oThread = New Threading.Thread(AddressOf oTask.calculateNextRunDate)
        'oThread.Priority = Threading.ThreadPriority.Normal
        'oThread.Start()

    End If
Next
' Need to wait until all threads finish

我总是先调用 LaunchTask()，然后再调用 calculateRunDates()（如果我在数据库中获得新记录）。

在启动 calculateRunDates() 之前，我必须等待函数 LaunchTask() 中的所有线程完成。

• 如何使用 TPL（我以前从未使用过），比如 thread.join() 来做到这一点？

• 在这种情况下我应该使用线程还是 TPL？

• 如何在服务中使用 TPL 处理异常（类似于 that）？

注意：我的 CLASSE_Task 使用 SyncLock 锁定。

没有足够的例子使用 vb.net，主要是 C#。

希望我已经足够清楚了。

Answer 1

首先，回答您的问题：

如何使用 TPL（我以前从未使用过），比如 thread.join() 来做到这一点？

您应该为此使用task.Wait()。如果你想等待几个Tasks，你可以使用Task.WaitAll()。

在这种情况下我应该使用线程还是 TPL？

您应该使用 TPL。它更易于使用且更高效。

如何在服务中使用 TPL 处理异常？

如果Task 中的代码引发异常，然后您在该Task 上Wait()（或在多个Tasks 上WaitAll()），它将引发包含引发异常的AggregateException。如果你不打电话给Wait()，你可以使用ContinueWith()，正如你链接到的问题所暗示的那样。

---

但是对于您的代码，我认为更好的选择是使用Parallel.ForEach()：它会为您创建Tasks，它会更有效地完成它（它在迭代之间共享Tasks ) 并且您不必处理等待，因为当它返回时，所有迭代都已完成：

Parallel.ForEach(oDatatable.Rows.Cast(Of DataRow)(),
                 Sub(oRow)
                     Dim oCLASSE_Task As New CLASSE_Task
                     If oCLASSE_Task.Load(oRow.Item("Mytask")) Then
                         oCLASSE_Task.launchSteps()
                     End If
                 End Sub)

Answer 2

要等待多个任务完成，您可以使用 Task.WaitAll(...) 方法。有关示例，请参阅this。 本文还展示了如何处理任务引发的异常。将 try/catch 放在 Task.WaitAll() 周围并检查捕获的 AggregateException 以获取任务抛出的单个异常。

但是，您的代码似乎会受益于使用 Parallel.ForEach API，这将提供更智能的循环分区。简单地为每一行创建一个单独的任务可能会使线程池过载。