不支持 STA 线程上的多个句柄的 WaitAll

Question

1. 为什么会收到此错误消息？ “不支持 STA 线程上的多个句柄的 WaitAll。”
2. 我应该使用 [MTAThreadAttribute] 属性吗？ 更新：不适用于 WPF 应用程序！

注意： 错误在 WaitHandle.WaitAll(doneEvents); 我正在使用标准的 WPF 项目。

private void Search()
{
    const int CPUs = 2;
    var doneEvents = new ManualResetEvent[CPUs];

    // Configure and launch threads using ThreadPool:
    for (int i = 0; i < CPUs; i++)
    {
        doneEvents[i] = new ManualResetEvent(false);
        var f = new Indexer(Paths[i], doneEvents[i]);
        ThreadPool.QueueUserWorkItem(f.WaitCallBack, i);
    }

    // Wait for all threads in pool 
    WaitHandle.WaitAll(doneEvents);
    Debug.WriteLine("Search completed!");
}

更新：以下解决方案不适用于 WPF 应用程序！ 无法将主应用程序属性更改为 MTAThreadAttribute。这将导致以下错误：

错误：“不支持 STA 线程上的多个句柄的 WaitAll。”

Answer 1

其实我用下面的来代替 WaitHandle.WaitAll(doneEvents);

foreach (var e in doneEvents)
    e.WaitOne();

Answer 2

如何使用任务为您执行线程。

http://msdn.microsoft.com/en-us/library/system.threading.tasks.task.aspx

var task1 = Task.Factory.StartNew(() => DoSomeWork());
var task2 = Task.Factory.StartNew(() => DoSomeWork());
var task3 = Task.Factory.StartNew(() => DoSomeWork());
Task.WaitAll(task1, task2, task3);

Answer 3

使用一个ManualResetEvent 并等待它。还要维护一个 TaskCount 变量，该变量设置为您启动的工作线程数，在工作线程代码中使用 Interlocked.Decrement 作为工作线程的最后一个操作，并在计数器达到零时发出事件信号，例如

// other worker actions...
if (Interlocked.Decrement(ref taskCount) == 0)
   doneEvent.Set();

Answer 4

我会重构您的代码以改用CountdownEvent 类。

private void Search() 
{ 
    const int CPUs = 2; 
    var done = new CountdownEvent(1);

    // Configure and launch threads using ThreadPool: 
    for (int i = 0; i < CPUs; i++) 
    { 
        done.AddCount();
        var f = new Indexer(Paths[i], doneEvents[i]); 
        ThreadPool.QueueUserWorkItem(
          (state) =>
          {
            try
            {
              f.WaitCallBack(state);
            }
            finally
            {
              done.Signal();
            }
          }, i); 
    } 

    // Wait for all threads in pool  
    done.Signal();
    done.Wait();
    Debug.WriteLine("Search completed!"); 
} 

Answer 5

使用这样的东西：

foreach (ITask Task in Tasks)
{
    Task.WaitHandle = CompletedEvent;
    new Thread(Task.Run).Start();
}

int TasksCount = Tasks.Count;
for (int i = 0; i < TasksCount; i++)
    CompletedEvent.WaitOne();

if (AllCompleted != null)
    AllCompleted(this, EventArgs.Empty);