maobaolong commented on PR #2175:
URL:
https://github.com/apache/incubator-uniffle/pull/2175#issuecomment-2421251548
```java
new GrpcThreadPoolExecutor(
rpcExecutorSize,
rpcExecutorSize * 2,
10,
TimeUnit.MINUTES,
Queues.newLinkedBlockingQueue(Integer.MAX_VALUE),
ThreadUtils.getThreadFactory("Grpc"),
grpcMetrics);
```
@jerqi Reference this code, the original author set the different
`corePoolSize` and `maxPoolSize`, it means that the author expected the working
thread could be grow up to 2 time of `corePoolSize`, but he/she use a unlimited
size queue here, so the working thread number could never grow up unless the
waiting queue full, it could never be able to full for this unlimited queue.
So I supply a way to customize the queue size for cluster maintainer.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
