当前位置: 首页 > news >正文

异步编程详解(.NET)

在之前写的一篇关于asyncawait的前世今生的文章之后,大家似乎在asyncawait提高网站处理能力方面还有一些疑问,很多网站本身也做了不少的尝试。今天我们再来回答一下这个问题,同时我会做一个asyncawaitWinForm中的尝试,并且对比在4.5之前的异步编程模式APM/EAPasync/await的区别,最后我还会探讨在不同线程之间交互的问题。

众所周知,IIS存在着处理能力的问题,但是WinForm却是UI响应的问题,并且WinFormUI线程至始至终都是同一个,所以两者之间有一定的区别。
  
有人可能会问,现在还有人写WinForm吗?当然有啊,比如说我还在用,但它确实是一个比较老的东西呢,不如WPF酷炫,技术也不如WPF先进。
但是从架构层面来讲,不管是Web,还是WinForm,又或是WPFMobile,这些都只是表现层,你觉得不是吗?
现在的大型系统一般桌面客户端、Web端、手机、平板端等都会涉及,这也是为什么会有应用层,服务层的存在。
我们在这里谈论的ASP.NET MVCWinFormWFPAndroidIOSWP 等都是表现层,在表现层我们应该只处理与“表现”相关的逻辑,任何与业务相关的逻辑应该都是放在下层处理的。关于架构的问题,我们后面再慢慢深入,另外别怪我没有提示您,我今天还会看到.NET中另一个已经老去的技术Web Service

还得提示您,文章内容有点长,涉及的知识点比较多,所以,我推荐:”先赞后看“ ,先赞后看是21世纪看长篇的首选之道,是良好沟通的开端,想知道是什么会让你与众不同吗?想知道为什么上海今天会下这么大的雨吗?请记住先赞后看,你赞的不是我的文章,而是我冒着大雨还要去上班的可贵精神!先赞后看,你值得拥有!
async/await如何提升IIS处理能力

首先响应能力并不完全是程序性能的问题,有时候可能你的程序没有任何问题,而且经过精心设计和优化,可是响应能力还是不够理想,网站性能分析是一个复杂的活,有时候只能靠经验和不断的尝试才能达到比较好的效果。当然我今天讨论的主要是IIS的处理能力,或者也可能说是IIS的性能,但绝非代码本身的性能。即使async/await能够提高IIS的处理能力,但是对于用户来说整个页面从发起请求到页面渲染完成这段时间,是不是因为我们增加了async/await之后产生的变化?
  另外异步的ASP.NET并非只有async/await才能实现,ASP.NETWeb Form时代就已经有异步Page了,包括ASP.NET MVC不一样也有异步的Controller么?async/await 很酷,但它也只是在原有一技术基础上做了一些改进,程序员在写异步代码时更容易了。大家常说微软喜欢新瓶装旧酒,至少我们要看到这个新瓶给我们带来了什么?不管是任何产品,都不可能一开始就很完美,都需要不断的更新迭代,也可以说是一种正确做事的方式。
ASP.NET并行处理的步骤

ASP.NET是如何在IIS中工作的一文已经很详细的介绍了一个请求是如何从客户端到服务器的HTTP.SYS最后进入CLR进行处理的(强烈建议不了解这一块的同学先看这篇文章,有助于你理解本小节),但是所有的步骤都是基于一个线程的假设下进行的。IIS本身就是一个多线程的工作环境,如果我们从多线程的视角来看会发生什么变化呢?首先我们看下面这张图,注意:下面的步骤是建立在IIS 7.0以后的集成模式基础之上的。

在这里插入图片描述
我们再来梳理一下上面的步骤:
所有的请求最开始是由HTTP.SYS接收的,HTTP.SYS内部有一个队列维护着这些请求,这个队列的request的数量大于一定数量(默认是1000)的时候,HTTP.SYS就会直接返回503状态(服务器忙),这是我们的第一个阀门。性能计数指标:“Http Service Request Queues\CurrentQueueSize”。

w3dt负责把请求从HTTP.SYS 的队列中放到一个对应端口的队列中,据非官方资料显示该队列长度能为20(该队列是非公开的,没有文档,所以也没有性能计数器)。
IIS 的IO线程从上一步的队列中获取请求,如果是需要ASP.NET处理的,就会转交给CLR 线程池的Worker 线程,IIS的IO线程继续返回重复做该步骤。CLR 线程池的Worker线程数量是第二个阀门。

当CLR中正在被处理的请求数据大于一定值(最大并行处理请求数量,.NET4以后默认是5000)的时候,从IO线程过来的请求就不会直接交给Worker线程,而是放到一个进程池级别的一个队列了,等到这个数量小于临界值的时候,才会把它再次交给Worker线程去处理。这是我们的第三个阀门。

上一步中说到的那个进程池级别的队列有一个长度的限制,可以通过web.config里面的processModel/requestQueueLimit来设置。这可以说也是一个阀门。当正在处理的数量大于所允许的最大并行处理请求数量的时候,我们就会得到503了。可以通过性能计数指标:“ASP.NET v4.0.30319\Requests Queued” 来查看该队列的长度。
哪些因素会控制我们的响应能力

从上面我们提到了几大阀门中,可以得出下面的几个数字控制或者说影响着我们的响应能力。
  
HTTP.SYS队列的长度

CLR线程池最大Worker线程数量

最大并行处理请求数量

进程池级别队列所允许的长度

HTTP.SYS队列的长度

这个我觉得不需要特别解释,默认值是1000。这个值取决于我们我们后面IIS IO线程和Worker线程的处理速度,如果它们两个都处理不了,这个数字再大也没有用。因为最后他们会被存储到进程池级别的队列中,所以只会造成内存的浪费。
最大Worker线程数量
  这个值是可以在web.config中进行配置的。

在这里插入图片描述
maxWorkerThreads: CLR中真实处理请求的最大Worker线程数量。
  minWorkerThreads:CLR中真实处理请求的最小Worker线程数量。
  minWorkerThreads的默认值是1,合理的加大它们可以避免不必要的线程创建和销毁工作。
最大并行处理请求数量
 进程池级别的队列给CLR一定的缓冲,需要注意,这个队列还没有进入到CLR,所以它不会占用我们托管环境的任何资源,把请求卡在CLR的外面。我们需要在aspnet.config级别进行配置,在.Net Fraemwork的安装目录下找到它。一般是 C:\Windows\Microsoft.NET\Framework\v4.0.30319 如果你安装的是4.0版本。
在这里插入图片描述

maxConcurrentRequestPerCPU: 每个CPU所允许的最大并行处理请求数量,当CLR中Worker线程正在处理的请求之和大于这个数时,从IO线程过来的请求就会被放到我们进程池级别的队列中。
  maxConcurrentThreadsPerCPU: 设置为0即禁用。
  requestQueue: 进程池级别队列所允许的长度。
  
async和await 做了什么?

终于要切入主题了,就ASP.NET MVC举例,如果不采用async的Action,那么毫无疑问,它是在一个Woker线程中执行的。当我们访问一些web service,或者读文件的时候,这个Worker线程就会被阻塞。假设我们这个Action执行时间一共是100ms,其它访问web service花费80ms,理想情况下一个Worker线程一秒可以响应10个请求,假设我们的maxWorkerThreads是10,那我们一秒内总是可响应请求就是100。如果说我们想把这个可响应请求数升到200怎么做呢?
  
  有人会说,这还不简单,把maxWorkerThreads调20不就行了么? 其实这么做也没有什么问题,确实是可以的,而且也确实能起到作用。那我们为什么还要大费周章的搞什么 async/await呢?搞得脑子都晕了?async/await给我们解决了什么问题?它可以在我们访问web service的时候把当前的Worker线程放走,将它放回线程池,这样它就可以去处理其它的请求了。等到web service给我们返回结果了,会再到线程池中随机拿一个新的woker线程继续往下执行。也就是说我们减少了那一部分等待的时间,充份利用了线程。
  
  我们来对比一下使用async/awit和不使用的情况,
  不使用async/await: 20个woker线程1s可以处理200个请求。
  那转换成总的时间的就是 20 * 1000ms = 20000ms,
  其中等待的时间为 200 * 80ms = 16000ms。
  也就是说使用async/await我们至少节约了16000ms的时间,这20个Worker线程又会再去处理请求,即使按照每个请求100ms的处理时间我们还可以再增加160个请求。而且别忘了100ms是基于同步情况下,包括等待时间在内的基础上得到的,所以实际情况可能还要多,当然这里没有算上线程切换的时间,所以实际情况中是有一点差异的,但是应该不会很大,因为我们的线程都是基于线程池的操作。
  
  所有结果是20个Worker线程不使用异步的情况下,1s能自理200个请求,而使用异步的情况下可以处理360个请求,立刻提升80%!采用异步之后,对于同样的请求数量,需要的Worker线程数据会大大减少50%左右,一个线程至少会在堆上分配1M的内存,如果是1000个线程那就是1G的容量,虽然内存现在便宜,但是省着总归是好的嘛,而且更少的线程是可以减少线程池在维护线程时产生的CPU消耗的。另:CLR在1秒之内只能创建2个线程。
  
  注意:以上数据并非真实测试数据,真实情况一个request的时间也并非100ms,花费在web service上的时间也并非80ms,仅仅是给大家一个思路,所以这里用了async和await之后对响应能力有多大的提升和我们原来堵塞在这些IO和网络上的时间是有很大的关系的。
几点建议

看到这里,不知道大家有没有得到点什么。首先第一点我们要知道的是async/await不是万能药,不能指望只靠写两个关键字就希望性能的提升。要记住,一个CPU在同一时间段内是只能执行一个线程的。所以这也是为什么async和await建议在IO或者是网络操作的时候使用。我们的MVC站点访问WCF或者Web Service这种场景就非常的适合使用异步操作。在上面的例子中80ms读取web service的时间,大部份时间都是不需要cpu操作的,这样cpu才可以被其它的线程利用,如果不是一个读取web service的操作,而是一个复杂计算的操作,那你就等着cpu爆表吧。
  
  除了程序中利用异步,我们上面讲到的关于IIS的配置是很重要的,如果使用了异步,请记得把maxWorkerThreads和maxConcurrentRequestPerCPU的值调高试试。
  
早期对Web service的异步编程模式APM

讲完我们高大上的async/await之后,我们来看看这个很老的技术,但是概念确依旧延续至今的Web Service。 我们这里所说的针对web service的异步编程模式不是指在服务器端的web service本身,而是指调用web service的客户端。
大家知道对于web service,我们通过添加web service引用或者.net提供的生成工具就可以生成相应的代理类,可以让我们像调用本地代码一样访问web service,而所生成的代码类中针对每一个web service方法生成3个对应的方法,比如说我们的方法名叫DownloadContent,除了这个方法之外还有BeginDownloadContent和EndDownloadContent方法,而这两个就是我们今天要说的早期的异步编程模式APM(Asynchronous Programming Model)。
下面就来看看我们web service中的代码,注意我们现在的项目都是在.NET Framework3.5下实现的。

public class PageContent : System.Web.Services.WebService
{[WebMethod]public string DownloadContent(string url){var client = new System.Net.WebClient();return client.DownloadString(url);}
}

注意web service中的DownloadContent方法调用的是WebClient的同步方法,WebClient也有异步方法,即:DownloadStringAsync。但是大家要明白,不管服务器是同步还是异步,当客户端调用web service都是一样的,就是得等待你返回结果。

当然,我们也可以像MVC中的代码一样,把服务器端也写成异步的。那得到好处的是那个托管web service的服务器,它的处理能力得到提高,就像ASP.NET一样。如果我们用JavaScript去调用Web Service,那么Ajax(Asynchronous Javascript + XML)就是客户端用到的异步编程技术。如果是其它的客户端呢?比如说一个CS的桌面程序?我们需要异步编程么?
当WinForm遇上Web Service

WinForm不像托管在IIS的ASP.NET网站,会有一个线程池管理着多个线程来处理用户的请求,ASP.NET网站本身就是基于多线程的。但是,在WinForm中,如果我们不刻意使用多线程,那至始至终,都只有一个线程,称之为UI线程(与Android系统很类似)。也许在一些小型的系统中,WinForm很少涉及到多线程,因为WinForm本身的优势就在它是独立运行在客户端,在性能上和可操作性上都会有很大的优势。所以很多中小型的WinForm系统都是直接就访问数据库了,并且基本上也只有数据的传输,什么图片资源那是很少的,所以等待的时间是很短的,基本不用考虑像在3秒之内必须将页面显示到用户面前这种问题。
  
  既然WinForm在性能上有这么大的优势,那它还需要异步吗?
  
  我们上面说的是中小型WinForm,如果是大型的系统呢?如果WinForm只是其它的很小一部分,就像我们文章开始说的还有很多其它成千上万个手机客户端,Web客户端,平板客户端呢?如果客户端很多导致数据库撑不住怎么办? 想在中间加一层缓存怎么办?
  
  比如B2B的网站功能,用户可以通过网站下单,手机也可以下单,还可以通过电脑的桌面客户端下单。在下完单之后要完成交易,库存扣减,发送订单确认通知等功能,而不管你的订单是通过哪个端完成的,这些功能我们都要去做,对吗?那我们就不能单独放在WinForm里面,不然这些代码在其它的端里面又得全部全新再一一实现,同样的代码放在不同的地方那可是相当危险的,所以就有了我们后来的SOA架构,把这些功能都抽成服务,每种类型的端都是调用服务就可以了。一是可以统一维护这些功能,二是可以很方便的做扩展,去更好的适应功能和架构上的扩展。比如像下面这样的一个系统。

在这里插入图片描述

在上图中,Web端虽然也是属于我们平常说的服务端(甚至是由多台服务器组成的web群集),但是对我们整个系统来说,它也只是一个端而已。对于一个端来说,它本身只处理和用户交互的问题,其余所有的功能,业务都会交给后来台处理。在上面的架构中,应用层都不会直接参加真正业务逻辑相关的处理,而是放到我们更下层数据层去做处理。那么应用层主要协助做一些与用户交互的一些功能,如果手机短信发送,邮件发送等等,并且可以根据优先级选择是放入队列中稍候处理还是直接调用功能服务立即处理。

在这样的一个系统中,我们的Web服务器也好,Winform端也好都将只是整个系统中的一个终端,它们主要的作用是用户和后面服务之间的一个桥梁。涉及到Service的调用之后,为了给用户良好的体验,在WinForm端,我们自然就要考虑异步的问题。
  
WinForm异步调用Web Service

有了像VS这样强大的工具为我们生成代理类,我们在写调用Web service的代码时就可以像调用本地类库一样调用Web Service了,我们只需要添加一个Web Reference就可以了。

在这里插入图片描述

private void button1_Click(object sender, EventArgs e) 
{var pageContentService = new localhost.PageContent();pageContentService.BeginDownloadContent(  "http://jesse2013.cnblogs.com",new AsyncCallback(DownloadContentCallback),  pageContentService);
}
private void DownloadContentCallback(IAsyncResult result)
{var pageContentService = (localhost.PageContent)result.AsyncState;var msg = pageContentService.EndDownloadContent(result);  MessageBox.Show(msg);
} 

代码非常的简单,在执行完pageContentService.BeginDownloadContent之后,我们的主线程就返回了。在调用Web service这段时间内我们的UI不会被阻塞,也不会出现“无法响应这种情况”,我们依然可以拖动窗体甚至做其它的事情。这就是APM的魔力,但是我们的callback究竟是在哪个线程中执行的呢?是线程池中的线程么?咋们接着往下看。

APM异步编程模式详解

线程问题

接下来我们更进一步的了解APM这种模式是如何工作的,但是首先我们要回答上面留下来的问题,这种异步的编程方式有没有为我们开启新的线程?让代码说话:

private void button1_Click(object sender, EventArgs e)
{Trace.TraceInformation("Is current thread from thread pool? {0}", Thread.CurrentThread.IsThreadPoolThread ? "Yes" : "No");Trace.TraceInformation("Start calling web service on thread: {0}", Thread.CurrentThread.ManagedThreadId);var pageContentService = new localhost.PageContent();pageContentService.BeginDownloadContent("http://jesse2013.cnblogs.com",new AsyncCallback(DownloadContentCallback),pageContentService);
}private void DownloadContentCallback(IAsyncResult result)
{var pageContentService = (localhost.PageContent)result.AsyncState;var msg = pageContentService.EndDownloadContent(result);Trace.TraceInformation("Is current thread from thread pool? {0}" , Thread.CurrentThread.IsThreadPoolThread ? "Yes" : "No");Trace.TraceInformation("End calling web service on thread: {0}, the result of the web service is: {1}",Thread.CurrentThread.ManagedThreadId,msg);
} 

我们在按钮点击的方法和callback方法中分别输出当前线程的ID,以及他们是否属于线程池的线程,得到的结果如下:

   Desktop4.0.vshost.exe Information: 0 : Is current thread a background thread? NODesktop4.0.vshost.exe Information: 0 : Is current thread from thread pool? NODesktop4.0.vshost.exe Information: 0 : Start calling web service on thread: 9Desktop4.0.vshost.exe Information: 0 : Is current thread a background thread? YESDesktop4.0.vshost.exe Information: 0 : Is current thread from thread pool? YESDesktop4.0.vshost.exe Information: 0 : End calling web service on thread: 14, the result of the web service is: <!DOCTYPE html>...

按钮点击的方法是由UI直接控制,很明显它不是一个线程池线程,也不是后台线程。而我们的callback却是在一个来自于线程池的后台线程执行的,答案揭晓了,可是这会给我们带来一个问题,我们上面讲了只有UI线程也可以去更新我们的UI控件,也就是说在callback中我们是不能更新UI控件的,那我们如何让更新UI让用户知道反馈呢?答案在后面接晓 😃,让我们先专注于把APM弄清楚。

从Delegate开始

其实,APM在.NET3.5以前都被广泛使用,在WinForm窗体控制中,在一个IO操作的类库中等。大家可以很容易找到搭配了Begin和End的方法,更重要的是只要是有代理的地方,我们都可以使用APM这种模式。我们来看一个很简单的例子:

delegate void EatAsync(string food);
private void button2_Click(object sender, EventArgs e)
{var myAsync = new EatAsync(eat);Trace.TraceInformation("Activate eating on thread: {0}", Thread.CurrentThread.ManagedThreadId);myAsync.BeginInvoke("icecream", new AsyncCallback(clean), myAsync);
}private void eat(string food)
{Trace.TraceInformation("I am eating.... on thread: {0}", Thread.CurrentThread.ManagedThreadId);
}private void clean(IAsyncResult asyncResult)
{Trace.TraceInformation("I am done eating.... on thread: {0}", Thread.CurrentThread.ManagedThreadId);
} 

上面的代码中,我们通过把eat封装成一个委托,然后再调用该委托的BeginInvoke方法实现了异步的执行。也就是实际的eat方法不是在主线程中执行的,我们可以看输出的结果:

   Desktop4.0.vshost.exe Information: 0 : Activate eating on thread: 10Desktop4.0.vshost.exe Information: 0 : I am eating.... on thread: 6Desktop4.0.vshost.exe Information: 0 : I am done eating.... on thread: 6

clean是我们传进去的callback,该方法会在我们的eat方法执行完之后被调用,所以它会和我们eat方法在同一个线程中被调用。大家如果熟悉代理的话就会知道,代码实际上会被编译成一个类,而BeginInvoke和EndInvoke方法正是编译器为我们自动加进去的方法,我们不用额外做任何事情,这在早期没有TPL和async/await之前(APM从.NET1.0时代就有了),的确是一个不错的选择。

再次认识APM

了解了Delegate实现的BeginInvoke和EndInvoke之后,我们再来分析一下APM用到的那些对象。 拿我们Web service的代理类来举例,它为我们生成了以下3个方法:

string DownloadContent(string url): 同步方法
IAsyncResult BeginDownloadContent(string url, AsyncCallback callback, object asyncState): 异步开始方法
EndDownloadContent(IAsyncResult asyncResult):异步结束方法

在我们调用EndDownloadContent方法的时候,如果我们的web service调用还没有返回,那这个时候就会用阻塞的方式去拿结果。但是在我们传到BeginDownloadContent中的callback被调用的时候,那操作一定是已经完成了,也就是说IAsyncResult.IsCompleted = true。而在APM异步编程模式中Begin方法总是返回IAsyncResult这个接口的实现。IAsyncReuslt仅仅包含以下4个属性:
在这里插入图片描述
WaitHanlde通常作为同步对象的基类,并且可以利用它来阻塞线程,更多信息可以参考MSDN 。 借助于IAsyncResult的帮助,我们就可以通过以下几种方式去获取当前所执行操作的结果。
轮询
强制等待
完成通知
  完成通知就是在"WinForm异步调用WebService"那段中用到的方法,调用完Begin方法之后,主线程就算完成任务了。我们也不用监控该操作的执行情况,当该操作执行完之后,我们在Begin方法中传进去的callback就会被调用了,我们可以在那个方法中调用End方法去获取结果。下面我们再简单说一下前面两种方式。

//轮询获取结果代码
ar pageContentService = new localhost.PageContent();
IAsyncResult asyncResult = pageContentService.BeginDownloadContent("http://jesse2013.cnblogs.com",null,pageContentService);while (!asyncResult.IsCompleted)
{Thread.Sleep(100);
}
var content = pageContentService.EndDownloadContent(asyncResult); 
// 强制等待结果代码
var pageContentService = new localhost.PageContent();
IAsyncResult asyncResult = pageContentService.BeginDownloadContent("http://jesse2013.cnblogs.com",null,pageContentService);// 也可以调用WaitOne()的无参版本,不限制强制等待时间
if (asyncResult.AsyncWaitHandle.WaitOne(2000))
{var content = pageContentService.EndDownloadContent(asyncResult);
}
else
{ // 2s时间已经过了,但是还没有执行完   
} 

EAP(Event-Based Asynchronous Pattern)

EAP是在.NET2.0推出的另一种过渡的异步编程模型,也是在.NET3.5以后Microsoft支持的一种做法,为什么呢? 如果大家建一个.NET4.0或者更高版本的WinForm项目,再去添加Web Reference就会发现生成的代理类中已经没有Begin和End方法了,记住在3.5的时候是两者共存的,你可以选择任意一种来使用。但是到了.NET4.0以后,EAP成为了你唯一的选择。(我没有尝试过手动生成代理类,有兴趣的同学可以尝试一下)让我们来看一下在.NET 4.0中,我们是如何异步调用Web Service的。

private void button1_Click(object sender, EventArgs e)
{var pageContent = new localhost.PageContent();pageContent.DownloadContentAsync("http://jesse2013.cnblogs.com");pageContent.DownloadContentCompleted += pageContent_DownloadContentCompleted;
}private void pageContent_DownloadContentCompleted(object sender, localhost.DownloadContentCompletedEventArgs e)
{if (e.Error == null){textBox1.Text = e.Result;}else{ // 出错了}
} 

线程问题

不知道大家还是否记得,在APM模式中,callback是执行在另一个线程中,不能随易的去更新UI。但是如果你仔细看一下上面的代码,我们的DownloadContentCompleted事件绑定的方法中直接就更新了UI,把返回的内容写到了一个文本框里面。通过同样的方法可以发现,在EAP这种异步编程模式下,事件绑定的方法也是在调用的那个线程中执行的。也就是说解决了异步编程的时候UI交互的问题,而且是在同一个线程中执行。 看看下面的代码:

private void button1_Click(object sender, EventArgs e)
{Trace.TraceInformation("Call DownloadContentAsync on thread: {0}", Thread.CurrentThread.ManagedThreadId);Trace.TraceInformation("Is current from thread pool? : {0}", Thread.CurrentThread.IsThreadPoolThread ? "YES" : "NO");var pageContent = new localhost.PageContent();pageContent.DownloadContentAsync("http://jesse2013.cnblogs.com");pageContent.DownloadContentCompleted += pageContent_DownloadContentCompleted;
}private void pageContent_DownloadContentCompleted(object sender, localhost.DownloadContentCompletedEventArgs e)
{Trace.TraceInformation("Completed DownloadContentAsync on thread: {0}", Thread.CurrentThread.ManagedThreadId);Trace.TraceInformation("Is current from thread pool? : {0}", Thread.CurrentThread.IsThreadPoolThread ? "YES" : "NO");
} 
   Desktop4.vshost.exe Information: 0 : Call DownloadContentAsync on thread: 10Desktop4.vshost.exe Information: 0 : Is current from thread pool? : NODesktop4.vshost.exe Information: 0 : Completed DownloadContentAsync on thread: 10Desktop4.vshost.exe Information: 0 : Is current from thread pool? : NO

async/await 给WinFrom带来了什么?

如果说async给ASP.NET带来的是处理能力的提高,那么在WinForm中给程序员带来的好处则是最大的。我们再也不用因为要实现异步写回调或者绑定事件了,省事了,可读性也提高了。不信你看下面我们将调用我们那个web service的代码在.NET 4.5下实现一下:

private async void button2_Click(object sender, EventArgs e)
{var pageContent = new localhost.PageContentSoapClient();var content = await pageContent.DownloadContentAsync("http://jesse2013.cnblogs.com");textBox1.Text = content.Body.DownloadContentResult;
} 

简单的三行代码,像写同步代码一样写异步代码,我想也许这就是async/await的魔力吧。在await之后,UI线程就可以回去响应UI了,在上面的代码中我们是没有新线程产生的,和EAP一样拿到结果直接就可以对UI操作了。

async/await似乎真的很好,但是如果我们await后面的代码执行在另外一个线程中会发生什么事情呢?

private async void button1_Click(object sender, EventArgs e)
{label1.Text = "Calculating Sqrt of 5000000";button1.Enabled = false;progressBar1.Visible = true;double sqrt = await Task<double>.Run(() =>{double result = 0;for (int i = 0; i < 50000000; i++){result += Math.Sqrt(i);progressBar1.Maximum = 50000000;progressBar1.Value = i;}return result;});progressBar1.Visible = false;button1.Enabled = true;label1.Text = "The sqrt of 50000000 is " + sqrt;
} 

我们在界面中放了一个ProgressBar,同时开一个线程去把从1到5000000的平方全部加起来,看起来是一个非常耗时的操作,于是我们用Task.Run开了一个新的线程去执行。(注:如果是纯运算的操作,多线程操作对性能没有多大帮助,我们这里主要是想给UI一个进度显示当前进行到哪一步了。)看起来没有什么问题,我们按F5运行吧!
在这里插入图片描述
当执行到这里的时候,程序就崩溃了,告诉我们”无效操作,只能从创建porgressBar的线程访问它。“ 这也是我们一开始提到的,在WinForm程序中,只有UI主线程才能对UI进行操作,其它的线程是没有权限的。接下来我们就来看看,如果在WinForm中实现非UI线程对UI控制的更新操作。
不同线程之间通讯的问题

万能的Invoke

WinForm中绝大多数的控件包括窗体在内都实现了Invoke方法,可以传入一个Delegate,这个Delegate将会被拥有那个控制的线程所调用,从而避免了跨线程访问的问题。

Trace.TraceInformation("UI Thread : {0}", Thread.CurrentThread.ManagedThreadId);
double sqrt = await Task<double>.Run(() =>
{Trace.TraceInformation("Run calculation on thread: {0}", Thread.CurrentThread.ManagedThreadId);double result = 0;for (int i = 0; i < 50000000; i++){result += Math.Sqrt(i);progressBar1.Invoke(new Action(() => {Trace.TraceInformation("Update UI on thread: {0}", Thread.CurrentThread.ManagedThreadId);progressBar1.Maximum = 50000000;progressBar1.Value = i;}));}return result;
}); 
   Desktop.vshost.exe Information: 0 : UI Thread : 9Desktop.vshost.exe Information: 0 : Run calculation on thread: 10Desktop.vshost.exe Information: 0 : Update UI on thread: 9

Invoke方法比较简单,我们就不做过多的研究了,但是我们要考虑到一点,Invoke是WinForm实现的UI跨线程沟通方式WPF用的却是Dispatcher,如果是在ASP.NET下跨线程之间的同步又怎么办呢。为了兼容各种技术平台下,跨线程同步的问题,Microsoft在.NET 2.0的时候就引入了我们下面的这个对象。

SynchronizationContext上下文同步对象

为什么需要SynchronizationContext

就像我们在WinForm中遇到的问题一样,有时候我们需要在一个线程中传递一些数据或者做一些操作到另一个线程。但是在绝大多数情况下这是不允许的,出于安全因素的考虑,每一个线程都有它独立的内存空间和上下文。因此在.NET 2.0,微软推出了SynchronizationContext
  
  它主要的功能之一是为我们提供了一种将一些工作任务(Delegate)以队列的方式存储在一个上下文对象中,然后把这些上下文对象关联到具体的线程上,当然有时候多个线程也可以关联到同一个SynchronizationContext对象。获取当前线程的同步上下文对象可以使用SynchronizationContext.Current。同时它还为我们提供以下两个方法Post和Send,分别是以异步和同步的方法将我们上面说的工作任务放到我们SynchronizationContext的队列中。
  
SynchronizationContext示例

还是拿我们上面Invoke中用到的例子举例,只是这次我们不直接调用控件的Invoke方法去更新它,而是写了一个Report的方法专门去更新UI。

double sqrt = await Task<double>.Run(() =>
{Trace.TraceInformation("Current thread id is:{0}", Thread.CurrentThread.ManagedThreadId);double result = 0;for (int i = 0; i < 50000000; i++){result += Math.Sqrt(i);Report(new Tuple<int, int>(50000000, i));}return result;
}); 

每一次操作完之后我们调用一下Report方法,把我们总共要算的数字,以及当前正在计算的数字传给它就可以了。接下来就看我们的Report方法了。

private SynchronizationContext m_SynchronizationContext;
private DateTime m_PreviousTime = DateTime.Now;public Form1()
{InitializeComponent();// 在全局保存当前UI线程的SynchronizationContext对象m_SynchronizationContext = SynchronizationContext.Current;
}public void Report(Tuple<int, int> value)
{DateTime now = DateTime.Now;if ((now - m_PreviousTime).Milliseconds > 100){m_SynchronizationContext.Post((obj) =>{Tuple<int, int> minMax = (Tuple<int, int>)obj;progressBar1.Maximum = minMax.Item1;progressBar1.Value = minMax.Item2;}, value);m_PreviousTime = now;}
} 

整个操作看起来要比Inovke复杂一点,与Invoke不同的是SynchronizationContext不需要对Control的引用,而Invoke必须先得有那个控件才能调用它的Invoke方法对它进行操作。

小结

这篇博客内容有点长,不知道有多少人可以看到这里。最开始我只是想写写WinFrom下异步调用Web Service的一些东西,在一开始这篇文件的题目是”异步编程在WinForm下的实践“,但是写着写着发现越来越多的迷团没有解开,其实都是一些老的技术以前没有接触和掌握好,所以所幸就一次性把他们都重新学习了一遍,与大家分享。
  
  我们再来回顾一下文章所涉及到的一些重要的概念:
  
async/await 在ASP.NET做的最大贡献(早期ASP.NET的异步开发模式同样也有这样的贡献),是在访问数据库的时候、访问远程IO的时候及时释放了当前的处理进程,可以让这些线程回到线程池中,从而实现可以去处理其它请求的功能。
异步的ASP.NET开发能够在处理能力上带来多大的提高,取决于我们的程序有多少时间是被阻塞的,也就是那些访问数据库和远程Service的时间。

除了将代码改成异步,我们还需要在IIS上做一些相对的配置来实现最优化。
不管是ASP.NET、WinForm还是Mobile、还是平板,在大型系统中都只是一个与用户交互的端而已,所以不管你现在是做所谓的前端(JavaScript + CSS等),还是所谓的后端(ASP.NET MVC、WCF、Web API 等 ),又或者是移动端(IOS也好,Andrioid也罢,哪怕是不争气的WP),都只是整个大型系统中的零星一角而已。当然我并不是贬低这些端的价值,正是因为我们专注于不同,努力提高每一个端的用户体验,才能让这些大型系统有露脸的机会。我想说的是,在你对现在的技术取得一定的成就之后,不要停止学习,因为整个软件架构体系中还有很多很多美妙的东西值得我们去发现。

APM和EAP是在async/await之前的两种不同的异步编程模式。

APM如果不阻塞主线程,那么完成通知(回调)就会执行在另外一个线程中,从而给我们更新UI带来一定的问题。

EAP的通知事件是在主线程中执行的,不会存在UI交互的问题。

最后,我们还学习了在Winform下不同线程之间交互的问题,以及SynchronizationContext。

APM是.NET下最早的异步编程方法,从.NET 1.0以来就有了。在.NET 2.0的时候,微软意识到了APM的回调函数中与UI交互的问题,于是带来了新的EAP。APM与EAP一直共存到.NET 3.5,在.NET 4.0的时候微软带来了TPL,也就是我们所熟知的Task编程,而.NET 4.5就是我们大家知道的async/await了,可以看到.NET一直在不停的进步,加上最近不断的和开源社区的合作,跨平台等特性的引入,我们有理由相信.NET会越走越好。
  最后,这篇文章从找资料学习到写出来,差不多花了我两个周未的时间,希望能够给需要的人或者感兴趣想要不断学习的人一点帮助(不管是往前学习,还是往后学习)。

相关文章:

异步编程详解(.NET)

在之前写的一篇关于async和await的前世今生的文章之后&#xff0c;大家似乎在async和await提高网站处理能力方面还有一些疑问&#xff0c;很多网站本身也做了不少的尝试。今天我们再来回答一下这个问题&#xff0c;同时我会做一个async和await在WinForm中的尝试&#xff0c;并且…...

excel怎么固定前几行前几列不滚动?

在Excel中&#xff0c;如果你想固定前几行或前几列不滚动&#xff0c;可以通过以下几种方法来实现。详细的介绍如下&#xff1a; **固定前几行不滚动&#xff1a;** 1. 选择需要固定的行数。例如&#xff0c;如果你想要固定前3行&#xff0c;应该选中第4行的单元格。 2. 在E…...

elasticsearch完整学习

文章目录 elasticsearch一、概念二、ELK集群部署三、图形化界面 elasticsearch 一、概念 1、ELKStack简介&#xff08;都是java架构&#xff0c;需要jdk底层&#xff09; 什么是ELK&#xff1f;通俗来讲&#xff0c;ELK是由Elasticsearch、Logstash、Kibana 三个开源软件组成的…...

vscode Coder Runner 运行C++

1. 设置Code Runner 2. 防止输入读不到&#xff0c;把在终端运行勾上。 3. 设置minw/bin的环境变量 安装mingw教程&#xff1a;https://blog.csdn.net/fancy_male/article/details/133992000 4. 见图...

牛客网刷题-(2)

&#x1f308;write in front&#x1f308; &#x1f9f8;大家好&#xff0c;我是Aileen&#x1f9f8;.希望你看完之后&#xff0c;能对你有所帮助&#xff0c;不足请指正&#xff01;共同学习交流. &#x1f194;本文由Aileen_0v0&#x1f9f8; 原创 CSDN首发&#x1f412; 如…...

FreeRTOS基础(如何学好FreeRTOS?)

目录 基础知识 进阶内容 后期“摆烂” 基础知识 实时操作系统 (RTOS)&#xff1a;FreeRTOS是一个实时操作系统&#xff0c;它提供了任务管理、调度和同步等功能&#xff0c;在嵌入式系统中有效地管理多个任务。 任务&#xff08;Task&#xff09;&#xff1a;任务是在RTOS…...

读书笔记:Effective C++ 2.0 版,条款43(多继承)、条款44(概念明确)、条款45-50(杂项)

条款43: 明智地使用多继承 并没有禁止&#xff0c;从概念上讲&#xff0c;多继承可能更符合真实世界。 条款44: 说你想说的&#xff1b;理解你所说的 概念明确 条款45: 弄清C在幕后为你所写、所调用的函数 隐性成本&#xff0c;看下编译后的c、asm源码。 条款46: 宁可编译和…...

最新Jn建站系统2.0 已集成各类源码 【附视频安装教程】

附视频安装教程|已集成各类源码 目前已集成的网站&#xff1a; 1.发卡网(最新) 2.代刷网(无需授权) 3. 博客网(自带模板) 4.易支付(稳定版) 5.个人导航网(简洁) 6.代理查询网 7.留言网 8.匿名网 9.表白墙(最新) 10.抽奖网 11.源码站 12.z-blog博客程序 13.织梦CM…...

JAVA多线程基础篇--守护线程(Daemon Thread)

1.概述 JAVA中的线程主要分为两类&#xff1a;用户线程&#xff08;User Thread&#xff09;和守护线程(Daemon Thread)。JAVA语言中无论是线程还是线程池&#xff0c;默认都是用户线程&#xff0c;因此用户线程也被称为普通线程。守护线程也被称之为后台线程、服务线程或精灵…...

对知识蒸馏的一些理解

知识蒸馏是一种模型压缩技术&#xff0c;它通过从一个大模型&#xff08;教师模型&#xff09;中传输知识到一个小模型&#xff08;学生模型&#xff09;中来提高学生模型的性能&#xff0c;知识蒸馏也要用到真实的数据集标签。 软损失soft loss就是拿教师模型在蒸馏温度为T的…...

概率论_概率公式中的分号(;)、逗号(,)、竖线(|) 及其优先级

目录 1.概率公式中的分号(;)、逗号(,)、竖线(|) 2.各种概率相关的基本概念 2.1 联合概率 2.2 条件概率&#xff08;定义&#xff09; 2.3 全概率(乘法公式的加强版) 2.4 贝叶斯公式 贝叶斯定理的公式推导 1.概率公式中的分号(;)、逗号(,)、竖线(|) ; 分号代表前后是两类…...

【C++】二叉树进阶 -- 详解

一、二叉搜索树概念 二叉搜索树 又称二叉排序树&#xff0c;它或者是一棵空树&#xff0c;或者是具有以下性质的二叉树&#xff1a; 若它的左子树不为空&#xff0c;则左子树上所有节点的值都小于根节点的值 若它的右子树不为空&#xff0c;则右子树上所有节点的值都大于根节点…...

K8S集群中Node节点资源不足导致Pod无法运行的故障排查思路

K8S集群中Node节点资源不足导致Pod无法运行的故障排查思路 Node节点资源不足可能会产生的故障 故障一&#xff1a;Pod数量太多超出物理节点的限制每一台Node节点中默认限制最多运行110个Pod资源&#xff0c;当一个应用程序有成百上千的Pod资源时&#xff0c;如果不扩容Node节…...

Node.js与npm版本比对

Node.js与npm版本比对 Node.js与npm版本比对版本对比表Node版本对比 Node.js与npm版本比对 我们在项目开发过程中&#xff0c;经常会遇到公司一些老的前端工程项目&#xff0c;而我们当前的node及npm版本都是相对比较新的了。 在运行以前工程时&#xff0c;会遇到相关环境不匹…...

智加科技与东风柳汽达成深度合作 自动驾驶重卡计划2024年初量产交付

&#xff08;2023年10月19日&#xff0c;苏州&#xff09;全球领先的重卡自动驾驶技术公司智加科技与东风柳汽宣布&#xff0c;双方共同开发的自动驾驶重卡H7计划2024年初实现量产交付。未来&#xff0c;双方将携手推出安全可靠、高性价比、性能卓越的自动驾驶重卡产品&#xf…...

mac下配置环境-node以及nvm

当前配置环境主要针对于mac下系统&#xff0c;需要提前安装brew包 如需要配置&#xff0c;可查阅&#xff1a;Brew包的基本安装&#xff08;手把手教学&#xff09;-CSDN博客 如果是window环境配置&#xff0c;分享一个不错的帖子&#xff1a;nvm的安装和使用&#xff08;详细&…...

Elasticsearch基础篇(六):es创建映射和设置

es创建映射和设置 一、什么是 Elasticsearch 映射&#xff1f;二、映射中的字段类型常见字段类型 &#xff08;Common data types&#xff09;对象和关联类型&#xff08;Objects and relational types&#xff09;结构化数据类型&#xff08;Structured data types&#xff09…...

机器人系统 ROS 常用命令行工具

1. 启动ros 主节点 roscore roscore运行成功如图&#xff1a; 1.1 rosrun 启动服务节点 例子&#xff1a;启动一个小乌龟节点 rosrun turtlesim turtlesim_node运行结果如图&#xff1a; 1.2 启动键盘控制 打开新的命令窗口&#xff0c;启动turtle_teleop_key 节点 rosr…...

Jasypt加解密、信息脱敏

文章目录 一、介绍二、Spring集成1、 Maven依赖2、application.xml的配置3、配置文件使用4、方法加密 二、SpringBoot集成1、 Maven依赖2、 Java Bean配置jasyptStringEncryptor3、配置文件使用4、Bean使用加密字段自动解密 一、介绍 Jasypt is a java library which allows th…...

力扣每日一题61:旋转链表

题目描述&#xff1a; 给你一个链表的头节点 head &#xff0c;旋转链表&#xff0c;将链表每个节点向右移动 k 个位置。 示例 1&#xff1a; 输入&#xff1a;head [1,2,3,4,5], k 2 输出&#xff1a;[4,5,1,2,3]示例 2&#xff1a; 输入&#xff1a;head [0,1,2], k 4 输…...

Docker 离线安装指南

参考文章 1、确认操作系统类型及内核版本 Docker依赖于Linux内核的一些特性&#xff0c;不同版本的Docker对内核版本有不同要求。例如&#xff0c;Docker 17.06及之后的版本通常需要Linux内核3.10及以上版本&#xff0c;Docker17.09及更高版本对应Linux内核4.9.x及更高版本。…...

(十)学生端搭建

本次旨在将之前的已完成的部分功能进行拼装到学生端&#xff0c;同时完善学生端的构建。本次工作主要包括&#xff1a; 1.学生端整体界面布局 2.模拟考场与部分个人画像流程的串联 3.整体学生端逻辑 一、学生端 在主界面可以选择自己的用户角色 选择学生则进入学生登录界面…...

【磁盘】每天掌握一个Linux命令 - iostat

目录 【磁盘】每天掌握一个Linux命令 - iostat工具概述安装方式核心功能基础用法进阶操作实战案例面试题场景生产场景 注意事项 【磁盘】每天掌握一个Linux命令 - iostat 工具概述 iostat&#xff08;I/O Statistics&#xff09;是Linux系统下用于监视系统输入输出设备和CPU使…...

LINUX 69 FTP 客服管理系统 man 5 /etc/vsftpd/vsftpd.conf

FTP 客服管理系统 实现kefu123登录&#xff0c;不允许匿名访问&#xff0c;kefu只能访问/data/kefu目录&#xff0c;不能查看其他目录 创建账号密码 useradd kefu echo 123|passwd -stdin kefu [rootcode caozx26420]# echo 123|passwd --stdin kefu 更改用户 kefu 的密码…...

人工智能(大型语言模型 LLMs)对不同学科的影响以及由此产生的新学习方式

今天是关于AI如何在教学中增强学生的学习体验&#xff0c;我把重要信息标红了。人文学科的价值被低估了 ⬇️ 转型与必要性 人工智能正在深刻地改变教育&#xff0c;这并非炒作&#xff0c;而是已经发生的巨大变革。教育机构和教育者不能忽视它&#xff0c;试图简单地禁止学生使…...

使用LangGraph和LangSmith构建多智能体人工智能系统

现在&#xff0c;通过组合几个较小的子智能体来创建一个强大的人工智能智能体正成为一种趋势。但这也带来了一些挑战&#xff0c;比如减少幻觉、管理对话流程、在测试期间留意智能体的工作方式、允许人工介入以及评估其性能。你需要进行大量的反复试验。 在这篇博客〔原作者&a…...

C++课设:简易日历程序(支持传统节假日 + 二十四节气 + 个人纪念日管理)

名人说:路漫漫其修远兮,吾将上下而求索。—— 屈原《离骚》 创作者:Code_流苏(CSDN)(一个喜欢古诗词和编程的Coder😊) 专栏介绍:《编程项目实战》 目录 一、为什么要开发一个日历程序?1. 深入理解时间算法2. 练习面向对象设计3. 学习数据结构应用二、核心算法深度解析…...

手机平板能效生态设计指令EU 2023/1670标准解读

手机平板能效生态设计指令EU 2023/1670标准解读 以下是针对欧盟《手机和平板电脑生态设计法规》(EU) 2023/1670 的核心解读&#xff0c;综合法规核心要求、最新修正及企业合规要点&#xff1a; 一、法规背景与目标 生效与强制时间 发布于2023年8月31日&#xff08;OJ公报&…...

解析两阶段提交与三阶段提交的核心差异及MySQL实现方案

引言 在分布式系统的事务处理中&#xff0c;如何保障跨节点数据操作的一致性始终是核心挑战。经典的两阶段提交协议&#xff08;2PC&#xff09;通过准备阶段与提交阶段的协调机制&#xff0c;以同步决策模式确保事务原子性。其改进版本三阶段提交协议&#xff08;3PC&#xf…...

一些实用的chrome扩展0x01

简介 浏览器扩展程序有助于自动化任务、查找隐藏的漏洞、隐藏自身痕迹。以下列出了一些必备扩展程序&#xff0c;无论是测试应用程序、搜寻漏洞还是收集情报&#xff0c;它们都能提升工作流程。 FoxyProxy 代理管理工具&#xff0c;此扩展简化了使用代理&#xff08;如 Burp…...