Проблема синхронизации с ManualResetEvent

Question

Я написал метод, который загружает некоторые файлы, и теперь я пытаюсь загрузить его до 5 файлов параллельно, а остальным ждать, пока предыдущие будут завершены. Я использую ManualResetEvent для этого, но когда я включаю часть syncronisation, он больше ничего не скачивает (без этого он работает).

Вот код методов:

static readonly int maxFiles = 5; 
    static int files = 0; 
    static object filesLocker = new object(); 
    static System.Threading.ManualResetEvent sync = new System.Threading.ManualResetEvent(true); 

    /// <summary> 
    /// Download a file from wikipedia asynchronously 
    /// </summary> 
    /// <param name="filename"></param> 
    public void DoanloadFileAsync(string filename) 
    { 
     ... 
     System.Threading.ThreadPool.QueueUserWorkItem(
      (o) => 
      { 
       bool loop = true; 
       while (loop) 
        if (sync.WaitOne()) 
         lock (filesLocker) 
         { 
          if (files < maxFiles) 
          { 
           ++files; 
           if (files == maxFiles) 
            sync.Reset(); 
           loop = false; 
          } 
         } 
       try 
       { 
        WebClient downloadClient = new WebClient(); 
        downloadClient.OpenReadCompleted += new OpenReadCompletedEventHandler(downloadClient_OpenReadCompleted); 
        downloadClient.OpenReadAsync(new Uri(url, UriKind.Absolute)); 
        //5 of them do get here 
       } 
       catch 
       { 
        lock (filesLocker) 
        { 
         --files; 
         sync.Set(); 
        } 
        throw; 
       } 
      }); 
    } 

    void downloadClient_OpenReadCompleted(object sender, OpenReadCompletedEventArgs e) 
    { 
     try 
     { 
      //but none of the 5 get here 
      ...Download logic... //works without the ManualResetEvent 
     } 
     finally 
     { 
      lock (filesLocker) 
      { 
       --files; 
       sync.Set(); 
      } 
     } 
    } 

я делаю что-то не так?

Он написан с Silverlight 4 для Windows Phone 7.

Edit: Там нет Семафор или SemaphoreSlim в Silverlight 4.

Answer 1

Что я имел в виду в своем комментарии, было использование медленного lock, когда вы можете использовать Interlocked. Кроме того, это будет более реалистичным.

В лучшем случае 5 загрузок активных параллельно:

public class Downloader 
{ 
private int fileCount = 0; 
private AutoResetEvent sync = new AutoResetEvent(false); 

private void StartNewDownload(object o) 
{ 
    if (Interlocked.Increment(ref this.fileCount) > 5) this.sync.WaitOne(); 

    WebClient downloadClient = new WebClient(); 
    downloadClient.OpenReadCompleted += downloadClient_OpenReadCompleted; 
    downloadClient.OpenReadAsync(new Uri(o.ToString(), UriKind.Absolute)); 
} 

private void downloadClient_OpenReadCompleted(object sender, OpenReadCompletedEventArgs e) 
{ 
    try 
    { 
    // Download logic goes here. 
    } 
    catch {} 
    finally 
    { 
    this.sync.Set(); 
    Interlocked.Decrement(ref this.fileCount); 
    } 
} 

public void Run() 
{ 
    string o = "url1"; 
    System.Threading.ThreadPool.QueueUserWorkItem(this.StartNewDownload, o); 
    Thread.Sleep(100); 

    o = "url2"; 
    System.Threading.ThreadPool.QueueUserWorkItem(this.StartNewDownload, o); 

    o = "url3"; 
    System.Threading.ThreadPool.QueueUserWorkItem(this.StartNewDownload, o); 
    Thread.Sleep(200); 

    o = "url4"; 
    System.Threading.ThreadPool.QueueUserWorkItem(this.StartNewDownload, o); 

    o = "url5"; 
    System.Threading.ThreadPool.QueueUserWorkItem(this.StartNewDownload, o); 

    o = "url6"; 
    System.Threading.ThreadPool.QueueUserWorkItem(this.StartNewDownload, o); 

    o = "url7"; 
    System.Threading.ThreadPool.QueueUserWorkItem(this.StartNewDownload, o); 
    Thread.Sleep(200); 

    o = "url8"; 
    System.Threading.ThreadPool.QueueUserWorkItem(this.StartNewDownload, o); 
    Thread.Sleep(400); 
} 
} 

Answer 2

По выглядит WaitOne() ударил, прежде чем вы создаете WebClient. Поскольку весь код, вызывающий Set(), находится внутри обработчика события или обработчика исключений, он никогда не ударит.

Возможно, вы по ошибке включили WebClient код внутри метода потока пула потоков, который должен быть вне его

System.Threading.ThreadPool.QueueUserWorkItem(
     (o) => 
     { 
      bool loop = true; 
      while (loop) 
       if (sync.WaitOne()) 
        lock (filesLocker) 
        { 
         if (files < maxFiles) 
         { 
          ++files; 
          if (files == maxFiles) 
           sync.Reset(); 
          loop = false; 
         } 
        } 

     }); 

//Have the try catch OUTSIDE the background thread. 
      try 
      { 
       WebClient downloadClient = new WebClient(); 
       downloadClient.OpenReadCompleted += new OpenReadCompletedEventHandler(downloadClient_OpenReadCompleted); 
       downloadClient.OpenReadAsync(new Uri(url, UriKind.Absolute)); 
       //5 of them do get here 
      } 
      catch 
      { 
       lock (filesLocker) 
       { 
        --files; 
        sync.Set(); 
       } 
       throw; 
      } 

Answer 3

кажется, что вы пытаетесь ограничить количество потоков, которые могут войти в свой критический раздел, файл скачать, сразу. Вместо того, чтобы пытаться использовать это оружие, используйте System.Threading.Semaphore - вот что он делает!