我可以将 Task.Run 包装在另一个 Task.Run() 下吗？

Question

我有一个位于 Task.Run() 下的方法 HandleAcceptedConnection，我想异步运行（在另一个单独的线程中）。我尝试将 HandleAcceptedConnection 声明为异步方法并且不调用 await 但它似乎没有异步运行。我可以确认我可以在另一个 Task.Run() 下拥有 Task.Run()（通过查看线程 id），但这是推荐的吗？

private async void Start_Click(object sender, RoutedEventArgs e)
{
        var task = Task.Run(() =>
        {
            while (isContinue)
            {
                var handler = listener.Accept();
                // handle connection

                Log("Before");
                Log("ThreadId Accept " + Thread.CurrentThread.ManagedThreadId);

                // i want to run method below asynchronously. i want to 
                // wrap it under Task.Run() but i am already under 
                // Task.Run(). i set HandleAcceptedConnection as async. i thought by not 
                // calling await on HandleAcceptedConnection, HandleAcceptedConnection 
                // is asynchronous
                HandleAcceptedConnection(handler); 

                Log("After");

                isContinue = true;
            }
        });
        await task;
}

private async Task HandleAcceptedConnection(Socket handler)
{
    Log("ThreadId HandleAcceptedConnection " + Thread.CurrentThread.ManagedThreadId);
    Log("Under HandleAcceptedConnection");
    Thread.Sleep(10000);   
}

当我运行它时，日志说

Before
Under HandleAcceptedConnection
After

我想要

Before
After
Under HandleAcceptedConnection

我希望 HandleAcceptedConnection 异步运行。我应该将它包装在另一个 Task.Run 下还是它已经是异步的？

Answer 1

你试过了吗

private async Task HandleAcceptedConnection(Socket handler)
{
    Thread.Sleep(1000);
    Log("Under HandleAcceptedConnection");
}

因为在另一个线程上做某事并不意味着它会被延迟。

Answer 2

你应该使用AcceptTcpClientAsync，那么你就不需要额外的线程了。以this answer 为例。如果有可用的自然异步版本，请不要使用同步 API。

已更新以解决评论问题。没有什么能阻止您从 Task.Run 内部使用 Task.Run，您的代码可能如下所示（未经测试）：

private async void Start_Click(object sender, RoutedEventArgs e)
{
    var connectionTasks = new List<Task>();

    Func<Task> handleConnection = async () =>
    {
        var connectionTask = Task.Run(() => HandleAcceptedConnection(handler));
        connectionTasks.Add(connectionTask);
        await connectionTask;
        connectionTasks.Remove(connectionTask);
    };

    var task = Task.Run(() =>
    {
        while (isContinue)
        {
            var handler = listener.Accept();
            // handle connection

            Log("Before");
            Log("ThreadId Accept " + Thread.CurrentThread.ManagedThreadId);

            var connectionTask = handleConnection();

            Log("After");

            isContinue = true;
        }
    });
    await task;
}