客服电话
APP下载
迪恩网络APP
随时随地掌握行业动态
官方微信
扫描二维码
关注迪恩网络微信公众号
|
Visual Studio提供的Controller创建向导默认为我们创建一个继承自抽象类Controller的Controller类型，这样的Controller只能定义同步Action方法。如果我们需要定义异步Action方法，必须继承抽象类AsyncController。这篇问你讲述两种不同的异步Action的定义方法和底层执行原理。[本文已经同步到《How ASP.NET MVC Works?》中]
ASP.NET通过线程池的机制处理并发的HTTP请求。一个Web应用内部维护着一个线程池，当探测到抵达的针对本应用的请求时，会从池中获取一个空闲的线程来处理该请求。当处理完毕，线程不会被回收，而是重新释放到池中。线程池具有一个线程的最大容量，如果创建的线程达到这个上限并且所有的线程均被处于“忙碌”状态，新的HTTP请求会被放入一个请求队列以等待某个完成了请求处理任务的线程重新释放到池中。 我们将这些用于处理HTTP请求的线程称为工作线程（Worker Thread），而这个县城池自然就叫做工作线程池。ASP.NET这种基于线程池的请求处理机制主要具有如下两个优势：
如果请求处理操作耗时较短，那么工作线程处理完毕后可以及时地被释放到线程池中以用于对下一个请求的处理。但是对于比较耗时的操作来说，意味着工作线程将被长时间被某个请求独占，如果这样的操作访问比较频繁，在高并发的情况下意味着线程池中将可能找不到空闲的工作线程用于及时处理最新抵达请求。 如果我们采用异步的方式来处理这样的耗时请求，工作线程可以让后台线程来接手，自己可以及时地被释放到线程池中用于进行后续请求的处理，从而提高了整个服务器的吞吐能力。值得一提的是，异步操作主要用于I/O绑定操作（比如数据库访问和远程服务调用等），而非CPU绑定操作，因为异步操作对整体性能的提升来源于：当I/O设备在处理某个任务的时候，CPU可以释放出来处理另一个任务。如果耗时操作主要依赖于本机CPU的运算，采用异步方法反而会因为线程调度和线程上下文的切换而影响整体的性能。 二、两种异步Action方法的定义在了解了在AsyncController中定义异步Action方法的必要性之后，我们来简单介绍一下异步Action方法的定义方式。总的来说，异步Action方法具有两种定义方式，一种是将其定义成两个匹配的方法XxxAsync/XxxCompleted，另一种则是定义一个返回类型为Task的方法。 XxxAsync/XxxCompleted如果我们使用两个匹配的方法XxxAsync/XxxCompleted来定义异步Action，我们可以将异步操作实现在XxxAsync方法中，而将最终内容的呈现实现在XxxCompleted方法中。XxxCompleted可以看成是针对XxxAsync的回调，当定义在XxxAsync方法中的操作以异步方式执行完成后，XxxCompleted方法会被自动调用。XxxCompleted的定义方式和普通的同步Action方法比较类似。 作为演示，我在如下一个HomeController中定义了一个名为Article的异步操作来呈现指定名称的文章内容。我们将指定文章内容的异步读取定义在ArticleAsync方法中，而在ArticleCompleted方法中讲读取的内容以ContentResult的形式呈现出来。 class HomeController : AsyncController
2: {
string name)
4: {
5: AsyncManager.OutstandingOperations.Increment();
6: Task.Factory.StartNew(() =>
7: {
, name));
new StreamReader(path))
10: {
] = reader.ReadToEnd();
12: }
13: AsyncManager.OutstandingOperations.Decrement();
14: });
15: }
string content)
17: {
return Content(content);
19: }
20: }
对于以XxxAsync/XxxCompleted形式定义的异步Action方法来说，ASP.NET MVC并不会以异步的方式来调用XxxAsync方法，所以我们需要在该方法中自定义实现异步操作的执行。在上面定义的ArticleAsync方法中，我们是通过基于Task的并行编程方式来实现对文章内容的异步读取的。当我们以XxxAsync/XxxCompleted形式定义的异步Action方法的时候，会频繁地使用到Controller的AsyncManager属性，该属性返回一个类型为AsyncManager对象，我们将在下面一节对其进行单独讲述。 在上面提供的实例中，我们在异步操作开始和结束的时候调用了AsyncManager的OutstandingOperations属性的Increment和Decrement方法对于ASP.NET MVC发起通知。此外，我们还利用AsyncManager的Parameters属性表示的字典来保存传递给ArticleCompleted方法的参数，参数在字典中的Key（content）与ArticleCompleted的参数名称是匹配的，所以在调用方法ArticleCompleted的时候，通过AsyncManager的Parameters属性指定的参数值将自动作为对应的参数值。 Task返回值如果采用上面的异步Action定义方式，意味着我们不得不为一个Action定义两个方法，实际上我们可以通过一个方法来完成对异步Action的定义，那就是让Action方法返回一个代表异步操作的Task对象。上面通过XxxAsync/XxxCompleted形式定义的异步Action可以采用如下的定义方式。 class HomeController : AsyncController
2: {
string name)
4: {
return Task.Factory.StartNew(() =>
6: {
, name));
new StreamReader(path))
9: {
] = reader.ReadToEnd();
11: }
12: }).ContinueWith<ActionResult>(task =>
13: {
];
return Content(content);
16: });
17: }
18: }
上面定义的异步Action方法Article的返回类型为Task<ActionResult>，我们将异步文件内容的读取体现在返回的Task对象中。对文件内容呈现的回调操作则通过调用该Task对象的ContinueWith<ActionResult>方法进行注册，该操作会在异步操作完成之后被自动调用。 如上面的代码片断所示，我们依然利用AsyncManager的Parameters属性实现参数在异步操作和回调操作之间的传递。其实我们也可以使用Task对象的Result属性来实现相同的功能，Article方法的定义也改写成如下的形式。 class HomeController : AsyncController
2: {
string name)
4: {
return Task.Factory.StartNew(() =>
6: {
, name));
new StreamReader(path))
9: {
return reader.ReadToEnd();
11: }
12: }).ContinueWith<ActionResult>(task =>
13: {
string)task.Result);
15: });
16: }
17: }
三、AsyncManager在上面演示的异步Action的定义中，我们通过AsyncManager实现了两个基本的功能，即在异步操作和回调操作之间传递参数和向ASP.NET MVC发送异步操作开始和结束的通知。由于AsyncManager在异步Action场景中具有重要的作用，我们有必要对其进行单独介绍，下面是AsyncManager的定义。 class AsyncManager
2: {
public AsyncManager();
public AsyncManager(SynchronizationContext syncContext);
5:
public EventHandler Finished;
7:
void Finish();
void Sync(Action action);
10:
public OperationCounter OutstandingOperations { get; }
object> Parameters { get; }
int Timeout { get; set; }
14: }
15:
class OperationCounter
17: {
event EventHandler Completed;
19:
int Increment();
value);
int Decrement();
value);
24:
int Count { get; }
26: }
如上面的代码片断所示，AsyncManager具有两个构造函数重载，非默认构造函数接受一个表示同步上下文的SynchronizationContext对象作为参数。如果指定的同步上下文对象为Null，并且当前的同步上下文（通过SynchronizationContext的静态属性Current表示）存在，则使用该上下文；否则创建一个新的同步上下文。该同步上下文用于Sync方法的执行，也就是说在该方法指定的Action委托将会在该同步上下文中以同步的方式执行。 AsyncManager的核心是通过属性OutstandingOperations表示的正在进行的异步操作计数器，该属性是一个类型为OperationCounter的对象。操作计数通过只读属性Count表示，当我们开始和完成异步操作的时候分别调用Increment和Decrement方法作增加和介绍计数操作。Increment和Decrement各自具有两个重载，作为整数参数value（该参数值可以是负数）表示增加或者减少的数值，如果调用无参方法，增加或者减少的数值为1。如果我们需要同时执行多个异步操作，则可以通过如下的方法来操作计数器。 1: AsyncManager.OutstandingOperations.Increment(3);
2:
3: Task.Factory.StartNew(() =>
4: {
//异步操作1
6: AsyncManager.OutstandingOperations.Decrement();
7: });
8: Task.Factory.StartNew(() =>
9: {
//异步操作2
11: AsyncManager.OutstandingOperations.Decrement();
12: });
13: Task.Factory.StartNew(() =>
14: {
//异步操作3
16: AsyncManager.OutstandingOperations.Decrement();
17: });
对于每次通过Increment和Decrement方法调用引起的计数数值的改变，OperationCounter对象都会检验当前计数数值是否为零，如果则表明所有的操作运行完毕，如果预先注册了Completed事件，该事件会被触发。值得一提的时候，表明所有操作完成执行的标志是计数器的值等于零，而不是小于零，如果我们通过调用Increment和Decrement方法使计数器的值称为一个负数，注册的Completed事件是不会被触发的。 AsyncManager在初始化的时候就注册了通过属性OutstandingOperations表示的OperationCounter对象的Completed事件，使该事件触发的时候调用自身的Finish方法。而虚方法Finish在AsyncManager中的默认实现又会触发自身的Finished事件。 如下面的代码片断所示，Controller类实现了IAsyncManagerContainer接口，而后者定义了一个只读属性AsyncManager用于提供辅助执行异步Action的AsyncManager对象，而我们在定义异步Action方法是使用的AsyncManager对象就是从抽象类Controller中集成下来的AsyncManager属性。 class Controller : ControllerBase, IAsyncManagerContainer,...
2: {
public AsyncManager AsyncManager { get; }
4: }
5:
interface IAsyncManagerContainer
7: {
8: AsyncManager AsyncManager { get; }
9: }
四、Completed方法的执行对于通过XxxAsync/XxxCompleted形式定义的异步Action，我们说回调操作XxxCompleted会在定义在XxxAsync方法中的异步操作执行结束之后被自动调用，那么XxxCompleted方法具体是如何被执行的呢？ 异步Action的执行最终是通过描述该Action的AsyncActionDescriptor对象的BeginExecute/EndExecute方法来完成的。通过之前“Model的绑定”的介绍我们知道通过XxxAsync/XxxCompleted形式定义的异步Action通过一个ReflectedAsyncActionDescriptor对象来表示的，ReflectedAsyncActionDescriptor在执行BeginExecute方法的时候会注册Controller对象的AsyncManager的Finished事件，使该事件触发的时候去执行Completed方法。 也就是说针对当前Controller的AsyncManager的Finished事件的触发标志着异步操作的结束，而此时匹配的Completed方法会被执行。由于AsyncManager的Finish方法会主动触发该事件，所以我们可以通过调用该方法使Completed方法立即执行。由于AsyncManager的OperationCounter对象的Completed事件触发的时候会调用Finish方法，所以当表示当前正在执行的异步操作计算器的值为零时，Completed方法也会自动被执行。 如果我们在XxxAsync方法中通过如下的方式同时执行三个异步操作，并在每个操作完成之后调用AsyncManager的Finish方法，意味着最先完成的异步操作会导致XxxCompleted方法的执行。换句话说，当XxxCompleted方法执行的时候，可能还有两个异步操作正在执行。 1: AsyncManager.OutstandingOperations.Increment(3);
2:
3: Task.Factory.StartNew(() =>
4: {
//异步操作1
6: AsyncManager.Finish();
7: });
8: Task.Factory.StartNew(() =>
9: {
//异步操作2
11: AsyncManager.Finish();
12: });
13: Task.Factory.StartNew(() =>
14: {
//异步操作3
16: AsyncManager.Finish();
17: });
如果完全通过为完成的异步操作计数机制来控制XxxCompleted方法的执行，由于计数的检测和Completed事件的触发只发生在OperationCounter的Increment/Decrement方法被执行的时候，如果我们在开始和结束异步操作的时候都没有调用这两个方法，XxxCompleted是否会执行呢？同样以之前定义的用语读取/显示文章内容的异步Action为例，我们按照如下的方式将定义在ArticleAsync方法中针对AsyncManager的OutstandingOperations属性的Increment和Decrement方法调用注释调用，ArticleCompleted方法是否还能正常运行呢？ class HomeController : AsyncController
2: {
string name)
4: {
//AsyncManager.OutstandingOperations.Increment();
6: Task.Factory.StartNew(() =>
7: {
, name));
new StreamReader(path))
10: {
] = reader.ReadToEnd();
12: }
//AsyncManager.OutstandingOperations.Decrement();
14: });
15: }
string content)
17: {
return Content(content);
19: }
全部评论
专题导读
上一篇：Asp.Net SignalR 多平台的Client与Server发布时间：2022-07-10下一篇：SharePoint基础之六- SharePoint基础架构中涉及的ASP.NET架构发布时间：2022-07-10热门推荐
热门话题
阅读排行榜
|
请发表评论