Searched refs:SharedResourcePool (Results 1 – 10 of 10) sorted by relevance
22 public final class SharedResourcePool<T> implements ObjectPool<T> { class25 private SharedResourcePool(SharedResourceHolder.Resource<T> resource) { in SharedResourcePool() method in SharedResourcePool29 public static <T> SharedResourcePool<T> forResource(SharedResourceHolder.Resource<T> resource) { in forResource()30 return new SharedResourcePool<T>(resource); in forResource()
84 SharedResourcePool.forResource(GrpcUtil.SHARED_CHANNEL_EXECUTOR);409 SharedResourcePool.forResource(GrpcUtil.SHARED_CHANNEL_EXECUTOR), in build()
61 SharedResourcePool.forResource(GrpcUtil.SHARED_CHANNEL_EXECUTOR);
23 import io.grpc.internal.SharedResourcePool;52 SharedResourcePool.forResource(GrpcUtil.TIMER_SERVICE), in newLoadBalancer()
23 import io.grpc.internal.SharedResourcePool;42 SharedResourcePool.forResource(GrpcUtil.TIMER_SERVICE), streamTracerFactories); in newServer()
27 import io.grpc.internal.SharedResourcePool;40 new InProcessServer("name", SharedResourcePool.forResource(GrpcUtil.TIMER_SERVICE), in getPort_notStarted()
28 import io.grpc.internal.SharedResourcePool;62 SharedResourcePool.forResource(TIMER_SERVICE); in scheduledExecutorService_default()
28 import io.grpc.internal.SharedResourcePool;96 SharedResourcePool.forResource(GrpcUtil.TIMER_SERVICE);
42 import io.grpc.internal.SharedResourcePool;66 SharedResourcePool.forResource(HandshakerServiceChannel.SHARED_HANDSHAKER_CHANNEL);
44 import io.grpc.internal.SharedResourcePool;63 SharedResourcePool.forResource(HandshakerServiceChannel.SHARED_HANDSHAKER_CHANNEL);