如何在新线程上运行任务并立即返回调用方？

Question

在过去的几个月里，我一直在阅读C#中的异步等待以及如何正确使用它。

出于实验室练习的目的，我正在构建一个小型Tcp服务器，它应该为连接到它的客户端提供服务。该程序是一个控制台应用程序。

我使用while循环等待连接，如下所示：

while (!_isStopRequested)
{
       TcpClient client = await _tcpListener.AcceptTcpClientAsync();

       await Task.Factory.StartNew(() => ProcessClientAsync(client), TaskCreationOptions.LongRunning);
} 

所以，到目前为止，我所做的方法ProcessClientAsync被标记为异步无效，我只称之为ProcessClientAsync（客户端），调用将立即返回给调用方。然而，我在网上读到，除非是为了一个活动，否则使用它是一个糟糕的决定。所以我将定义更改为异步任务。

好的，但是没有等待，我在VisualStudio中得到一个警告“因为这个调用没有等待，所以当前方法在调用完成之前继续运行”。

一旦我使用await ProcessClientAsync（客户端），代码就不起作用了。我只能连接一个客户端，然后调用方“等待”ProcessClientSync返回。但是，该方法有一个无限循环并且不会返回，但是我需要while循环来继续处理下一个客户机。

通过谷歌搜索，我想到了这个问题：如何在C#中安全地调用异步方法而无需等待

我想问题是几乎相同的，除了当我使用wait ProcessClientAsync时，我希望它立即返回给调用者，它不这样做，我知道，因为运行第二个客户端，而第一个仍在运行，第二个客户端不连接。

所以我这样做了：

await Task.Factory.StartNew(() => ProcessClientAsync(client), TaskCreationOptions.LongRunning);

但是，由于ProcessClientAsync必须返回任务，我不确定这是否可以？

这将是一个问题。

另一个问题是：如何调用将永远运行的异步任务方法，并让调用立即返回给调用方，以便while循环可以继续，tcp侦听器可以继续接受下一个客户端？

谢谢你。

抱歉，如果是重复，或者不清楚我在问什么。

Answer 1

如果我正确理解您的问题，那么以下代码应该会有所帮助：

private async void AcceptClient(TcpClient client)
{
  await Task.Factory.StartNew(() => ProcessClientAsync(client), TaskCreationOptions.LongRunning);
}

private async void Run()
{
  while (!_isStopRequested)
  {
       TcpClient client = await _tcpListener.AcceptTcpClientAsync();
       AcceptClient(client);
  }
} 

Answer 2

这将启动任务并返回调用方，并避免编译器警告：

var t = Task.Factory.StartNew(() => {});

Answer 3

出于实验室练习的目的，我正在构建一个小型Tcp服务器，它应该为连接到它的客户端提供服务。该程序是一个控制台应用程序。

嗯，我建议的第一件事是尝试一个更简单的练习。说真的，异步TCP服务器是您可以选择的最复杂的应用程序之一。绝大多数使用async的开发人员都在开发简单两个数量级的应用程序。

相反，试着编写一个UI应用程序，从URL下载一个文件。这是学习async更现实的起点。

但是，由于ProcessClientAsync必须返回任务，我不确定这是否可以？

我建议使用任务。运行而不是任务。工厂开始新建<代码>任务。Run知道async方法，而StartNew不知道。

然而，这首先假设启动线程是正确的操作。大多数TCP/IP服务器应用程序都不受CPU的限制，因此我对多线程的使用提出了质疑。完全可以有一个完全异步的TCP/IP服务器，它只将线程池用于其async方法的延续。

另一个是：我如何调用一个将永远运行的异步任务方法，并立即将调用返回给调用方，以便同时循环可以继续，tcp监听器可以继续接受下一个客户端？

您不必等待任务返回：

Task.Run(() => ProcessClientAsync(client));

然而，编译器会在这里抱怨，因为这段代码几乎肯定是错误的。如果忽略返回的任务，则忽略该代码中的任何异常。

TCP/IP服务器应用程序中的一种常见模式是为每个连接的客户端维护一个小的状态集合。这是放置套接字对象本身和表示处理该套接字连接的任务的自然位置：

var clientState = new ClientState(client);
clientState.Task = Task.Run(() => ProcessClientAsync(client));

这些客户端状态随后存储在列表/字典中。你如何做到这一点当然取决于你自己。