使用等待句柄的條件性定期計時器

Question

我需要一個定時器等價物，它將定期執行一些特定的動作（例如更新數據庫中的某些進度或檢查要在數據庫中執行的新作業）。

這些操作綁定到WaitHandle，它指定是否需要執行作業。所以基本上這可以是，例如，當數據庫中存在新實體並且觸發搜索這些新實體時從外部設置的AutoResetEvent。計時器是必要的，因爲我想限制查詢數量到數據庫。因此，如果有10個新通知到達，AutomaticResetEvent將只設置一次，並且對於所有這些通知也只有一個查詢。

我的第一次嘗試是這樣的：

class ConditionalScheduler 
{ 
    public void AddConditionalAction(WaitHandle handle, Action action) 
    { 
     lock (syncRoot) 
     { 
      handles.Add(handle); 
      actions.Add(handle, action); 
     } 
    } 

    private readonly object syncRoot = new object(); 

    private readonly Dictionary<WaitHandle, Action> actions = new Dictionary<WaitHandle, Action>(); 
    private readonly List<WaitHandle> handles = new List<WaitHandle>(); 

    public void RunTimerLoop() 
    { 
     do 
     { 
      WaitHandle[] waitHandles = handles.ToArray(); 
      int index = WaitHandle.WaitAny(waitHandles); 

      if (index >= 0) 
      { 
       WaitHandle handle = waitHandles[index]; 

       Action action; 
       lock (syncRoot) 
       { 
        action = actions[handle]; 
       } 

       action(); 
      } 
      Thread.Sleep(5000); 
     } while (true); 
    } 

這種方法的問題是，WaitHandle.WaitAny只會給我說是引發了第一次的WaitHandle的指數。所以如果我有兩個或更多的WaitHandles被觸發，那麼我將只執行第一個動作而不是其他的動作。

您是否有更好的設計來達到執行在指定時間段內觸發的所有操作所需的結果？如果它簡化了這個問題，我可以使用另一種通知機制而不是WaitHandles。

謝謝！

Answer 1

也許你可以去一個雙線程隊列/批量執行？ 請注意，代碼是隻是一個概念，我正在寫沒有Visual Studio，所以我正在做一個列表，這最好做一個隊列，但我不記得沒有intellisense的語法:) ...

private readonly Dictionary<WaitHandle, Action> actions = new Dictionary<WaitHandle, Action>(); 
    private readonly List<WaitHandle> handles = new List<WaitHandle>(); 
    private readonly List<WaitHandle> triggeredHandles = new List<WaitHandle>(); 

// thread 1 
    public void CheckLoop() 
    { 
     do 
     { 
      WaitHandle[] waitHandles = handles.ToArray(); 
      int index = WaitHandle.WaitAny(waitHandles); 

      if (index >= 0) 
      { 
       lock (triggeredHandles) 
       { 
        triggeredHandles.Add(waitHandles[index]); 
       } 

      }    
     } while (true); 
    } 

// thread 2 
public void RunLoop() 
    { 
     do 
     { 
      lock(triggeredHandles) 
      { 
       foreach (var th in triggeredHandles) { 

        Action action; 
        lock (syncRoot) 
        { 
         action = actions[th]; 
        } 

        action();     
       } 
       triggeredHandles.Clear(); 
      } 
      Thread.Sleep(5000); 
     } while (true); 
    } 

Answer 2

通過使用Reactive Extensions (Rx)，您可能會爲自己節省很多麻煩 - 它有很多偉大的方式來按照您要求的方式編寫事件。

This site是一種很方便的方法來查看rx可以做的事情。

Answer 3

您是否考慮過使用內建的Timer類？ System.Threading.Timer是一個輕量級實現，它使用ThreadPool或System.Timers.Timer，它提供相關事件和更多功能。