检测线程组何时完成的最佳实践

Question

检测整组线程何时完成处理的最佳实践是什么？ 我有一个进程将查询[长时间运行的] Web 服务以获取任意数量的对象，然后需要在所有对象都成功完成时采取事务操作。 我目前正在使用 .Net 线程池中的委托异步运行它们。 同步运行它们，违背了在多个线程上运行它们的目的......我还能如何检测所有线程何时完成？ 我想使用一个计数器（又名 COM 引用计数）来增加它以到达启动的线程并在回调函数中减少它，并保留一个动态列表，其中包含对其中每个线程的引用，以显式跟踪每个线程当它们完成时，但这两个解决方案似乎都有点混乱...

感谢所有人...基于您的建议，并且需要将对象实例传递给异步线程（由下面的 ref 变量 uPL 表示），我是使用以下代码... 注意：IEEDAL.GetUsagePayloadReadings(uPL1) 是远程 Web 服务调用

    foreach (MeterChannel chgChan in chgChs)
        foreach (UsagePayload uPL in chgChan.IntervalPayloads)
        {
            ManualResetEvent txEvnt = new ManualResetEvent(false);
            UsagePayload uPL1 = uPL;
            ThreadPool.QueueUserWorkItem(
                delegate(object state)
                    {
                        if (!uPL1.HasData)
                            IEEDAL.GetUsagePayloadReadings(uPL1);
                        UsageCache.PersistPayload(uPL1);
                        SavePayLoadToProcessFolder(uPL1);
                        txEvnt.Set();
                    } );
            waitHndls.Add(txEvnt);
        }
    WaitHandle.WaitAll(waitHndls.ToArray());

Answer 1

您可以使用WaitHandle.WaitAll。

Answer 2

我见过的最好的方法是使用倒计时锁存器。 2007 年 5 月有一个非常好的描述，包括 C# 源代码MSDN 杂志的一期。

Answer 3

有几个选择。

信号量让您可以在所有线程中使用计数器。 如果您确切知道有多少个，则可以使用它来检查它们何时完成。

另一种可能的替代方案是为每个线程提供一个 ResetEvent。 只需将事件设置在线程的“末尾”，然后在主线程中检查它们即可。 不过，这可能会更困难。

Answer 4

我不知道这是否是一种“最佳实践”，但是 System.Threading.ManualResetEvent 和 System.Threading.WaitHandle 类是我发现当线程需要相互发送信号时不可或缺的两个类。 下面是如何将它们与 ThreadPool 线程一起使用的基本示例。

    List<WaitHandle> handles = new List<WaitHandle>();
    for ( int iii = 0; iii < 10; iii++ ) {
        ManualResetEvent transactionEvent = new ManualResetEvent( false );
        ThreadPool.QueueUserWorkItem( delegate( object state ) {
            // Do your work here...
            transactionEvent.Set();
        } );
        handles.Add( transactionEvent );
    }
    WaitHandle.WaitAll( handles.ToArray() );

Answer 5

Dim WaitAllEvents(1) As AutoResetEvent

Dim thread1 As Thread
Dim thread2 As Thread

thread1 = New Thread(AddressOf Thread1Worker)
thread2 = New Thread(AddressOf Thread2Worker)

WaitAllEvents(0) = New AutoResetEvent(False)
WaitAllEvents(1) = New AutoResetEvent(False)

thread1.Start()
thread2.Start()

'Main thread will wait until all instances of AutoResetEvent 
'have become signaled with a call to Set()

WaitHandle.WaitAll(WaitAllEvents)

Console.WriteLine("All threads done exiting main thread")
thread2 = Nothing
thread1 = Nothing

'...
'...

Private Sub Thread1Worker()
    Thread.Sleep(5000)
    Console.WriteLine("Thread1 done")
    WaitAllEvents(0).Set() 
End Sub

Private Sub Thread2Worker()
    Thread.Sleep(3000)
    Console.WriteLine("Thread2 done")
    WaitAllEvents(1).Set() 
End Sub