Thank you Carl.
Is something like this what you meant? I striped out the resizing logic...
activeCalls is an AtomicInteger
@Override
public ServerCall.Listener
interceptCall(ServerCall call, Metadata headers,
ServerCallHandler next) {
resizePool(activeCalls.incrementAndGet());
Hi everyone,
Our gRPC server runs on a ThreadPoolExecutor with a corePoolSize of 4 and a
maximumPoolSize of 16. In order to have the pool size increase, we provide
a BlockingQueue with a bounded size of 20.
Sometimes short bursts happen and we're perfectly fine with dropping
requests at this