实现线程池后的 Tcp Server 性能问题

Question

我已经阅读了几个关于这个问题的讨论并设法理解了一点，但在从 Thread 类转换为 ThreadPool 类时仍然存在一些解决性能问题的问题

详情：

我已经构建了一个 tcp 服务器，用于教育目的（任务不应该使用异步方法），它接受客户端连接并为每个客户端创建一个新线程。使用这种方法，应用程序的执行时间不到一秒，但是当决定转移到像线程池这样的下一级解决方案时，我的性能下降到仅 100 个客户端的 40-50 秒，我只发送一个 2048 字节的缓冲区，接收它并关闭。

前 12 个线程非常快，很可能是因为我的 CPU 是 6 核 12 线程，然后线程开始出现延迟。我对解决方案的想法和结构方法持开放态度。

服务器代码：

public void OnSocketReceive()
    {
        while (!this.exitServer)
        {
            if (!tcpListener.Pending())
            {
                Thread.Sleep(10);
                continue;
            }

            TcpClient client = tcpListener.AcceptTcpClient();

            IManageConnectedUser chatLogic = new ManageConnectedUser(connections, welcomeMessage);

            //Thread clientThread = new Thread(new ParameterizedThreadStart(chatLogic.OnClientConnection));
            //clientThread.Start(client);

            ThreadPool.QueueUserWorkItem(chatLogic.OnClientConnection, client);
        }

更多说明

到目前为止，通过我所做的调试和阅读的讨论，我得出的结论是，问题出在 OnClientConnection 函数中的阻塞代码，更具体地说是在 stringCreateHandler 的内部函数中。我在哪里收到此错误： System.Threading.ThreadInterruptedException: 线程从第 39 行的等待状态中断，即 Thread.Sleep(10);

public string stringCreateHandler(TcpClient client)
    {
        StringBuilder sb = new StringBuilder();
        try
        {
            do
            {
                if (client.Available > 0)
                {
                    while (client.Available > 0)
                    {
                        char ch = (char)client.GetStream().ReadByte();

                        if (ch == '\r')
                        {
                            continue;
                        }
                        if (ch == '\n')
                        {
                            return sb.ToString();
                        }

                        sb.Append(ch);
                    }
                }

                Thread.Sleep(10);
              
            } while (true);
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            throw;
        }

    }

我已经检查了其余的代码，我认为没有更多的阻塞代码，但我给出了项目的链接https://github.com/nikolaymih/Chat-Project/tree/master/ChatProjectNewThreads 唯一的区别是 Thread 类而不是 ThreadPool 但这只是为了定位

Answer 1

查看您的完整项目，我认为您的问题是 OnClientConnection 长期运行：在该连接关闭之前它不会返回，并且由于这是一个“聊天应用程序”，连接保持打开状态并且不是t 很快就关门了。

正如您所见，ThreadPool 以许多空闲线程开始，它会根据需要以大约每 500 毫秒一个的速率添加线程（尽管这是一个实现细节）。这通常不是问题：您不应该将 ThreadPool 用于非常长时间运行的任务，这些任务永远不会返回，并且永远占用线程。但是，由于您的 OnClientConnection 方法很长时间都不会返回，因此您只是在抓取和占用 ThreadPool 线程，并迫使 ThreadPool 继续扩展。

如果您想为每个客户端使用一个线程，最好为每个客户端创建一个新的长时间运行的线程。但是，这非常浪费：您将有大量线程挂在周围，但没有做太多事情。最好有少量线程不断处理来自大量客户端的消息。可以自己构建它，但使用 TcpListener 和 NetworkStream 的 async/await 功能要容易得多。