4

关于这个问题已经进行了很多讨论，但他们似乎无法解释我的特定问题。使用 ThreadPool 而不是 Thread 类进行线程处理时，我遇到了严重的性能问题。

细节：

我已经构建了一个 tcp 服务器，当 tcp 服务器接受一个新客户端时，它会生成一个新线程来处理该客户端。一切都相当简单，但是我的服务器处理许多并发客户端的时间太长了。大约 35 个简单的客户端只发送一个 2048 字节的缓冲区，接收它并关闭它，需要 30 秒。

经过多次停止后，我发现ThreadPool.QueueUserWorkItem最多需要 26 秒。我用它来产生新的线程来处理新的客户。更换ThreadPool.QueueUserWorkItem后new Thread()我的性能提高到不到一秒钟。

我很想解释一下为什么会这样。

澄清：

延迟与客户端代码无关，从调用 ThreadPool.QueueUserWorkItem 到启动 clientMsgHandler.HandleIncomingMsgs 20 秒可以过去。

延迟从第一个线程开始，实际上随着测试的继续略有改善。我对解决方案不太感兴趣，而对解释为什么会发生更感兴趣。客户端确实阻塞了，但时间很短。

服务器代码：

private void AddTcpClientMsgHandler(TcpClient tcpClient)
    {
        //lock so no addition of client and closure can occur concurrently
        Stopwatch watch = new Stopwatch();
        watch.Start();
        Monitor.Enter(this);
        int pWatchIdx =  watchIDX++;
        if (!isOpen)
            throw new ObjectDisposedException(ResourceAlreadyClosed);

        TcpClientMsgHandler clientMsgHandler = CreateClientHandler(tcpClient);                                         
        clientMsgHandlerManager.AddTcpClientMsgHandler(clientMsgHandler);
        //ThreadPool.QueueUserWorkItem(clientMsgHandler.HandleIncomingMsgs); takes 20 seconds to run
        Thread thread = new Thread(clientMsgHandler.HandleIncomingMsgs);
        thread.Start();
        watch.Stop();
        Monitor.Exit(this);
        Console.WriteLine(string.Format("Iteration {0} took {1} Client {2}", pWatchIdx.ToString(),watch.Elapsed, tcpClient.Client.RemoteEndPoint));

    }
4

4 回答 4

4

阻塞代码是线程池的敌人。从您发布的示例中，无法判断阻塞发生的位置，但我建议您查看代码路径以找出代码阻塞的位置。在调试器中运行您的服务器，直到它开始显示高延迟，然后中断执行并查看 VS 的线程面板。这将向您显示线程阻塞的位置。这很可能是在同步 IO 上。考虑用异步代码替换。

于 2013-01-15T10:29:55.943 回答
1

ThreadPool.QueueUserWorkItem - 将执行的方法排队。该方法在线程池线程可用时执行。

  • ThreadPool 等待空闲线程。
  • 当找到空闲线程时，ThreadPool 使用它来执行您的方法。

为什么线程池很慢？

  • 在线程池中的线程用完之前，上述两个并不是真正的原因。
  • 在 .NET 3.5 下有 2000 个工作线程和 1000 个 IO 完成端口线程。（在 4.0、4.5 中甚至更多）。检查Jon Skeet 的答案（线程池中的活动线程号）。

[例如]

.Net 2.0 默认每个可用处理器有 25 个线程。这意味着如果您将 30 个任务排队，最后 5 个任务将必须等待线程从池中可用，然后才能执行。

解决方案 ：

SetMinThreads()使最小线程数为 30（对于 .Net 2.0）。这将提高性能，因为 ThreadPool 在需要时不会立即创建新线程；它只在特定的时间间隔内执行此操作。

注意：每个客户端使用一个线程不支持更多并发。

使用异步套接字- 这些是非阻塞套接字，除了您不必轮询：每当发生“有趣”的事情时，堆栈都会向程序发送一个特殊的窗口消息。

于 2013-01-15T11:34:00.460 回答
0

在线程池中的前几个线程用完后，系统会在启动每个新线程池线程之前引入延迟（这不影响重用线程）。

您可以通过在启动任何线程之前将ThreadPool.SetMinThreads设置为适当大的值来更改线程池线程的初始数量。但你不应该那样做！（所以你没有从我这里听到……；）

您应该研究一种减少线程数量的方法，而不是这样做。

于 2013-01-15T10:24:28.643 回答
0

我认为这取决于您在clientMsgHandler.HandleIncomingMsgs()方法中所做的事情。线程池必须仅用于非常短的处理。

此外，线程池的默认大小为每个可用处理器 25 个工作线程，请注意线程中的交叉锁。

>> 托管线程池

于 2013-01-15T10:35:23.777 回答