- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
研究过异步web开发的概念,具体来自this源,我创建了一个示例应用程序来证明这个概念。
该解决方案由 2 个 ASP.NET Web API 应用程序组成。第一个是模拟的慢端点;它等待 1000 毫秒,然后返回一个名为 Student 的自定义类列表:
public IEnumerable<Student> Get()
{
Thread.Sleep(1000);
return new List<Student> { new Student { Name = @"Paul" }, new Student { Name = @"Steve" }, new Student { Name = @"Dave" }, new Student { Name = @"Sue" } };
}
这是学生类:
public class Student
{
public string Name { get; set; }
}
此端点托管在 localhost:4002 上的 IIS 7 中。
第二个应用程序使用 2 个端点联系第一个应用程序,一个是同步的,另一个是异步的:
public IEnumerable<Student> Get() {
var proxy = WebRequest.Create(@"http://localhost:4002/api/values");
var response = proxy.GetResponse();
var reader = new StreamReader(response.GetResponseStream());
return JsonConvert.DeserializeObject<IEnumerable<Student>>(reader.ReadToEnd());
}
public async Task<IEnumerable<Student>> Get(int id) {
var proxy = new HttpClient();
var getStudents = proxy.GetStreamAsync(@"http://localhost:4002/api/values");
var stream = await getStudents;
var reader = new StreamReader(stream);
return JsonConvert.DeserializeObject<IEnumerable<Student>>(reader.ReadToEnd());
}
它托管在 localhost:4001 上的 IIS 7 中。
两个端点均按预期工作,并在大约1秒。根据上面链接中 13:25 的视频,异步方法应该释放它的线程,从而最大限度地减少争用。
我正在使用 Apache Bench 对应用程序运行性能测试。以下是具有 10 个并发请求的同步方法的响应时间:
这正是我所期望的;更多的并发连接会增加争用并延长响应时间。但是,这里是异步响应时间:
如您所见,似乎仍有一些争议。我原以为平均响应时间会更加平衡。如果我使用 50 个并发请求在两个端点上运行测试,我仍然会得到类似的结果。
基于此,似乎异步和同步方法都以或多或少相同的速度(预期)运行,没有考虑异步方法中的开销,而且异步方法似乎并没有将线程释放回线程池。欢迎提出任何意见或说明,谢谢。
最佳答案
我认为您很有可能没有测试您认为正在测试的内容。据我所知,您正在尝试通过比较时间和推断线程注入(inject)来检测返回线程池的释放。
一方面,.NET 4.5 上线程池的默认设置非常高。您不会同时发出 10 或 100 个请求来攻击他们。
退后一步,想一想您要测试的内容:异步方法是否将其线程返回到线程池?
我有一个演示来演示这一点。我不想为我的演示(在我的演示笔记本电脑上运行)创建重负载测试,所以我采用了一个小技巧:我人为地将线程池限制为更合理的值。
一旦你这样做了,你的测试就非常简单了:同时执行那么多连接,然后执行那么多加一个。同步实现必须等待一个完成才能启动最后一个,而异步实现将能够启动它们。
在服务器端,首先将线程池线程限制为系统中的处理器数量:
protected void Application_Start()
{
int workerThreads, ioThreads;
ThreadPool.GetMaxThreads(out workerThreads, out ioThreads);
ThreadPool.SetMaxThreads(Environment.ProcessorCount, ioThreads);
...
}
然后做同步和异步的实现:
public class ValuesController : ApiController
{
// Synchronous
public IEnumerable<string> Get()
{
Thread.Sleep(1000);
return new string[] { "value1", "value2" };
}
// Asynchronous
public async Task<IEnumerable<string>> Get(int id)
{
await Task.Delay(1000);
return new string[] { "value1", "value2" };
}
}
最后是客户端测试代码:
static void Main(string[] args)
{
try
{
MainAsync().Wait();
}
catch (Exception ex)
{
Console.WriteLine(ex);
}
Console.ReadKey();
}
static async Task MainAsync()
{
ServicePointManager.DefaultConnectionLimit = int.MaxValue;
var sw = new Stopwatch();
var client = new HttpClient();
var connections = Environment.ProcessorCount;
var url = "http://localhost:35697/api/values/";
await client.GetStringAsync(url); // warmup
sw.Start();
await Task.WhenAll(Enumerable.Range(0, connections).Select(i => client.GetStringAsync(url)));
sw.Stop();
Console.WriteLine("Synchronous time for " + connections + " connections: " + sw.Elapsed);
connections = Environment.ProcessorCount + 1;
await client.GetStringAsync(url); // warmup
sw.Restart();
await Task.WhenAll(Enumerable.Range(0, connections).Select(i => client.GetStringAsync(url)));
sw.Stop();
Console.WriteLine("Synchronous time for " + connections + " connections: " + sw.Elapsed);
url += "13";
connections = Environment.ProcessorCount;
await client.GetStringAsync(url); // warmup
sw.Restart();
await Task.WhenAll(Enumerable.Range(0, connections).Select(i => client.GetStringAsync(url)));
sw.Stop();
Console.WriteLine("Asynchronous time for " + connections + " connections: " + sw.Elapsed);
connections = Environment.ProcessorCount + 1;
await client.GetStringAsync(url); // warmup
sw.Restart();
await Task.WhenAll(Enumerable.Range(0, connections).Select(i => client.GetStringAsync(url)));
sw.Stop();
Console.WriteLine("Asynchronous time for " + connections + " connections: " + sw.Elapsed);
}
在我的(8 逻辑核心)机器上,我看到这样的输出:
Synchronous time for 8 connections: 00:00:01.0194025
Synchronous time for 9 connections: 00:00:02.0362007
Asynchronous time for 8 connections: 00:00:01.0413737
Asynchronous time for 9 connections: 00:00:01.0238674
这清楚地表明异步方法正在将其线程返回到线程池。
关于c# - 使用 Async & Await 的 ASP.NET C#5 异步 Web 应用程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17145028/
我有带皮肤的 DNN。我的 head 标签有 runat="server"所以我尝试在 head 标签内添加一个标签 "> 在后面的代码中,我在属性中设置了 var GoogleAPIkey。问题是它
我在 Node.JS 中有一个导出模块 exports.doSomethingImportant= function(req, res) { var id = req.params.id; Demo.
我是 F# 的新手,我一直在阅读 F# for Fun and Profit。在为什么使用 F#? 系列中,有一个 post描述异步代码。我遇到了 Async.StartChild函数,我不明白为什么
File 中有一堆相当方便的方法类,如 ReadAll***/WriteAll***/AppendAll***。 我遇到过很多情况,当我需要它们的异步对应物时,但它们根本不存在。 为什么?有什么陷阱吗
我最近开始做一个 Node 项目,并且一直在使用 async 库。我有点困惑哪个选项会更快。在某些数据上使用 async.map 并获取其结果,或使用 async.each 迭代一组用户并将他们的相应
您好,我正在试用 Springs 异步执行器,发现您可以使用 @Async。我想知道是否有可能在 @Async 中使用 @Async,要求是需要将任务委托(delegate)给 @Async 方法在第
我需要支持取消一个函数,该函数返回一个可以在启动后取消的对象。在我的例子中,requester 类位于我无法修改的第 3 方库中。 actor MyActor { ... func d
假设 asyncSendMsg不返回任何内容,我想在另一个异步块中启动它,但不等待它完成,这之间有什么区别: async { //(...async stuff...) for msg
我想用 Mocha 测试异步代码. 我跟着这个教程testing-promises-with-mocha .最后,它说最好的方法是 async/await。 以下是我的代码,我打算将 setTimeo
正如我有限(甚至错误)的理解,Async.StartImmediate 和 Async.RunSynchronously 在当前线程上启动异步计算。那么这两个功能究竟有什么区别呢?谁能帮忙解释一下?
我有一行使用await fetch() 的代码。我正在使用一些调用 eval("await fetch ...etc...") 的脚本注入(inject),但问题是 await 在执行时不会执行从ev
我正在尝试使用 nodeJS 构建一个网络抓取工具,它在网站的 HTML 中搜索图像,缓存图像源 URL,然后搜索最大尺寸的图像。 我遇到的问题是 deliverLargestImage() 在循环遍
我想结合使用 async.each 和 async.series,但得到了意想不到的结果。 async.each([1, 2], function(item, nloop) { async.s
我的代码有问题吗?我使用 async.eachSeries 但我的结果总是抛出 undefined。 这里是我的代码: async.eachSeries([1,2,3], function(data,
我想在 trait 中编写异步函数,但是因为 async fn in traits 还不被支持,我试图找到等效的方法接口(interface)。这是我在 Rust nightly (2019-01-0
async setMyPhotos() { const newPhotos = await Promise.all(newPhotoPromises); someOtherPromise();
async.js 中 async.each 与 async.every 的区别?似乎两者都相同,只是 async.every 返回结果。纠正我,我错了。 最佳答案 每个异步 .each(coll, i
我正在尝试对一组项目运行 async.each。 对于每个项目,我想运行一个 async.waterfall。请参阅下面的代码。 var ids = [1, 2]; async.each(ids,
我的目标是测试 API 调用,将延迟考虑在内。我的灵感来自 this post . 我设计了一个沙箱,其中模拟 API 需要 1000 毫秒来响应和更改全局变量 result 的值。测试检查 500
async.each 是否作为异步数组迭代工作? async.eachSeries 是否作为同步数组迭代工作?(它实际上等待响应) 我问这些是因为两者都有回调,但 async.each 的工作方式类似
我是一名优秀的程序员,十分优秀!