java - 从 java Grpc 服务器调试线程转储？

Question

我正在调试 java Grpc 服务器上的一个问题，每 n 分钟，服务器在处理请求时就会暂停一次。我附加了一个分析器，我可以立即看到问题，每 n 分钟线程数量就会出现峰值，然后几秒钟后它再次恢复正常，并且在接下来的 n 分钟内一切正常。当线程峰值发生时，我对 jvm 进行了线程转储，我可以轻松地看到有大量等待线程。但从那里我无法真正判断是什么导致了这种情况 - 请参阅下面的线程转储的示例输出。服务器可能因太多请求而过载，但我无法从下面解释这一点:

"grpc-default-executor-1212" - Thread t@4520
   java.lang.Thread.State: TIMED_WAITING
    at java.base@11.0.1/jdk.internal.misc.Unsafe.park(Native Method)
    - parking to wait for <44b4dca3> (a java.util.concurrent.SynchronousQueue$TransferStack)
    at java.base@11.0.1/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234)
    at java.base@11.0.1/java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:462)
    at java.base@11.0.1/java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:361)
    at java.base@11.0.1/java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:937)
    at java.base@11.0.1/java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1053)
    at java.base@11.0.1/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114)
    at java.base@11.0.1/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at java.base@11.0.1/java.lang.Thread.run(Thread.java:834)

   Locked ownable synchronizers:
    - None

有没有人遇到过以上情况，能解释一下原因吗？ (CPU 使用率和堆都很好，因此不会导致问题)谢谢

Answer 1

您可以查看java doc SynchronousQueue的

A blocking queue in which each insert operation must wait for a corresponding remove operation by another thread, and vice versa. A synchronous queue does not have any internal capacity, not even a capacity of one

你可以使用SynchronousQueue作为参数来创建一个ThreadPool。SynchronousQueue是一个没有容量的队列，当线程从线程池中获取某个任务时，它们会被阻塞，直到某些任务被提交。