我需要使 TcpClient 事件驱动而不是一直轮询消息，所以我想:我将创建一个线程来等待消息到来并在消息到来时触发事件。这是一个总体思路:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Net;

namespace ThreadsTesting
{
    class Program
    {
        static void Main(string[] args)
        {
            Program p = new Program();

            //imitate a remote client connecting
            TcpClient remoteClient = new TcpClient();
            remoteClient.Connect(IPAddress.Parse("127.0.0.1"), 80);

            //start listening to messages
            p.startMessageListener();

            //send some fake messages from the remote client to our server
            for (int i = 0; i < 5; i++)
            {
                remoteClient.GetStream().Write(new byte[] { 0x80 }, 0, 1);
                Thread.Sleep(200);
            }

            //sleep for a while to make sure the cpu is not used
            Console.WriteLine("Sleeping for 2sec");
            Thread.Sleep(2000);

            //attempt to stop the server
            p.stopMessageListener();

            Console.ReadKey();
        }

        private CancellationTokenSource cSource;
        private Task listener;
        private TcpListener server;
        private TcpClient client;

        public Program()
        {
            server = new TcpListener(IPAddress.Parse("127.0.0.1"), 80);
            server.Start();
        }

        private void startMessageListener()
        {
            client = server.AcceptTcpClient();

            //start listening to the messages
            cSource = new CancellationTokenSource();
            listener = Task.Factory.StartNew(() => listenToMessages(cSource.Token), cSource.Token);
        }

        private void stopMessageListener()
        {
            Console.Out.WriteLine("Close requested");
            //send cancelation signal and wait for the thread to finish
            cSource.Cancel();
            listener.Wait();
            Console.WriteLine("Closed");
        }

        private void listenToMessages(CancellationToken token)
        {
            NetworkStream stream = client.GetStream();

            //check if cancelation requested
            while (!token.IsCancellationRequested)
            {
                //wait for the data to arrive
                while (!stream.DataAvailable)
                { }

                //read the data (always 1 byte - the message will always be 1 byte)
                byte[] bytes = new byte[1];
                stream.Read(bytes, 0, 1);

                Console.WriteLine("Got Data");

                //fire the event
            }
        }
    }
}

由于显而易见的原因，这不能正常工作:

• while (!stream.DataAvailable) 阻塞线程并始终使用 25% 的 CPU(在 4 核 CPU 上)，即使那里没有数据也是如此。
• listener.Wait(); 将一直等待，因为 while 循环没有检测到取消已被调用。

我的替代解决方案是在 listenToMessages 方法中使用异步调用:

private async Task listenToMessages(CancellationToken token)
{
    NetworkStream stream = client.GetStream();

    //check if cancelation requested
    while (!token.IsCancellationRequested)
    {
         //read the data
         byte[] bytes = new byte[1];
         await stream.ReadAsync(bytes, 0, 1, token);

         Console.WriteLine("Got Data");

          //fire the event
    }
}

这完全符合我的预期:

• 如果队列中没有消息，CPU 不会阻塞，但我们仍在等待它们
• 取消请求被正确接收并且线程按预期完成

虽然我想走得更远。由于 listenToMessages 现在返回一个任务本身，我认为没有必要启动一个任务来执行该方法。这是我所做的:

private void startMessageListener()
{
    client = server.AcceptTcpClient();

    //start listening to the messages
    cSource = new CancellationTokenSource();
    listener = listenToMessages(cSource.Token);
}

这并不像我预期的那样起作用，因为当调用 Cancel() 时，ReadAsync() 方法似乎没有从 token 中获取取消消息，并且线程没有停止，相反，它停留在 ReadAsync() 行上。

知道为什么会这样吗？我认为 ReadAsync 仍会像以前一样获取 token ...
感谢您的宝贵时间和帮助。

-- 编辑--
好吧，在更深入的评估之后，我的解决方案 2 并没有像预期的那样工作:
线程本身结束到调用者，因此调用者可以继续。然而，线程并没有“死”，所以如果我们发送一些数据它会再次执行!
这是一个例子:

//send some fake messages from the remote client to our server
for (int i = 0; i < 5; i++)
{
    remoteClient.GetStream().Write(new byte[] { 0x80 }, 0, 1);
    Thread.Sleep(200);
}

Console.WriteLine("Sleeping for 2sec");
Thread.Sleep(2000);

//attempt to stop the server
p.stopListeners();

//check what will happen if we try to write now
remoteClient.GetStream().Write(new byte[] { 0x80 }, 0, 1);
Thread.Sleep(200);

Console.ReadKey();

这将输出消息“Got Data”，即使理论上我们已经停止了!我将进一步调查并报告我的发现。

最佳答案

使用现代库，无论何时键入 new Thread，您都已经拥有遗留代码。

您的情况的核心解决方案是异步套接字方法。不过，有几种方法可以处理您的 API 设计:Rx、TPL Dataflow 和普通 TAP 浮现在脑海中。如果您真的想要事件，那么EAP是一个选项。

我有一个 EAP 套接字库 here .它确实需要同步上下文，因此如果您需要从控制台应用程序中使用它，则必须使用类似 ActionDispatcher 的东西(包含在同一库中)(如果您不需要它在 WinForms/WPF 中使用它)。

关于c# - 在 C# 中停止线程，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/20145215/