异步 WCF 查询最后一步

Question

我正在尝试学习如何实现异步模式来同时查询多个 wcf 服务，但不知道如何检查所有并发调用是否已完成。我有一个执行异步操作的类，然后在操作完成时添加到列表中：

   public static class ODataAsync
    {
        static DataServiceContext ServiceContext;
        static List<DynamicEntity> Results = new List<DynamicEntity>(); 

        private static void GetAsync(string serviceUri, NameValueCollection queryOptions, IAuthenticationScheme authenticationScheme)
        {
            string baseUri;
            string entitySet;
            string entityKey;
            string queryString;
            ValidateServiceUri(serviceUri, out baseUri, out entitySet, out entityKey, out queryString);
            string resource = !string.IsNullOrEmpty(entityKey) ? entitySet + "(" + entityKey + ")" : entitySet;

            DataServiceContext context = new DataServiceContext(new Uri(baseUri));
            context.IgnoreMissingProperties = true;

            ServiceContext = context; 

            DataServiceContextHandler handler = new DataServiceContextHandler(authenticationScheme);
            handler.HandleGet(context);

            DataServiceQuery<EntryProxyObject> query = context.CreateQuery<EntryProxyObject>(resource);

            NameValueCollection options = HttpUtility.ParseQueryString(queryString);
            options.Add(queryOptions);

            foreach (string key in options.AllKeys)
            {
                query = query.AddQueryOption(key, options[key]);
            }

            try
            {
                query.BeginExecute(GetAsyncComplete, query);
            }
            catch (DataServiceQueryException ex)
            {
                throw new ApplicationException("An error occurred during query execution.", ex); 
            }
        }

        private static void GetAsyncComplete(IAsyncResult result)
        {
            QueryOperationResponse<EntryProxyObject> response = 
                ((DataServiceQuery<EntryProxyObject>)result).EndExecute(result) as QueryOperationResponse<EntryProxyObject>; 

            IList<dynamic> list = new List<dynamic>(); 

            foreach (EntryProxyObject proxy in response)
            {
                DynamicEntity entity = new DynamicEntity(proxy.Properties);
                Results.Add(entity);
            }

            while (response.GetContinuation() != null)
            {
                Uri uri = response.GetContinuation().NextLinkUri;

                response = ServiceContext.Execute<EntryProxyObject>(uri) as QueryOperationResponse<EntryProxyObject>;

                foreach (EntryProxyObject proxy in response)
                {
                    DynamicEntity entity = new DynamicEntity(proxy.Properties);
                    Results.Add(entity);
                }
            }
        }    
    }

我的两个问题是：

1）如何确保仅在所有并发调用完成时才获得列表结果？例如，如果在循环中调用 GetAsync()，启动多个并发进程，我需要确保它们全部完成，然后再从列表结果中取出数据。

2) 我可以在 GetContinuation() 调用中使用 BeginExecute() 并递归地使用相同的方法 GetAsyncComplete() 作为回调函数吗？或者这会创建大量线程并实际上减慢速度。

谢谢。

Answer 1

看一下静态 WaitHandle.WaitAll(WaitHandle[] waitHandles)方法。该页面上有一个很棒的代码示例。

通常，任何实现异步模式的类都会定义以下形式的方法：

IAsyncResult BeginXXX(AsyncCallback callback, Object state);

Result EndXXX(IAsyncResult asyncResult);

调用 BeginXXX 异步调用该方法，调用 EndXXX 强制当前线程等待，直到异步方法完成。

要进行多个异步调用，您只需根据需要多次调用 BeginXXX，然后调用传入 IAsyncResult 的 WaitHandle.WaitAll(...) 即可。 AsyncWaitHandle 用于您要等待的所有调用。

要回答你的第二个问题，是的，你可以递归地使用 GetAsynComplete 。提供给 BeginXXX 调用的 state 参数用于识别请求，并且可以通过 IAsyncResult.UserState 属性访问 - 因此您可以匹配请求到响应。

这是否是一件好事有点主观。通常，异步调用通过线程池进行，因此一次创建大量异步调用可能会耗尽可用线程，之后新的调用将排队，直到有线程可用。在线程之间切换会产生一些开销，但与同步执行切换所需的时间相比，这可能不会很大（除非您有大量线程）。