如何使两个SQL查询真正异步

当您对尚未完成的任务使用Result属性时，调用线程将阻塞，直到操作完成。这意味着在您的情况下，GetAccounts操作需要在对GetDeposits的调用开始之前完成。

如果您想确保这些方法是并行的（包括同步CPU密集型部分），您需要将这些工作卸载到另一个线程。最简单的方法是使用Task.Run:

static async Task Main()
{
    var accountTask = Task.Run(async () => Console.WriteLine(await GetAccounts()));
    var depositsTask = Task.Run(async () => Console.WriteLine(await GetDeposits()));
    await Task.WhenAll(accountTask, depositsTask);
}

以下是异步和并行执行两项任务的方法：

Task<int> accountTask = GetAccounts();
Task<int> depositsTask = GetDeposits();
int[] results = await Task.WhenAll(accountTask, depositsTask);
int accounts = results[0];
int deposits = results[1];

我通常更喜欢使用Task.WaitAll。为了设置这个代码段，我更改了GetAccounts/GetDeposits签名，只是为了返回int（public static int GetAccounts()）

我将Console.WriteLine放在分配返回的同一线程中，以验证一个GetDeposits是否在GetAccounts之前返回，但这是不必要的，可能最好将其移动到Task.WaitAll 之后

     private static void Main(string[] args) {
        int getAccountsTask = 0;
        int getDepositsTask = 0;
        List<Task> tasks = new List<Task>() {
            Task.Factory.StartNew(() => {
                getAccountsTask = GetAccounts();
                Console.WriteLine(getAccountsTask);
            }),
            Task.Factory.StartNew(() => {
                getDepositsTask = GetDeposits();
                Console.WriteLine(getDepositsTask);
            })
        };
        Task.WaitAll(tasks.ToArray());

    }

如果是ASP.NET，请在页面呈现后使用AJAX进行提取并将数据放入存储区。每个AJAX获取都是异步的。如果要在服务器上同时创建SQL查询？

用法：

 // Add some queries ie. ThreadedQuery.NamedQuery([Name], [SQL])
 var namedQueries= new ThreadedQuery.NamedQuery[]{ ... };
 System.Data.DataSet ds = ThreadedQuery.RunThreadedQuery(
 "Server=foo;Database=bar;Trusted_Connection=True;", 
 namedQueries).Result;

 string msg = string.Empty;
 foreach (System.Data.DataTable tt in ds.Tables)
 msg += string.Format("{0}: {1}'r'n", tt.TableName, tt.Rows.Count);

来源：

public class ThreadedQuery
{
    public class NamedQuery
    {
        public NamedQuery(string TableName, string SQL)
        {
            this.TableName = TableName;
            this.SQL = SQL;
        }
        public string TableName { get; set; }
        public string SQL { get; set; }
    }
    public static async System.Threading.Tasks.Task<System.Data.DataSet> RunThreadedQuery(string ConnectionString, params NamedQuery[] queries)
    {
        System.Data.DataSet dss = new System.Data.DataSet();
        List<System.Threading.Tasks.Task<System.Data.DataTable>> asyncQryList = new List<System.Threading.Tasks.Task<System.Data.DataTable>>();
        foreach (var qq in queries)
            asyncQryList.Add(fetchDataTable(qq, ConnectionString));
        foreach (var tsk in asyncQryList)
        {
            System.Data.DataTable tmp = await tsk.ConfigureAwait(false);
            dss.Tables.Add(tmp);
        }
        return dss;
    }
    private static async System.Threading.Tasks.Task<System.Data.DataTable> fetchDataTable(NamedQuery qry, string ConnectionString)
    {
        // Create a connection, open it and create a command on the connection
        try
        {
            System.Data.DataTable dt = new System.Data.DataTable(qry.TableName);
            using (SqlConnection connection = new SqlConnection(ConnectionString))
            {
                await connection.OpenAsync().ConfigureAwait(false);
                System.Diagnostics.Debug.WriteLine("Connection Opened ... " + qry.TableName);
                using (SqlCommand command = new SqlCommand(qry.SQL, connection))
                {
                    using (SqlDataReader reader = command.ExecuteReader())
                    {
                        System.Diagnostics.Debug.WriteLine("Query Executed ... " + qry.TableName);
                        dt.Load(reader);
                        System.Diagnostics.Debug.WriteLine(string.Format("Record Count '{0}' ... {1}", dt.Rows.Count, qry.TableName));
                        return dt;
                    }
                }
            }
        }
        catch(Exception ex)
        {
            System.Diagnostics.Debug.WriteLine("Exception Raised ... " + qry.TableName);
            System.Diagnostics.Debug.WriteLine(ex.Message);
            return new System.Data.DataTable(qry.TableName);
        }
    }
}

如果进程需要很长时间，异步就很好。另一种选择是使用一个存储过程来返回所有三个记录集。

        adp = New SqlDataAdapter(cmd)
        dst = New DataSet
        adp.Fill(dst)

在页面的代码后面，将它们引用为dst。表（0），dst。表（1）和dst。表（2）。这些表的顺序与存储过程中的select语句的顺序相同。