WaitAll cho nhiều xử lý trên một chuỗi STA không được hỗ trợ

Question

1. Tại sao tôi nhận được thông báo lỗi này? "WaitAll cho nhiều xử lý trên một chuỗi STA không được hỗ trợ."
2. Tôi có nên sử dụng [MTAThreadAttribute] không? Cập nhật: Không được làm việc với các ứng dụng WPF!

Lưu ý: Lỗi ở dòng WaitHandle.WaitAll (doneEvents); Tôi đang sử dụng dự án WP2 tiêu chuẩn.

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!"); 
} 

Cập nhật: Các giải pháp sau đây không hoạt động cho các ứng dụng WPF! Không thể thay đổi thuộc tính ứng dụng chính thành MTAThreadAttribute. Điều này sẽ dẫn đến lỗi sau:

Lỗi: "WaitAll cho nhiều xử lý trên chuỗi STA không được hỗ trợ".

Answer 1

Điều gì về việc sử dụng Nhiệm vụ để thực hiện luồng cho bạn.

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 2

Sử dụng một ManualResetEvent và đợi. Đồng thời duy trì biến TaskCount được đặt thành số chuỗi công việc bạn bắt đầu, sử dụng Interlocked.Decrement trong mã chuỗi công việc là hành động cuối cùng của nhân viên và báo hiệu sự kiện nếu bộ đếm đạt đến số không, ví dụ:

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

Answer 3

tôi sẽ cấu trúc lại mã của bạn để sử dụng lớp CountdownEvent để thay thế.

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 4

Thực ra tôi sử dụng như sau để thay thế WaitHandle.WaitAll (doneEvents);

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

Answer 5

sử dụng một cái gì đó như thế này:

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);