замок Приобретать при выходе WaitOne

Question

У меня есть планировщик задач реализован так:

private readonly List<Task> mTasks = new List<Task>(); 
    private readonly ManualResetEvent mNoTaskEvent = new ManualResetEvent(false); 

    public void AddTask(Task task) 
    { 
    lock (mTasks) 
    { 
     mTasks.Add(task); 
     mNoTaskEvent.Set(); 
    } 
    } 

    public void RemoveTask(Task task) 
    { 
    lock (mTasks) 
    { 
     mTasks.Remove(task); 
     if (mTasks.Count == 0) 
      mNoTaskEvent.Reset(); 
    } 
    } 

    void BackgroundThreadProc() 
    { 
    while (mRunning) 
    { 
     mNoTaskEvent.WaitOne(); 

     if (!mRunning) break; 

     Task nextTask; 

     lock (mTasks) 
     { 
      mTasks.Sort(...); 
      nextTask = mTasks.First(); 
     } 

     nextTask.Run(); 
    } 
    } 

mNoTaskEvent позволяет блокировать фоновый поток, когда нет задачи доступны. Состояние гонки, если другой поток удаляет все оставшиеся задания между «mNoTaskEvent.WaitOne()» и «lock (mTasks)».

Как я мог атомарно получить блокировку mTasks при выходе из mNoTaskEvent.WaitOne()?

Edit потоковой API имеет функцию, которая делает именно то, что мне нужно: pthread_cond_wait

Answer 1

Простое исправление для скаковой состояния будет проверять количество раз:

lock (mTasks) 
    { 
     if (mTasks.Count < 1) 
     continue; 

     mTasks.Sort(...); 
     nextTask = mTasks.First(); 
    } 

---

Использование Monitor.Wait():

while (mRunning) 
{ 
    //mNoTaskEvent.WaitOne(); 

    if (!mRunning) break; 

    Task nextTask; 

    lock (mTasks) 
    { 
     while (mTasks.Count < 1) 
     { 
      Monitor.Wait(mTasks); 

      if (!mRunning) break;     
     } 

     ...  
    } 



public void AddTask(Task task) 
{ 
    lock (mTasks) 
    { 
    mTasks.Add(task); 
    //mNoTaskEvent.Set(); 
    Monitor.Pulse(mTasks); 
    } 
} 

Вам также понадобится Pulse() при остановке всей цепочки.