在异步WCF服务中使用CCR

Question

我正在学习如何将CCR（并发和协调运行时）与异步WCF Web服务结合使用。

这是测试WCF服务：

public class Service : IService 
    { 
     private Accounts.Manager accountManager = new Accounts.Manager(); 
     public IAsyncResult BeginGetAccount(int id, AsyncCallback callback, object state) 
     { 
      //How Do I Call the CCR Function without blocking a Thread? 
      throw new NotImplementedException(); 
     } 

     public string EndGetAccount(IAsyncResult result) 
     { 
      //How Do I Finish the Call and Pass back the Result? 
      throw new NotImplementedException(); 
     } 
    } 

这将需要一个ID号，并返回匹配的帐户名（如果有的话）

我已经写了CCR功能应该找到匹配的帐户（s） （显然需要大量的工作 - 这只是概念验证） 这里是我去的地方。

如何传回结果（全局端口？） 更重要的是：如何在不阻塞线程的情况下将CCR插入WCF异步服务调用？

public IEnumerator<ITask> GetAccount(int id) 
    { 
     SqlDataReader reader = null; 
     SqlConnection connection = new SqlConnection(@"Data Source=.\SQLEXPRESS;Initial Catalog=BizData;Integrated Security=True;Async=True;"); 
     string query = "SELECT * FROM Account WHERE AccountID = @AccountID"; 
     SqlCommand command = new SqlCommand(query, connection); 
     SqlParameter accountID = new SqlParameter("AccountID", id); 
     command.Parameters.Add(accountID); 

     connection.Open(); 
     yield return Arbiter.Choice(SQLAdapter.GetReader(command), 
      delegate(SqlDataReader r) { reader = r; }, 
      delegate(Exception e) { Console.Write("Failed to get SQL data"); }); 

     if (reader == null) yield break;  

     while (reader.Read())  
     { 
      Account account = new Account { ID = Convert.ToInt32(reader["AccountID"]), 
       Name = reader["Account"].ToString(), 
       ParkingNo = Convert.ToInt32(reader["ParkingNo"]), 
       Password = reader["Password"].ToString() }; 
      //Post account? 
     } 
     connection.Close(); 
    } 

Answer 1

好的，我终于得到了所有这一切！

第一项：您需要一个定制的AsyncResult类

class AsyncResult : IAsyncResult , IDisposable 
    { 
     object _state; 
     ManualResetEvent _waitHandle = new ManualResetEvent(false); 
     bool _isCompleted; 

     #region IAsyncResult Members 
     public object AsyncState 
     { 
      get { return _state; } 
     } 

     public System.Threading.WaitHandle AsyncWaitHandle 
     { 
      get { return _waitHandle; } 
     } 

     public bool CompletedSynchronously 
     { 
      get { return false; } 
     } 

     public bool IsCompleted 
     { 
      get { return _isCompleted; } 
     } 
     #endregion 

     Exception _exception; 
     internal Exception Exception 
     { 
      get { return _exception; } 
     } 

     Accounts.Account _result; 
     internal Accounts.Account Result 
     { 
      get { return _result; } 
     } 

     internal AsyncResult(PortSet<Accounts.Account, Exception> port, DispatcherQueue queue, AsyncCallback callback, object state) 
     { 
      _state = state; 

      Arbiter.Activate(queue, 
       Arbiter.Choice(port, 
        r => 
        { 
         _result = r; 
         Complete(callback); 
        }, 
        e => 
        { 
         _exception = e; 
         Complete(callback); 
        } 
       ) 
      ); 
     } 

     private void Complete(AsyncCallback callback) 
     { 
      _isCompleted = true; 
      _waitHandle.Set(); 

      if (callback != null) 
      { 
       ThreadPool.QueueUserWorkItem(s => callback(this)); 
      } 
     } 

     private bool disposedValue = false; 

     public void Dispose() 
     { 
      if (!this.disposedValue) 
      { 
       _waitHandle.Close(); 
       _waitHandle = null; 
       _state = null; 
      } 
      this.disposedValue = true; 
     } 
    } 

好了，那么我们就需要使用异步WCF方法来把这些在呼叫：

public class Service : IService 
    { 
     private Dispatcher dispatcher; 
     private DispatcherQueue dq; 

     public Service() 
     { 
      dispatcher = new Dispatcher(); 
      dq = new DispatcherQueue("CCR DispatcherQueue", dispatcher); 
     } 

     public IAsyncResult BeginGetAccount(int id, AsyncCallback callback, object state) 
     { 
      PortSet<Accounts.Account, Exception> port = new PortSet<Accounts.Account, Exception>(); 
      Accounts.Manager manager = new Accounts.Manager(); 
      manager.GetAccountData(dq, port, id); 

      AsyncResult result = new AsyncResult(port, dq, callback, state); 
      return result; 
     } 

     public string EndGetAccount(IAsyncResult result) 
     { 
      { 
       var AccountName = string.Empty; 
       if ((result != null)) 
       { 
        using (Common.AsyncResult asyncResult = result as Common.AsyncResult) 
        { 

         if (asyncResult == null) 
         { 
          throw new NullReferenceException("IAsynchResult Parameter is Null"); 
         } 

         asyncResult.AsyncWaitHandle.WaitOne(); 
         if (asyncResult.Result != null) 
         { 
          AccountName = asyncResult.Result.Name; 
         } 
        } 
       } 
       return AccountName; 
      } 
     } 
    } 

然后你只需要IEnumerator的方法发布回答端口

Answer 2

查看此博客的端到端示例：

Exception Handling, Queuing, and UI Synchronization for WCF Services using the CCR