File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
temporal-sdk/src/main/java/io/temporal/internal/client/external Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change 44import static io .temporal .serviceclient .MetricsTag .METRICS_TAGS_CALL_OPTIONS_KEY ;
55
66import com .google .common .util .concurrent .ListenableFuture ;
7+ import com .google .common .util .concurrent .ThreadFactoryBuilder ;
78import com .uber .m3 .tally .Scope ;
89import com .uber .m3 .util .ImmutableMap ;
910import io .grpc .Deadline ;
1819import javax .annotation .Nonnull ;
1920
2021public final class GenericWorkflowClientImpl implements GenericWorkflowClient {
21-
22- // TODO we need to shutdown this executor
2322 private static final ScheduledExecutorService asyncThrottlerExecutor =
24- new ScheduledThreadPoolExecutor (1 , r -> new Thread (r , "generic-wf-client-async-throttler" ));
25-
23+ Executors .newSingleThreadScheduledExecutor (
24+ new ThreadFactoryBuilder ()
25+ .setDaemon (true )
26+ .setNameFormat ("generic-wf-client-async-throttler-%d" )
27+ .build ());
2628 private final WorkflowServiceStubs service ;
2729 private final Scope metricsScope ;
2830 private final GrpcRetryer grpcRetryer ;
You can’t perform that action at this time.
0 commit comments