problem: too many timeouts under load or spike in load

This commit is contained in:
Igor Artamonov
2019-09-12 23:29:20 -04:00
parent bd6d6aa6bb
commit ee0ab43f9c

View File

@@ -74,7 +74,7 @@ class GrpcUpstreams(
val client = ReactorBlockchainGrpc.newReactorStub(channel.build())
this.client = client
var i = 0
val grpcExecutor = Executors.newFixedThreadPool(64) { r -> Thread(r, "grpc-up-$id-${i++}") };
val grpcExecutor = Executors.newCachedThreadPool { r -> Thread(r, "grpc-up-$id-${i++}") };
this.grpcTransport = EmeraldGrpcTransport.newBuilder()
.forChannel(client.channel)
.setObjectMapper(objectMapper)