NotSupportedException on WaitHandle.WaitAll

Question

Я пытаюсь выполнить следующий код.Код пытается параллельно загружать и сохранять изображения.Я передаю список изображений для скачивания.Я написал это в C # 3.0 и скомпилировал его, используя .NET Framework 4 (VS.NET Express Edition).Операция WaitAll приводит к NotSupportedException (WaitAlll для нескольких дескрипторов потока STA не поддерживается) каждый раз, когда я пытаюсь запустить свою программу.Я попытался удалить SetMaxThreads, но это не имело никакого значения.

public static void SpawnThreads(List<string> imageList){
    imageList = new List<string>(imageList);
    ManualResetEvent[] doneEvents = new ManualResetEvent[imageList.Count];
    PicDownloader[] picDownloaders = new PicDownloader[imageList.Count];
    ThreadPool.SetMaxThreads(MaxThreadCount, MaxThreadCount);
    for (int i = 0; i < imageList.Count; i++) {
        doneEvents[i] = new ManualResetEvent(false);
        PicDownloader p = new PicDownloader(imageList[i], doneEvents[i]);
        picDownloaders[i] = p;
        ThreadPool.QueueUserWorkItem(p.DoAction);
    }
    // The following line is resulting in "NotSupportedException"     
    WaitHandle.WaitAll(doneEvents);
    Console.WriteLine("All pics downloaded");
}

Не могли бы вы дать мне понять, с чем я сталкиваюсь?

Спасибо

Answer 1

Советую не использовать несколько экземпляров WaitHandle для ожидания завершения. Вместо этого используйте класс CountdownEvent . В результате получается более элегантный и масштабируемый код. Кроме того, метод WaitHandle.WaitAll поддерживает только до 64 дескрипторов и не может быть вызван в потоке STA. Путем рефакторинга вашего кода для использования канонического шаблона я придумал следующее.

public static void SpawnThreads(List<string> imageList)
{ 
  imageList = new List<string>(imageList); 
  var finished = new CountdownEvent(1);
  var picDownloaders = new PicDownloader[imageList.Count]; 
  ThreadPool.SetMaxThreads(MaxThreadCount, MaxThreadCount); 
  for (int i = 0; i < imageList.Count; i++) 
  { 
    finished.AddCount();    
    PicDownloader p = new PicDownloader(imageList[i]); 
    picDownloaders[i] = p; 
    ThreadPool.QueueUserWorkItem(
      (state) =>
      {
        try
        {
          p.DoAction
        }
        finally
        {
          finished.Signal();
        }
      });
  } 
  finished.Signal();
  finished.Wait();
  Console.WriteLine("All pics downloaded"); 
} 

Answer 2

Вы пометили один из методов с атрибутом [STAThread]?

Answer 3

Вы пытались установить состояние квартиры для потока?

thread.SetApartmentState (System.Threading.Apartmentstate.MTA );