关于这个问题已经进行了很多讨论,但他们似乎无法解释我的特定问题。使用 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));
}