如何解决并行异步执行是一个线程使用多个线程休眠的地方吗？
这是我为了更好地理解异步方法而编写的代码。我知道异步方法与多线程方法不同，但是在这种特定情况下似乎不是这样：
func loginFunction(username: String,password: String,onEnded: @escaping () -> () = {}) {
var result = false
// ... other code
result = getResponse.status
// ... other code
// make sure you have this call once and definitely performed at the end,// because your current implementation has many returns
// which prevent reporting any result
DispatchQueue.main.async {
self.loggedIn = result
self.onEnded() // << callback
}
如您所见，func AttempLogin(){
self.networkManager.loginFunction(username: self.usernameInput,password: self.passwordInput) {
// will be received at the login processed
if self.networkManager.loggedIn {
print("You're now logged on")
}
else{
print("You aren't logged in")
}
}
}
方法等待1.5秒，然后返回“ a”。名为class Program
{
static void Main(string[] args)
{
Thread.CurrentThread.CurrentCulture = new System.Globalization.CultureInfo("en-US");
//the line above just makes sure that the console output uses . to represent doubles instead of,ExecuteAsync();
Console.ReadLine();
}
private static async Task ParallelAsyncMethod() //this is the method where async parallel execution is taking place
{
List<Task<string>> tasks = new List<Task<string>>();
for (int i = 0; i < 5; i++)
{
tasks.Add(Task.Run(() => DownloadWebsite()));
}
var strings = await Task.WhenAll(tasks);
foreach (var str in strings)
{
Console.WriteLine(str);
}
}
private static string DownloadWebsite() //Imitating a website download
{
Thread.Sleep(1500); //making the thread sleep for 1500 miliseconds before returning
return "Download finished";
}
private static async void ExecuteAsync()
{
var watch = Stopwatch.StartNew();
await ParallelAsyncMethod();
watch.Stop();
Console.WriteLine($"It took the machine {watch.ElapsedMilliseconds} milliseconds" +
$" or {Convert.ToDouble(watch.ElapsedMilliseconds) / 1000} seconds to complete this task");
Console.ReadLine();
}
}
//OUTPUT:
/*
Download finished
Download finished
Download finished
Download finished
Download finished
It took the machine 1537 milliseconds or 1.537 seconds to complete this task
*/
的方法将其中五个方法添加到“任务”列表中，然后开始并行异步执行。如您所见，我还跟踪了执行DownloadWebsite方法所花费的时间。结果总是在1540毫秒左右。这是我的问题：如果ParallelAsyncMethod方法需要一个线程在1500毫秒内休眠5次，这是否意味着这些方法的并行执行需要5个不同的线程？如果没有，那么为什么只花1540毫秒来执行程序却没有花7500毫秒呢？
解决方法
我知道异步方法不同于多线程
是的，异步方法在I / O发生时释放当前线程，并在完成后安排继续。
异步和线程是完全不相关的概念。
但在这种特定情况下似乎并非如此
这是因为您使用DownloadWebsite在ThreadPool上显式运行了Task.Run，它在指示提供的委托运行后通过返回Task来模仿异步代码。
由于您不必等待每个Task完成之后再开始下一个，所以可以同时使用多个线程。
当前，每个线程都被阻塞，就像您在Thread.Sleep的实现中使用DownloadWebsite一样，这意味着您实际上在ThreadPool上运行5个同步方法。
在生产代码中，您的DownloadWebsite方法应该异步编写，也许使用HttpClient.GetAsync：
private static async Task<string> DownloadWebsiteAsync()
{
//...
await httpClinet.GetAsync(//...
//...
}
在这种情况下，GetAsync返回一个Task，并在等待HTTP响应的同时释放当前线程。
您仍然可以同时运行多个异步方法，但是由于每次释放线程时，它很可能使用少于5个单独的线程，甚至可能使用单个线程。
确保不要将Task.Run与异步方法一起使用；这只会增加不必要的开销：
var tasks = new List<Task<string>>();
for (int i = 0; i < 5; i++)
{
tasks.Add(DownloadWebsiteAsync()); // No need for Task.Run
}
var strings = await Task.WhenAll(tasks);
顺便说一句，如果您想模仿异步操作，请使用Task.Delay而不是Thread.Sleep，因为前者是非阻塞的：
private static async Task<string> DownloadWebsite() //Imitating a website download
{
await Task.Delay(1500); // Release the thread for ~1500ms before continuing
return "Download finished";
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。