[grpc-io] Re: [java] - gRPC ThreadPoolExecutor and bounded queue

2018-11-29 Thread info
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());

[grpc-io] [java] - gRPC ThreadPoolExecutor and bounded queue

2018-11-29 Thread info
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