using System;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
class TaskSample
{
public static void Do()
{
Run();
}
private static readonly SemaphoreSlim _mutex = new SemaphoreSlim(5);
private static void Run()
{
var allTasks = Enumerable.Range(1, 10000000).Select(id => DoWorkAsync(id));
//await Task.WhenAll(tasks);
Task.WaitAll(allTasks.ToArray());
}
private static async Task DoWorkAsync(int id)
{
await _mutex.WaitAsync();
try
{
Console.WriteLine($"Starting Work {id}");
await HttpClientGetAsync();
Console.WriteLine($"Finished Work {id}");
}
finally
{
_mutex.Release();
}
}
static async Task HttpClientGetAsync()
{
await Task.Delay(2000);
}
}
运行截图:
谢谢浏览!
Copyright © 广州京杭网络科技有限公司 2005-2025 版权所有 粤ICP备16019765号
广州京杭网络科技有限公司 版权所有