如何等待不希望返回的异步方法

Question

我正在制作一个 TCP 服务器。我正在使用 async/await 来处理多线程。我用来监听传入客户端和后续消息的方法看起来有点像这样：

private static async Task Listener()
        {
            while (Online)
            {
                TcpClient socket = await tcpListener.AcceptTcpClientAsync();
                OnReceivedTcpClient(socket);
            }           
        }

如您所知，此方法预计不会很快返回。我的问题是关于我应该如何调用这个监听器方法。目前我这样做的方式是这样的：

（控制台应用程序） 在 Main 的 Program.cs 中，我调用 Server.Start()

static void Main(string[] args)
        {
            Console.Title = "Server (Prototype)";

            Server.Start(100, 26950);

            ConsoleKeyInfo input;
            do
            {
                input = Console.ReadKey();

                // check input and do stuff
                }
        }
            while (input.Key != ConsoleKey.C);  
            
        }

Server.Start 初始化一些值，然后调用一个事件，该事件又调用监听器

private static event EventHandler<EventArgs> StartEvent;
private static void OnStartEvent() => StartEvent?.Invoke(null, new EventArgs());

public static void Start(int maxClients, int port)
        {
            Stop();
            Console.WriteLine("Starting server...");
            Init(maxClients, port);
            OnStartEvent();
        }

private async void ServerOnStartEvent(object sender, EventArgs e)
        {           
            Online = true;          
            Console.WriteLine($"Server started on port {Port}");
            await Listener();
        }

如果我调用了 await Listener();在 Server.Start 内部，那么该方法将需要 async 关键字，并且它必须返回 void （我知道这不是一个理想的设计）或返回一个 Task ，这意味着我必须调用 _ = Server.Start( ) 在 program.cs 中（这也不是很好的设计）。

所以我的问题是，我的解决方案是等待异步任务方法的好方法吗？有更好的方法吗？

Answer 1

我通常处理这个问题的方法是添加一个Stop-方法。因此 Start 启动任务并将其保存在字段中。 stop 方法请求任务停止（通过任何方式），并返回存储的任务。

所以调用者可以等待 stop 方法的结果，一旦任务完成，调用者可以确保所有资源都被清理等等。

一种变体是让 Start 方法返回类似 IAsyncDisposable 的内容，这可以允许 using 语句在超出范围时自动停止并等待清理。

例子：

public class MyClass
    volatile bool stopRequested; // or use CancellationTokenSource
    Task task;
    public void Start() => task = Task.Run(DoWork); // Should probably make this "longRunning"
    public void DoWork(){
        while(!stopRequested){
            // Do something that take a limited amount of time.
        }
        // Do cleanup
    }
    public Task Stop(){
        stopRequested = true;
        return task;
    }