C# Task.WhenAll

1、有时候我们需要同时执行一些操作，然后把这些操作的结果进行汇总，以达到用异步处理降低操作耗时的效果，此时我们会考虑使用Task，而Task.WhenAll则排上了用场。

public void IssueStatistics()

        {
　　　　　　　　　　var task = GetIssueStatisticsAsync();

                var dtRet = task.Result;

        }

 private async Task<DataTable> GetIssueStatisticsAsync()

        {

            var taskList = new List<Task<DataTable>>

            {

                GetIssueDataAsync(),

                GetB2CIssueDataAsync()

            };

            var tasks = taskList.ToArray();

            var tables = await Task.WhenAll(tasks).ConfigureAwait(false);

            var retDt = orderDAL.CreateIssueDataTable();

            for (int index = ; index < tables.Length; index++)

            {

                for (int k = ; k < tables[index].Rows.Count; k++)

                {

                    retDt.ImportRow(tables[index].Rows[k]);

                }

            }

            return retDt;

        }

        private Task<DataTable> GetIssueDataAsync()

        {

            return Task.Run(() =>

            {

                var dt = orderDAL.GetIssueDataOfOrder();

                return dt;

            });

        }

        private Task<DataTable> GetB2CIssueDataAsync()

        {

            return Task.Run(() =>

            {

                var dt = orderDAL.GetIssueDataOfB2C();

                return dt;

            });

        }

这里有个地方需要注意的，如果不是在控制台应用程序，那么需要在Task.WhenAll后面加 ConfigureAwait(false)，不然无法返回当前线程。

当然，按照官网的实例写法，你也可以这样写：

private async Task<int> ExecuteDataAsync()

        {

            var dtRecord = _dao.GetDataOfStockOut();

            var dataList = _comDao.ToSyncDataList(dtRecord);

            if (dataList == null) return ;

            var tasksQuery = from data in dataList select DoRunIssueDataAsync(data);

            var tasks = tasksQuery.ToArray();

            int[] flags = await Task.WhenAll(tasks);

            int total = flags.Sum();

            return total;

        }

        private async Task<int> DoRunIssueDataAsync(SyncDataM data)

        {

            return await Task.Run(() =>

            {

               //要处理的事情
　　　　　　　　　return ;

            });

        }

这样调用就可以了：

var task = ExecuteDataAsync();

task.Wait();

巴特西

C# Task.WhenAll

最新文章

热门文章