问题 如何将其转换为异步任务？

所以，考虑到你不能调用任何现有的约束   异步方法，必须完成Thread.Sleep和   在异步任务中Console.WriteLine，你是如何在一个   与原始代码一样有效的方式？

IMO，这是一个 非常 你真正需要坚持的综合约束 Thread.Sleep。在这种约束下，你仍然可以略微改善你的 Thread.Sleep基于代码。而不是这个：

static async Task DoSomethingAsync2(int id) {
    await Task.Run(() => {
        Thread.Sleep(50);
        Console.WriteLine(@"DidSomethingAsync({0})", id);
    });
}

你可以这样做：

static Task DoSomethingAsync2(int id) {
    return Task.Run(() => {
        Thread.Sleep(50);
        Console.WriteLine(@"DidSomethingAsync({0})", id);
    });
}

这样，您就可以避免编译器生成的状态机类的开销。这两个代码片段之间存在细微差别 如何传播异常。

无论如何，这是 不 减速的瓶颈在哪里。

（使用以下控制台应用程序也会更慢 - 如果你   在DoSomethingAsync和DoSomethingAsync2调用之间交换，你可以看到一个   完成所需时间的显着差异）

让我们再看一下你的主循环代码：

static async Task MainAsync(String[] args) {

    List<Task> tasks = new List<Task>();
    for (int i = 1; i <= 1000; i++)
        tasks.Add(DoSomethingAsync2(i)); // Can replace with any version
    await Task.WhenAll(tasks);

}

从技术上讲，它要求并行运行1000个任务，每个任务都应该在自己的线程上运行。在理想的宇宙中，你期望执行 Thread.Sleep(50) 平行1000次，在大约50ms完成整个事情。

然而， 这个要求永远不会满足 由TPL的默认任务调度程序，有一个很好的理由：线程是一种宝贵且昂贵的资源。而且，并发操作的实际数量限于CPU /核心数。所以实际上，默认大小为 ThreadPool， 我越来越 21个泳池线程（峰值时） 并行提供此操作。这就是为什么 DoSomethingAsync2 / Thread.Sleep 花了这么长时间 DoSomethingAsync / Task.Delay。 DoSomethingAsync 不阻塞池线程，它只在超时完成时请求一个。因此，更多 DoSomethingAsync 任务实际上可以并行运行 DoSomethingAsync2 那些。

考试 （控制台应用程序）：

// https://stackoverflow.com/q/21800450/1768303

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Threading;
using System.Threading.Tasks;

namespace Console_21800450
{
    public class Program
    {
        static async Task DoSomethingAsync(int id)
        {
            await Task.Delay(50);
            UpdateMaxThreads();
            Console.WriteLine(@"DidSomethingAsync({0})", id);
        }

        static async Task DoSomethingAsync2(int id)
        {
            await Task.Run(() =>
            {
                Thread.Sleep(50);
                UpdateMaxThreads();
                Console.WriteLine(@"DidSomethingAsync2({0})", id);
            });
        }

        static async Task MainAsync(Func<int, Task> tester)
        {
            List<Task> tasks = new List<Task>();
            for (int i = 1; i <= 1000; i++)
                tasks.Add(tester(i)); // Can replace with any version
            await Task.WhenAll(tasks);
        }

        volatile static int s_maxThreads = 0;

        static void UpdateMaxThreads()
        {
            var threads = Process.GetCurrentProcess().Threads.Count;
            // not using locks for simplicity
            if (s_maxThreads < threads)
                s_maxThreads = threads;
        }

        static void TestAsync(Func<int, Task> tester)
        {
            s_maxThreads = 0;
            var stopwatch = new Stopwatch();
            stopwatch.Start();

            MainAsync(tester).Wait();

            Console.WriteLine(
                "time, ms: " + stopwatch.ElapsedMilliseconds +
                ", threads at peak: " + s_maxThreads);
        }

        static void Main()
        {
            Console.WriteLine("Press enter to test with Task.Delay ...");
            Console.ReadLine();
            TestAsync(DoSomethingAsync);
            Console.ReadLine();

            Console.WriteLine("Press enter to test with Thread.Sleep ...");
            Console.ReadLine();
            TestAsync(DoSomethingAsync2);
            Console.ReadLine();
        }

    }
}

输出：

按Enter键以使用Task.Delay进行测试...
...
时间，ms：1077，峰值线程：13

按Enter键以使用Thread.Sleep进行测试...
...
时间，ms：8684，高峰期线程：21

是否有可能改善时间数据 Thread.Sleep基 DoSomethingAsync2？我能想到的唯一方法就是使用 TaskCreationOptions.LongRunning 同 Task.Factory.StartNew：

在任何实际应用程序中执行此操作之前，您应该三思而后行：

static async Task DoSomethingAsync2(int id)
{
    await Task.Factory.StartNew(() =>
    {
        Thread.Sleep(50);
        UpdateMaxThreads();
        Console.WriteLine(@"DidSomethingAsync2({0})", id);
    }, TaskCreationOptions.LongRunning | TaskCreationOptions.PreferFairness);
}

// ...

static void Main()
{
    Console.WriteLine("Press enter to test with Task.Delay ...");
    Console.ReadLine();
    TestAsync(DoSomethingAsync);
    Console.ReadLine();

    Console.WriteLine("Press enter to test with Thread.Sleep ...");
    Console.ReadLine();
    TestAsync(DoSomethingAsync2);
    Console.ReadLine();
}

输出：

按Enter键以使用Thread.Sleep进行测试...
...
时间，ms：3600，峰值线程：163

时间越来越好，但价格却很高。此代码要求任务计划程序为每个新任务创建一个新线程。做 不 期望这个帖子来自池：

Task.Factory.StartNew(() =>
{
    Thread.Sleep(1000);
    Console.WriteLine("Thread pool: " + 
        Thread.CurrentThread.IsThreadPoolThread); // false!
}, TaskCreationOptions.LongRunning).Wait();