0

我正在尝试学习如何实现异步模式以同时查询多个 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() 吗？或者这会创建大量线程并实际上减慢速度。

谢谢你。

4

1 回答 1

1

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

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

IAsyncResult BeginXXX(AsyncCallback callback, Object state);

Result EndXXX(IAsyncResult asyncResult);

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

要进行多个异步调用，您需要做的就是BeginXXX根据需要多次调用，然后调用WaitHandle.WaitAll(...)传入 IAsyncResult.AsyncWaitHandle 以获取您想要等待的所有调用。

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

这是否是一件好事是有点主观。通常，异步调用通过线程池进行，因此一次创建大量异步调用会耗尽可用线程，之后，新调用会排队等待线程可用。在线程之间切换会有一些开销，但与同步执行它所花费的时间相比，这可能并不重要（除非你有大量的线程）。

于 2011-03-26T15:15:14.417 回答