異步調用機制設計c＃

Question

要求是連續讀取硬件中的數據並將數據發送到上層的 進行進一步處理。

目前我使用同步機制。即 請求 - >等待 - >讀取--->發送進行處理。

do 
    { 

    int ix = iy; 
      iy = 0; 

      if(ix<1) 
      { 
       while (((ix = ReadSst(ref sBuffer)) < 1) && bProcessNotEnded == true) 
       { 
        if (ix < 0) // BT Error 
        { 
         eErr = CError.BUFF_KILL; //Throw error and exit 
         break; 
        } 

        Thread.Sleep(2); 

        iTimeOut += 2; 
        if (iTimeOut > TIMEOUT_2000) 
        { 
         eErr = CError.TIMEOUT_ERR; 
         objLogger.WriteLine("HW TIMED OUT"); 
         break; 
        } 

       } 
      } 

      iBytesRead = ix; 

      if (iBytesRead <= 0) 
      { 
       eErr = CError.READ_ERR; 
       objLogger.WriteLine("READ ERROR"); 
       break; 
      } 

      sReadMsg = sReadMsg + sBuffer; 


    if(sReadMsg.Length >0) 
     iEndPos = sReadMsg.IndexOf('\n',1); 
    else 
     iEndPos = -1; 


       if (sReadMsg.Length > 2) 
       { 
        if ((iEndPos == 0 && sReadMsg[0] == '\n') || (iEndPos > 0 && sReadMsg[sReadMsg.Length - 1] == '\n' && sReadMsg[sReadMsg.Length - 2] == '\r')) //finished 
        { 
         Thread.Sleep(50); // wait a short time to be sure there that there is no further input 
         if (sReadMsg.Length >= 3 && sReadMsg[sReadMsg.Length - 3] == 'a') 
          continue; 

         iy = ReadSst(ref sBuffer); 
         if (iy == 0) 
         { 
          bProcessNotEnded = false; 
          objLogger.WriteLine("bProcessNotEnded is made false, End of frame detected"); 
          break; 
         } 
         else if (iy < 0) 
         { 
          eErr = CError.BUFF_KILL; // error 
          break; 
         } 
        } 
       } 


     } while (bProcessNotEnded); 

ReadSst方法是一個調用硬件來請求數據。

從代碼中可以看出，當前邏輯循環並讀取，直到bProcessNotEnded標誌爲真。一旦在我收到的字符串緩衝區中檢測到幀的結尾，我將該標誌設置爲假，循環停止（硬件讀取也是如此）

現在我需要在代碼中實現一些並行性，提升性能我想學習以異步方式完成閱讀的方式來改進它。

任何人誰會幫助我改善這種現有的設計。

在此先感謝

Answer 1

一般有三種常見的模式做異步工作在.NET：

1. 的Asynchronous Programming Model
2. 的Event-based asynchronous programming model
3. 的Task parallel library（.NET 4.0）

對於你明顯低級的p代碼我會去1或3，因爲2通常用於更高級別的組件。

一般設計將去執行你的循環在一個單獨的線程使用上述任何一種方式，當循環完成時通知調用線程操作完成，傳遞結果（在你的情況下，這應該是內容sReadMsg）以適當的方式（取決於你選擇的方式）。

這裏是你能怎麼做很容易使用TPL一個簡單的例子：

private void ReadMessageAsync() 
{ 
    // Set up the task to read the message from the hardware device. 
    Task<string> readMessageTask = new Task<string>(ReadMessage); 

    // Set up the task to process the message when the message was read from the device. 
    readMessageTask.ContinueWith(ProcessMessage); 

    // Start the task asynchronously. 
    readMessageTask.Start(); 
} 

private void ProcessMessage(Task<string> readMessageTask) 
{ 
    string message = readMessageTask.Result; 

    // Process the message 
} 

private string ReadMessage() 
{ 
    string message = string.Empty; 

    // Retrieve the message using your loop 

    return message; 
} 

Answer 2

有一個稱爲後臺工作.NET組件，你可以把循環處理的「DoWork的」事件並同時保持您的應用程序響應。

這裏是公開它的類：

http://msdn.microsoft.com/en-us/library/system.componentmodel.backgroundworker%28v=VS.90%29.aspx

還包含如何使用它的一個很好的例子。

希望這有助於

Answer 3

我覺得你的設計可以通過使用異步IO得到改善。我們沒有看到ReadSst是如何實現的，但我懷疑你在那裏使用了Stream。而不是調用Read（這是同步的），而是使用BeginRead（這是異步的）。這種改變將導致代碼設計的其他更重大的變化。我首先研究異步IO並自己嘗試實現，然後發佈後續問題，如果它們是我們可以提供幫助的更具體問題。