相信大家看过不少讲C# async await的文章,博客园就能搜到很多,但还是有很多C#程序员不明白。
如果搞不明白,其实也不影响使用。但有人就会疑惑,为什么要用异步?我感觉它更慢了,跟同步有啥区别?
有的人研究深入,比如去研究状态机,可能会明白其中的原理。但深入研究的毕竟少数。有的人写一些示例,有的专业有的不是很专业,但看的人仍有不明白的。
所以我写了一个示例,尽量简单,让大家形象地理解一下C#的异步。
就是一个示例,没有什么理论讲解,大家自己测试自己思考。如果大家看理论讲解,就能明白,我也就没必要写这个示例了。
先直接测试,看结果,下面再放代码

其它博客也写过示例,是控制台示例,输出的主线程ID,是有可能会变化的。这里是Winform示例,输出的主线程ID始终是UI线程的ID,即是1;
我没有演示主线程ID发生变化的情况,这样会使示例变得复杂一点,不容易看明白。
服务端和客户端是两个独立的工程,测试时在一起跑,但其实可以分开部署,部署到不同的机器上
服务端是一个web api接口,用.NET 6、VS2022开发,代码如下:
[ApiController]
[Route("[controller]")]
public class TestController : ControllerBase
{
[HttpGet]
[Route("[action]")]
public async Task<string> ForPreheat()
{
return await Task.FromResult("预热返回结果");
}
[HttpGet]
[Route("[action]")]
public async Task<string> Get()
{
await Task.Delay(2000); //模拟耗时操作
return "测试返回结果";
}
}
大家看客户端代码时,不需要关心服务端怎么写
客户端是一个Winform工程,用.NET 6、VS2022开发,代码如下:
public partial class Form1 : Form
{
private string _urlPreheat = "http://localhost:5028/Test/ForPreheat";
private string _url = "http://localhost:5028/Test/Get";
private int _index1 = 1; //测试时请快速连续点击5次button1
private int _index2 = 1; //测试时请快速连续点击5次button2
private Stopwatch _sw1;
private Stopwatch _sw2;
public Form1()
{
InitializeComponent();
}
private async void Form1_Load(object sender, EventArgs e)
{
Request(_urlPreheat); //预热
await RequestAsync(_urlPreheat); //预热
Log("==== 预热请求结束 ====================================");
}
#region Log
private void Log(string msg)
{
msg = $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} {msg}\r\n";
if (this.InvokeRequired)
{
this.BeginInvoke(new Action(() =>
{
txtLog.AppendText(msg);
}));
}
else
{
txtLog.AppendText(msg);
}
}
#endregion
private async void button1_Click(object sender, EventArgs e)
{
await Task.Delay(1000); //为了能1秒内快速点击几次,为了能写这句代码button1_Click前面加了async,但后面的代码仍是同步调用;如果不加这句,第一次点击界面就卡死了,无法连续点击5次。
Log("==== 同步请求开始 ====================================");
if (_index1 == 1) _sw1 = Stopwatch.StartNew();
Request(_url);
if (_index1 == 5)
{
_sw1.Stop();
Log($"5次请求耗时:{_sw1.Elapsed.TotalSeconds:0.000}秒");
}
_index1++;
}
private async void button2_Click(object sender, EventArgs e)
{
await Task.Delay(1000); //为了和button1保持一致
Log("==== 异步请求开始 ====================================");
if (_index2 == 1) _sw2 = Stopwatch.StartNew();
await RequestAsync(_url);
if (_index2 == 5)
{
_sw2.Stop();
Log($"5次请求耗时:{_sw2.Elapsed.TotalSeconds:0.000}秒");
}
_index2++;
}
private async Task RequestAsync(string url)
{
Stopwatch sw = Stopwatch.StartNew();
HttpClient httpClient = HttpClientFactory.GetClient();
var result = await (await httpClient.GetAsync(url)).Content.ReadAsStringAsync();
sw.Stop();
Log($"线程ID={Thread.CurrentThread.ManagedThreadId},请求耗时:{sw.Elapsed.TotalSeconds:0.000}秒,返回内容长度:{result.Length}");
}
private void Request(string url)
{
Stopwatch sw = Stopwatch.StartNew();
var result = HttpUtil.HttpGet(url);
sw.Stop();
Log($"线程ID={Thread.CurrentThread.ManagedThreadId},请求耗时:{sw.Elapsed.TotalSeconds:0.000}秒,返回内容长度:{result.Length}");
}
}
把button2_Click方法中的await RequestAsync(_url);修改为两行:
await RequestAsync(_url);
await RequestAsync(_url);
那么5次点击,每次点击请求2次,共5×2=10次请求,请问这10次请求的总耗时大约是几秒?
答案是4秒,为什么?
因为每次点击的2次请求是顺序的,耗时是2+2=4秒,而5次点击是并发的,没有增加耗时时长
https://gitee.com/s0611163/AsyncAwaitDemo2
最后,我画了两个流程图,但这两个流程图可能画的很不专业,所以仅供参考
button1点击5次的流程图:

button2点击5次的流程图:

我之前说过,异步的本质是回调,这句话是否正确我也不知道,主要是为了大家理解异步。
前面测试时说了,异步不卡界面,确定不卡界面?其实没这么简单。就前面那个代码,实际应用中就卡界面了!这是怎么回事?听我仔细道来。
点击按钮,少量异步调用,确实不卡界面,但是我要生产模拟数据10000条,我写了个循环for(int i=0; i<10000; i++),伪代码如下:
private async void btnWriteToEs_Click(object sender, EventArgs e)
{
for (int i = 0; i < 10000; i++)
{
await ......
}
}
这样写程序是没问题,但是生产数据时,界面卡死,只是体验不好,怎么才能不卡界面呢?这样写就不卡界面了:
private async void btnWriteToEs_Click(object sender, EventArgs e)
{
await Task.Run(async () =>
{
for (int i = 0; i < 10000; i++)
{
await ......
Log("xxx"); //向界面输出日志
}
});
}
除了在UI线程for循环10000次,还有一个导致界面卡的原因,就是每次await调用异步方法后,都要输出一条日志到界面上,频繁操作界面控件TextBox,肯定卡。
为了向界面输出大量日志,而又不卡界面,我是这样写的:
private System.Timers.Timer _timerForLog;
private ConcurrentQueue<string> _logMsgs = new ConcurrentQueue<string>();
private void Form1_Load(object sender, EventArgs e)
{
_timerForLog = new System.Timers.Timer();
_timerForLog.Elapsed += _timerForLog_Elapsed;
_timerForLog.Interval = 200;
_timerForLog.Start();
}
private void _timerForLog_Elapsed(object a, ElapsedEventArgs e)
{
Task.Run(() =>
{
StringBuilder sb = new StringBuilder();
while (_logMsgs.TryDequeue(out string msg))
{
sb.Append(msg);
}
if (!this.Disposing && sb.Length > 0)
{
if (this.InvokeRequired)
{
this.BeginInvoke(new Action(() =>
{
txtLog.AppendText(sb.ToString());
}));
}
else
{
txtLog.AppendText(sb.ToString());
}
}
});
}
public void Info(string msg)
{
Log(msg);
}
private void Log(string msg)
{
_logMsgs.Enqueue($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} {msg}\r\n");
}
点击按钮,生产数据时,日志疯狂地向界面输出的时候,Winform窗体还可以拖动,其它按钮可响应点击事件。
尝试通过RVM将RubyGems升级到版本1.8.10并出现此错误:$rvmrubygemslatestRemovingoldRubygemsfiles...Installingrubygems-1.8.10forruby-1.9.2-p180...ERROR:Errorrunning'GEM_PATH="/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/ruby-1.9.2-p180@global:/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/rub
使用带有Rails插件的vim,您可以创建一个迁移文件,然后一次性打开该文件吗?textmate也可以这样吗? 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件,这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails,您可以创建一个新的迁移文件并一次性打开它吗?,我们在StackOverflow上找到一个类似的问题: https://sta
我需要从一个View访问多个模型。以前,我的links_controller仅用于提供以不同方式排序的链接资源。现在我想包括一个部分(我假设)显示按分数排序的顶级用户(@users=User.all.sort_by(&:score))我知道我可以将此代码插入每个链接操作并从View访问它,但这似乎不是“ruby方式”,我将需要在不久的将来访问更多模型。这可能会变得很脏,是否有针对这种情况的任何技术?注意事项:我认为我的应用程序正朝着单一格式和动态页面内容的方向发展,本质上是一个典型的网络应用程序。我知道before_filter但考虑到我希望应用程序进入的方向,这似乎很麻烦。最终从任何
我想要做的是有2个不同的Controller,client和test_client。客户端Controller已经构建,我想创建一个test_clientController,我可以使用它来玩弄客户端的UI并根据需要进行调整。我主要是想绕过我在客户端中内置的验证及其对加载数据的管理Controller的依赖。所以我希望test_clientController加载示例数据集,然后呈现客户端Controller的索引View,以便我可以调整客户端UI。就是这样。我在test_clients索引方法中试过这个:classTestClientdefindexrender:template=>
exe应该在我打开页面时运行。异步进程需要运行。有什么方法可以在ruby中使用两个参数异步运行exe吗?我已经尝试过ruby命令-system()、exec()但它正在等待过程完成。我需要用参数启动exe,无需等待进程完成是否有任何rubygems会支持我的问题? 最佳答案 您可以使用Process.spawn和Process.wait2:pid=Process.spawn'your.exe','--option'#Later...pid,status=Process.wait2pid您的程序将作为解释器的子进程执行。除
我正在使用puppet为ruby程序提供一组常量。我需要提供一组主机名,我的程序将对其进行迭代。在我之前使用的bash脚本中,我只是将它作为一个puppet变量hosts=>"host1,host2"我将其提供给bash脚本作为HOSTS=显然这对ruby不太适用——我需要它的格式hosts=["host1","host2"]自从phosts和putsmy_array.inspect提供输出["host1","host2"]我希望使用其中之一。不幸的是,我终其一生都无法弄清楚如何让它发挥作用。我尝试了以下各项:我发现某处他们指出我需要在函数调用前放置“function_”……这
我正在编写一个gem,我必须在其中fork两个启动两个webrick服务器的进程。我想通过基类的类方法启动这个服务器,因为应该只有这两个服务器在运行,而不是多个。在运行时,我想调用这两个服务器上的一些方法来更改变量。我的问题是,我无法通过基类的类方法访问fork的实例变量。此外,我不能在我的基类中使用线程,因为在幕后我正在使用另一个不是线程安全的库。所以我必须将每个服务器派生到它自己的进程。我用类变量试过了,比如@@server。但是当我试图通过基类访问这个变量时,它是nil。我读到在Ruby中不可能在分支之间共享类变量,对吗?那么,还有其他解决办法吗?我考虑过使用单例,但我不确定这是
我的最终目标是安装当前版本的RubyonRails。我在OSXMountainLion上运行。到目前为止,这是我的过程:已安装的RVM$\curl-Lhttps://get.rvm.io|bash-sstable检查已知(我假设已批准)安装$rvmlistknown我看到当前的稳定版本可用[ruby-]2.0.0[-p247]输入命令安装$rvminstall2.0.0-p247注意:我也试过这些安装命令$rvminstallruby-2.0.0-p247$rvminstallruby=2.0.0-p247我很快就无处可去了。结果:$rvminstall2.0.0-p247Search
如果您尝试在Ruby中的nil对象上调用方法,则会出现NoMethodError异常并显示消息:"undefinedmethod‘...’fornil:NilClass"然而,有一个tryRails中的方法,如果它被发送到一个nil对象,它只返回nil:require'rubygems'require'active_support/all'nil.try(:nonexisting_method)#noNoMethodErrorexceptionanymore那么try如何在内部工作以防止该异常? 最佳答案 像Ruby中的所有其他对象
关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗?通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion为什么SecureRandom.uuid创建一个唯一的字符串?SecureRandom.uuid#=>"35cb4e30-54e1-49f9-b5ce-4134799eb2c0"SecureRandom.uuid方法创建的字符串从不重复?