根据我的理解,async和await所做的主要事情之一是使代码易于编写和阅读-但使用它们是否等于生成后台线程来执行长时间的逻辑?

我目前正在尝试最基本的例子。我内联添加了一些注释。你能给我解释一下吗?

// I don't understand why this method must be marked as `async`.
private async void button1_Click(object sender, EventArgs e)
{
    Task<int> access = DoSomethingAsync();
    // task independent stuff here

    // this line is reached after the 5 seconds sleep from 
    // DoSomethingAsync() method. Shouldn't it be reached immediately? 
    int a = 1; 

    // from my understanding the waiting should be done here.
    int x = await access; 
}

async Task<int> DoSomethingAsync()
{
    // is this executed on a background thread?
    System.Threading.Thread.Sleep(5000);
    return 1;
}

当前回答

这里所有的答案都使用Task.Delay()或其他内置的异步函数。但下面是我的例子,没有使用这些async函数:

// Starts counting to a large number and then immediately displays message "I'm counting...". 
// Then it waits for task to finish and displays "finished, press any key".
static void asyncTest ()
{
    Console.WriteLine("Started asyncTest()");
    Task<long> task = asyncTest_count();
    Console.WriteLine("Started counting, please wait...");
    task.Wait(); // if you comment this line you will see that message "Finished counting" will be displayed before we actually finished counting.
    //Console.WriteLine("Finished counting to " + task.Result.ToString()); // using task.Result seems to also call task.Wait().
    Console.WriteLine("Finished counting.");
    Console.WriteLine("Press any key to exit program.");
    Console.ReadLine();
}

static async Task<long> asyncTest_count()
{
    long k = 0;
    Console.WriteLine("Started asyncTest_count()");
    await Task.Run(() =>
    {
        long countTo = 100000000;
        int prevPercentDone = -1;
        for (long i = 0; i <= countTo; i++)
        {
            int percentDone = (int)(100 * (i / (double)countTo));
            if (percentDone != prevPercentDone)
            {
                prevPercentDone = percentDone;
                Console.Write(percentDone.ToString() + "% ");
            }

            k = i;
        }
    });
    Console.WriteLine("");
    Console.WriteLine("Finished asyncTest_count()");
    return k;
}

其他回答

这里有一个快速的控制台程序,让那些遵循。TaskToDo方法是你想让它异步的长期运行的方法。让它以异步方式运行是由TestAsync方法完成的。test loops方法只是运行TaskToDo任务,并异步运行它们。你可以在结果中看到这一点,因为它们在每次运行中完成的顺序不同——当它们完成时,它们会报告给控制台UI线程。简单,但我认为简单的例子比复杂的例子更好地揭示了模式的核心:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace TestingAsync
{
    class Program
    {
        static void Main(string[] args)
        {
            TestLoops();
            Console.Read();
        }

        private static async void TestLoops()
        {
            for (int i = 0; i < 100; i++)
            {
                await TestAsync(i);
            }
        }

        private static Task TestAsync(int i)
        {
            return Task.Run(() => TaskToDo(i));
        }

        private async static void TaskToDo(int i)
        {
            await Task.Delay(10);
            Console.WriteLine(i);
        }
    }
}

说实话,我仍然认为最好的解释是维基百科上关于未来和承诺的解释:http://en.wikipedia.org/wiki/Futures_and_promises

基本思想是,您拥有一个单独的异步执行任务的线程池。使用时。然而,对象承诺它将在某个时间执行操作,并在您请求时给您结果。这意味着当您请求结果并且还没有完成时,它将阻塞,否则将在线程池中执行。

从那里你可以优化事情:一些操作可以异步实现,你可以优化像文件IO和网络通信通过批处理后续请求和/或重新排序它们。我不确定这是否已经在微软的任务框架中-但如果不是,这将是我首先要添加的事情之一。

实际上,您可以在c# 4.0中实现这种未来模式。如果你想知道它到底是如何工作的,我可以推荐这个链接:http://code.google.com/p/fracture/source/browse/trunk/Squared/TaskLib/。但是,如果您自己开始使用它,您将注意到如果您想做所有很酷的事情,您确实需要语言支持——这正是微软所做的。

我想对此发表我的意见,如果任何其他答案包含我将解释的内容,我很抱歉,我读了大部分,但没有找到它,但我可能错过了一些东西。

我看到了很多错误的概念和很多好的解释,只是想解释一下异步与并行编程的区别,我相信这会让事情更容易理解。

当你需要做长时间的计算,处理器密集的工作,你应该选择使用并行编程,如果可能的话,以优化核心的使用。这将打开一些线程并同时处理一些事情。

假设你有一个数字数组,想要对每一个数字进行一些昂贵的长计算。平行是你的朋友。

异步编程在不同的用例中使用。

当你在等待一些不依赖于你的处理器的事情时,它用来释放你的线程,例如IO(写入和读取磁盘),当你执行IO时,你的线程什么都不做,当你等待一个昂贵的查询结果从DB返回时也是一样。

异步方法在线程等待很长时间返回结果时释放线程。这个线程可以被应用程序的其他部分使用(例如,在web应用程序中,它可以处理其他请求),也可以返回操作系统用于其他用途。

当您的结果完成时,相同的线程(或另一个线程)将返回给您的应用程序以继续处理。

在像。net这样的多线程环境中,异步编程不是强制性的(但是个很好的实践),在web应用程序中,其他线程将响应新请求,但如果你是在像nodejs这样的单线程框架中,这是强制性的,因为你不能阻塞你唯一的线程,否则你将无法回答任何其他请求。

总而言之,长处理器密集型计算将从并行编程中受益更多,而不依赖于处理器的长等待时间,如IO或DB查询或对某些API的调用将从异步编程中受益更多。

这就是为什么Entity Framework有一个async api来保存、列表、查找等等…

记住async/await与wait或waitAll不同,上下文不同。Async/await释放线程,是异步编程。wait / waitAll阻塞所有线程(它们没有被释放)来强制并行上下文中的同步…不同的东西…

希望这对某些人有用…

在一个简单的控制台程序中显示上述解释:

class Program
{
    static void Main(string[] args)
    {
        TestAsyncAwaitMethods();
        Console.WriteLine("Press any key to exit...");
        Console.ReadLine();
    }

    public async static void TestAsyncAwaitMethods()
    {
        await LongRunningMethod();
    }

    public static async Task<int> LongRunningMethod()
    {
        Console.WriteLine("Starting Long Running method...");
        await Task.Delay(5000);
        Console.WriteLine("End Long Running method...");
        return 1;
    }
}

输出为:

Starting Long Running method...
Press any key to exit...
End Long Running method...

因此,

Main通过TestAsyncAwaitMethods启动长时间运行的方法。这立即返回,而不停止当前线程,我们立即看到'按任何键退出'消息 在此期间,LongRunningMethod一直在后台运行。一旦它完成,来自Threadpool的另一个线程拾取该上下文并显示最终消息

因此,没有线程被阻塞。

为了最快的学习..

理解方法执行流程(用图表):3分钟 问题自省(为了学习):1分钟 快速浏览语法糖:5分钟 分享开发人员的困惑:5分钟 问题:快速将正常代码的实际实现更改为 异步代码:2分钟 下一步何去何从?

理解方法执行流程(用图表):3分钟

在这张图中,只关注#6(没有其他)

在第6步,执行工作耗尽并停止。要继续,它需要getStringTask(一种函数)的结果。因此,它使用await操作符来暂停进程,并将控制权交还给调用者(我们所在的方法)。对getStringTask的实际调用是在#2前面进行的。在#2中,承诺返回一个字符串结果。但是它什么时候会返回结果呢?我们应该(#1:AccessTheWebAsync)再次进行第二次调用吗?谁得到结果,#2(调用语句)还是#6(等待语句)?

AccessTheWebAsync()的外部调用者现在也在等待。调用者等待AccessTheWebAsync,而AccessTheWebAsync正在等待GetStringAsync。有趣的是AccessTheWebAsync在等待之前做了一些工作(#4),可能是为了节省等待的时间。同样的多任务自由也适用于外部调用者(以及链中的所有调用者),这是这个“异步”东西的最大优点!你觉得这是同步的,或者是正常的,但事实并非如此。

#2和#6被分开了,所以我们有#4的优势(边等待边工作)。但我们也可以不分裂。因此,#2将是:string urlContents = await client.GetStringAsync("…");这里我们没有看到任何优势,但在链的某个地方,一个函数将被分裂,而其他函数将调用它而不分裂。这取决于你使用链中的哪个函数/类。从一个函数到另一个函数的行为变化是本主题中最令人困惑的部分。

记住,该方法已经返回(#2),它不能再次返回(没有第二次)。那么,调用者如何知道呢?这都是关于任务!任务返回。等待任务状态(不是方法,不是值)。值将在任务中设置。任务状态将被设置为完成。调用者只监视任务(#6)。所以6#是在哪里/谁得到结果的答案。进一步阅读请点击这里。

为学习而反思问题:1分钟

让我们稍微调整一下这个问题:

如何以及何时使用async和await任务?

因为学习任务自动涵盖了其他两个(并回答了你的问题)。

整个想法非常简单。方法可以返回任何数据类型(double, int, object等),但在这里我们只是拒绝这一点,并强制返回一个'Task'对象!但我们仍然需要返回的数据(除了void),对吗?这将在'Task'对象中的标准属性中设置,例如:'Result'属性。

快速浏览语法糖:5分钟

原始的非异步方法

int方法(int arg0, int arg1) { Int result = arg0 + arg1; IO ();//执行一些长时间运行的IO。 返回结果; }

一个全新的Task-ified方法来调用上面的方法

内部静态任务<int> MethodTask(int arg0, int arg1) { Task<int> Task = new Task<int>(() => Method(arg0, arg1)); task.Start ();// Hot task(已启动的任务)应该总是返回。 返回任务; }

我们提到await或async了吗?不。调用上面的方法,就可以得到一个可以监视的任务。您已经知道任务返回(或包含)什么。一个整数。

调用Task有点棘手,这是关键字开始出现的时候。如果有一个方法调用原始方法(非异步),那么我们需要按照下面所示编辑它。让我们调用MethodTask()

内部静态异步任务<int> MethodAsync(int arg0, int arg1) { int result = await HelperMethods。MethodTask (arg0, __arg1); 返回结果; }

与上图相同的代码:

我们正在“等待”完成任务。因此使用await(强制语法) 因为使用了await,所以必须使用async(强制语法) 以Async为前缀的MethodAsync(编码标准)

await很容易理解,但其余两个(async, async)可能不是:)。好吧,这对编译器来说应该更有意义。进一步阅读请点击这里

所以有两个部分。

创建“任务”(只有一个任务,它将是一个额外的方法) 创建使用await+async调用任务的语法糖(如果要转换非异步方法,则需要更改现有代码)

记住,我们有一个外部调用AccessTheWebAsync()和调用者也没有幸免…也就是说,它也需要相同的await+async。这个链条还在继续(因此这是一个突破性的变化,可能会影响许多职业)。它也可以被认为是一个非破坏性的更改,因为原始方法仍然在那里等待调用。如果您想进行破坏性更改,则更改它的访问权限(或删除并将其移动到任务中),然后类将被迫使用task -method。无论如何,在异步调用中,总是在一端有一个任务,而且只有一个。

一切都好,但是有一个开发人员对Task感到惊讶 失踪……

分享开发人员的困惑:5分钟

开发人员犯了一个错误,没有实现Task,但它仍然可以工作!试着理解问题和这里提供的公认答案。希望你已经阅读并完全理解。总的来说,我们可能没有看到/实现“Task”,但它在父类/关联类的某个地方实现了。同样,在我们的例子中,调用一个已经构建的MethodAsync()要比自己用Task(MethodTask())实现该方法容易得多。大多数开发人员发现在将代码转换为异步代码时很难理解任务。

提示:尝试寻找一个现有的异步实现(如MethodAsync或ToListAsync)来外包这个困难。所以我们只需要处理Async和await(这很简单,非常类似于正常的代码)

问题:快速将正常代码的实际实现更改为 异步操作:2分钟

数据层中显示的代码行开始中断(许多地方)。因为我们从。net framework 4.2中更新了一些代码。*到。net核心。我们必须在1小时内修复整个应用程序!

var myContract = query.Where(c => c.ContractID == _contractID).First();

easypeasy !

我们安装了EntityFramework nuget包,因为它有QueryableExtensions。或者换句话说,它执行异步实现(任务),所以我们可以在代码中使用简单的Async和等待。 namespace =微软。EntityFrameworkCore

呼叫代码行是这样改变的

var myContract = await query.Where(c => c.ContractID == _contractID).FirstAsync();

方法签名从

GetContract(int contractnumber)

to

async Task<Contract> GetContractAsync(int contractnumber)

调用方法也受到影响:GetContract(123456);GetContractAsync(123456).Result;

等等!结果是什么?好赶上!GetContractAsync只返回一个任务而不是我们想要的值(合约)。一旦操作的结果可用,它就会被存储,并在后续调用result属性时立即返回。 我们也可以用类似的'Wait()'来实现超时

TimeSpan ts = TimeSpan. frommilliseconds (150);

如果(!t.Wait (ts)) 控制台。WriteLine("超时间隔已过");

我们在30分钟内把它换遍了所有地方!

但是架构师告诉我们不要仅为此使用EntityFramework库!哦!戏剧!然后我们创建了一个自定义的Task实现。你知道怎么做。还容易!..还咯咯大笑。

下一步何去何从? 我们可以观看一个关于在ASP中将同步调用转换为异步调用的视频。Net Core,也许这是读了这篇文章后人们会去的方向。或者我解释得够多了吗?;)