调试时异步行为同步？答案

【问题标题】：Async behaving sync while debugging?调试时异步行为同步？
【发布时间】：2016-04-14 00:57:19
【问题描述】：

我对 async/await 的理解肯定存在缺陷。我想要一段名为 SaveSearchCase 的代码在后台异步运行。

我希望它被触发并忘记它并继续当前方法的返回语句。

public IList<Entities.Case.CreateCaseOutput> createCase(ARC.Donor.Data.Entities.Case.CreateCaseInput CreateCaseInput, ARC.Donor.Data.Entities.Case.SaveCaseSearchInput SaveCaseSearchInput)
{
    ..........
    ..........
    ..........
    var AcctLst = rep.ExecuteStoredProcedure<Entities.Case.CreateCaseOutput>(strSPQuery, listParam).ToList();

    if (!string.IsNullOrEmpty(AcctLst.ElementAt(0).o_case_seq.ToString()))
    {
        Task<IList<Entities.Case.SaveCaseSearchOutput>> task = saveCaseSearch(SaveCaseSearchInput, AcctLst.ElementAt(0).o_case_seq);
        Task t = task.ContinueWith(
                r => { Console.WriteLine(r.Result); }
         );
    }
    Console.WriteLine("After the async call");
    return AcctLst;
}

SaveCaseSearch 看起来像

public async Task<IList<Entities.Case.SaveCaseSearchOutput>> saveCaseSearch(ARC.Donor.Data.Entities.Case.SaveCaseSearchInput SaveCaseSearchInput,Int64? case_key)
{
    Repository rep = new Repository();
    string strSPQuery = string.Empty;
    List<object> listParam = new List<object>();
    SQL.CaseSQL.getSaveCaseSearchParameters(SaveCaseSearchInput, case_key,out strSPQuery, out listParam);
    var AcctLst = await rep.ExecuteStoredProcedureAsync<Entities.Case.SaveCaseSearchOutput>(strSPQuery, listParam);
    return (System.Collections.Generic.IList<ARC.Donor.Data.Entities.Case.SaveCaseSearchOutput>)AcctLst;
}

但是当我看到调试器 createCase 方法首先等待 SaveCaseSearch 完成，然后才完成

它打印 "After Async Call"

然后返回。我绝对不想要。

那么我的理解在哪方面有缺陷？请帮助使其异步运行并继续当前方法的打印和返回语句。

更新

我更新了 SaveCaseSearch 方法以反映如下：

public async Task<IList<Entities.Case.SaveCaseSearchOutput>> saveCaseSearch(ARC.Donor.Data.Entities.Case.SaveCaseSearchInput SaveCaseSearchInput,Int64? case_key)
{
    return Task.Run<IList<Entities.Case.SaveCaseSearchOutput>>(async (SaveCaseSearchInput, case_key) =>
    {
        Repository rep = new Repository();
        string strSPQuery = string.Empty;
        List<object> listParam = new List<object>();
        SQL.CaseSQL.getSaveCaseSearchParameters(SaveCaseSearchInput, case_key, out strSPQuery, out listParam);
        var AcctLst = await rep.ExecuteStoredProcedureAsync<Entities.Case.SaveCaseSearchOutput>(strSPQuery, listParam);
        return (System.Collections.Generic.IList<ARC.Donor.Data.Entities.Case.SaveCaseSearchOutput>)AcctLst;
    });
}

但是参数有问题。它说

Error   4   A local variable named 'SaveCaseSearchInput' cannot be declared in this scope because it would give a different meaning to 'SaveCaseSearchInput', which is already used in a 'parent or current' scope to denote something else C:\Users\m1034699\Desktop\Stuart_V2_12042016\Stuart Web Service\ARC.Donor.Data\Case\Search.cs   43  79  ARC.Donor.Data

【问题讨论】：

当你使用异步功能时，你应该将回调传递给你的函数，在它完成所有你需要的事情之后，你调用回调，这就是你使用异步的方式，因为当你使用返回语句时，它将运行同步
if (!string.IsNullOrEmpty(AcctLst.ElementAt(0).o_case_seq.ToString())) { SaveCaseSearch ...} 我想在后台调用这个方法 async 。你能告诉我如何达到同样的效果吗？
你应该在调用saveCaseSearch方法时使用await关键字，然后打印结果。
Fire and Forget approach的可能重复
编译器可能会告诉你，如果你不使用 await 关键字，它会同步运行。而且该方法仍将在主线程上运行（不是真正触发并忘记），但在执行存储过程时它不会阻塞线程。

标签： c# asynchronous asp.net-web-api async-await

【解决方案1】：

这个saveCaseSearch() 方法在主线程中同步运行，这是这里的主要问题。而不是返回带有任务的结果，您应该返回带有操作本身的任务。这是一些简化的示例：

同步运行，等待 5 秒

    public IList<int> A()
    {

        var AcctLst = new List<int> { 0, 2, 5, 8 };

        if (true)
        {
            Task<IList<int>> task = saveCaseSearch();

            Task t = task.ContinueWith(
                    r => { Console.WriteLine(r.Result[0]); }
             );
        }

        Console.WriteLine("After the async call");

        return AcctLst;
    }

    // runs sync and in the end returns Task that is never actually fired
    public async Task<IList<int>> saveCaseSearch()
    {
        Thread.Sleep(5000);
        return new List<int>() { 10, 12, 16 };
    }

异步运行 - 触发任务并忘记：

    public IList<int> A()
    {
        ... same code as above
    }

    // notice that we removed `async` keyword here because we just return task.
    public Task<IList<int>> saveCaseSearch()
    {
        return Task.Run<IList<int>>(() =>
        {
            Thread.Sleep(5000);
            return new List<int>() { 10, 12, 16 };
        });
    }

这里是full code for this example

【讨论】：

实际上在 SaveCaseSearch 的代码中我们有类似 await rep.ExecuteStoredProcedureAsync(strSPQuery, listParam);那么用 Task.Run() 把所有东西都包起来可以吗？即 await 可以在 Task.Run() 中吗？
@StrugglingCoder 是的，您可以在任务内部的方法中添加 async 关键字，例如：Task.Run<IList<int>>(*async* () => { });
@StrugglingCoder 这看起来像是不同的问题，请提出或用新的代码和问题更新您的问题
@StrugglingCoder 您实际上不需要在 lambda 中传递参数，您可以使用名为 closure 的东西。从async (SaveCaseSearchInput, case_key) => {} 中删除参数，只留下async () => {} ，它应该可以工作。

【解决方案2】：

与我所相信的与“即发即弃”有关的所有内容相反，您可以通过以下方式编写代码来做到这一点：

public Task<SaveCaseSearchOutput> SaveCaseSearch(
    SaveCaseSearchInput saveCaseSearchInput,
    long? caseKey)
{
    var rep = new Repository();
    var query = string.Empty;
    var listParam = new List<object>();
    SQL.CaseSQL
       .getSaveCaseSearchParameters(
           saveCaseSearchInput, 
           caseKey, 
           out query,
           out listParam);

    return rep.ExecuteStoredProcedureAsync<SaveCaseSearchOutput>(
        strSPQuery, 
        istParam);
}

然后，如果您想在哪里触发它并在它返回时记录（这确实是您所拥有的——所以您不会忘记它），请执行以下操作：

public IList<CreateCaseOutput> CreateCase(
    CreateCaseInput createCaseInput,
    SaveCaseSearchInput saveCaseSearchInput)
{
    // Omitted for brevity...

    var AcctLst = 
        rep.ExecuteStoredProcedure<CreateCaseOutput>(
            strSPQuery,
            listParam)
           .ToList();

    if (!string.IsNullOrEmpty(AcctLst.ElementAt(0).o_case_seq.ToString()))
    {
        SaveCaseSearch(saveCaseSearchInput,
                       AcctLst.ElementAt(0).o_case_seq)
            .ContinueWith(r => Console.WriteLine(r.Result));
    }

    Console.WriteLine("After the async call");
    return AcctLst;
}

问题是您在SaveSearchCase 函数中使用了async 和await，这基本上意味着您的代码与“即发即弃”相反。

附带说明，您真的应该只使用async 和await，并避免“一劳永逸” 的想法！让您的数据库调用异步并充分利用这种范例！

考虑以下几点：

SaveCaseSearch 调用可以保持如我在上面定义的那样。

public Task<SaveCaseSearchOutput> SaveCaseSearch(
    SaveCaseSearchInput saveCaseSearchInput,
    long? caseKey)
{
    var rep = new Repository();
    var query = string.Empty;
    var listParam = new List<object>();
    SQL.CaseSQL
       .getSaveCaseSearchParameters(
           saveCaseSearchInput, 
           caseKey, 
           out query,
           out listParam);

    return rep.ExecuteStoredProcedureAsync<SaveCaseSearchOutput>(
        strSPQuery, 
        istParam);
}

然后在你调用它时，改为这样做：

public async Task<IList<CreateCaseOutput>> CreateCase(
    CreateCaseInput createCaseInput,
    SaveCaseSearchInput saveCaseSearchInput)
{
    // Omitted for brevity...

    var AcctLst = 
        await rep.ExecuteStoredProcedureAsync<CreateCaseOutput>(
            strSPQuery,
            listParam)
           .ToList();

    if (!string.IsNullOrEmpty(AcctLst.ElementAt(0).o_case_seq.ToString()))
    {
        await SaveCaseSearch(saveCaseSearchInput,
                       AcctLst.ElementAt(0).o_case_seq)
            .ContinueWith(r => Console.WriteLine(r.Result));
    }

    Console.WriteLine("After the async call");
    return AcctLst;
}

这是一个更好的解决方案！

【讨论】：