如何確保線程正在等待事件？

Question

我不知道如何確保一個線程正在等待事件。 讓說我是引發事件的組件：

public delegate void TestHandler(object sender, EventArgs eventArgs); 
class Producer 
{ 
    public event TestHandler Handler; 
    public void InvokeHandler(EventArgs eventargs) 
    { 
     var handler = Handler; 
     if (handler != null) handler(this, eventargs); 
    } 

    public Producer() 
    { 
     Task.Factory.StartNew(() => 
     { 
      while (true) 
      { 
       Thread.Sleep((new Random()).Next(0,100)); 
       InvokeHandler(new EventArgs()); 
      } }); } } 

與聽衆：

class Listener 
{ 
    private readonly BlockingCollection<EventArgs> _blockingCollection; 
    public Listener() 
    { 
     var producer = new Producer(); 
     _blockingCollection = new BlockingCollection<EventArgs>(10); 
     producer.Handler += producer_Handler; 
    } 

    void producer_Handler(object sender, EventArgs eventArgs) 
    { 
     _blockingCollection.TryAdd(eventArgs); //no error handling for simplicity sake 
    } 

    internal void ProcessEvents() 
    { 
     while (true) 
     { 
      EventArgs eventArgs; 
      try 
      { 
       if (_blockingCollection.TryTake(out eventArgs)) 
        Console.WriteLine("Received event"); 
      } 
      catch (Exception ex) 
      { 
       Console.WriteLine(ex.Message); 
      } } } } 

如果我將開始它：

class Program 
    { 
     static void Main(string[] args) 
     { 
      var listner = new Listener(); 
      listner.ProcessEvents(); 
     } } 

我得到預期的行爲（從我時不時收到事件通過阻止收集。

但是，如果我會w在任務中說唱這個電話：

Task.Factory.StartNew(() => { 
    var listner = new Listener(); 
    listner.ProcessEvents(); }); 

我永遠不會進入處理部分。 任何想法爲什麼會這樣？我錯過了明顯的東西嗎？

一邊，有人知道一個模式，這將有助於這裏很好的描述？ 我正在尋找在一個線程（最好不是主應用程序線程）上拾取事件，然後在一個單獨的線程上同時處理它們，如果事件數量變得太高（典型的閾值我假設）

在此先感謝，

Answer 1

爲了弄清楚發生了什麼事情，你應該把一些日誌信息，並確認時，當您啓動新的任務沒有異常拋出：

Thread listenerThread = new Thread(() => 
{ 
    // print a message when the task is started 
    Console.WriteLine("Task started!"); 

    var listner = new Listener(); 
    listner.ProcessEvents(); 
}); 

// set your thread to background so it doesn't live on 
// even after you're 
listenerThread.IsBackground = true; 
listenerThread.Start(); 

的Thread.join（ ）和Task.Wait（）一樣。你可以把它稱爲不指定超時，你可以指定一個無限超時，或者如果你想你的測試停止等待的線程來完成，那麼你指定以毫秒爲單位：

// this will block until the thread is complete 
listenerThread.Join(Timeout.Infinite); 

如果您需要停止測試，那麼你必須執行一個異步中斷。中斷引發Thread內ThreadInterruptedException這你應該趕上（如ProcessEvents方法所示）：

listenerThread.Interrupt(); 

此外，您使用的是阻塞集合，但你不使用的攔截功能集合。沒有理由爲什麼你應該繼續重試時，有沒有集合中，而不是你寧願阻塞，直到有東西在它（這是這個系列的目的是做）：

internal void ProcessEvents() 
{ 
    while (true) 
    { 
     try 
     { 
      var myEvent = _blockingCollection.Take(); 
      Console.WriteLine("Received event"); 
     } 
     catch(ThreadInterruptedException) 
     { 
      Console.WriteLine("Thread interrupted!"); 
      break;// break out of the loop! 
     } 
     catch (Exception ex) 
     { 
      Console.WriteLine(ex.Message); 
      // Do you REALLY want to keep going if there is an unexpected exception? 
      // Consider breaking out of the loop... 
     } 
    } 
} 

Answer 2

愚蠢的我。 ..

當我在任務中包裝我的呼叫時，它在後臺線程上運行。 我應該在退出前等待任務完成。

已經這樣做了，那就是分配：

var task = Task.Factory.StartNew(/*task body*/); 
task.Wait(); 

，等待我能得到我想要的東西。