Skip to content

Commit c189259

Browse files
refactor:add instance detect thread factory. (#667)
Signed-off-by: Haotian Zhang <928016560@qq.com>
1 parent 2135a85 commit c189259

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

polaris-discovery/polaris-discovery-client/src/main/java/com/tencent/polaris/discovery/client/stat/ServiceCallResultCollector.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import com.tencent.polaris.api.pojo.ServiceKey;
2525
import com.tencent.polaris.client.api.SDKContext;
2626
import com.tencent.polaris.client.api.ServiceCallResultListener;
27+
import com.tencent.polaris.client.util.NamedThreadFactory;
2728

2829
import java.util.HashSet;
2930
import java.util.Set;
@@ -59,7 +60,7 @@ public synchronized void init(SDKContext sdkContext) {
5960
LocalRegistry localRegistry = sdkContext.getExtensions().getLocalRegistry();
6061
instancesStatisticUpdater = new InstancesStatisticUpdater(localRegistry);
6162
if (outlierDetectionConfig.getWhen() != When.never) {
62-
detectTaskExecutors = Executors.newSingleThreadScheduledExecutor();
63+
detectTaskExecutors = Executors.newSingleThreadScheduledExecutor(new NamedThreadFactory("instance-detect"));
6364
long checkPeriodMs = outlierDetectionConfig.getCheckPeriod();
6465
detectTask = new InstancesDetectTask(sdkContext.getExtensions(), outlierDetectionConfig.getWhen());
6566
calledServiceSet = detectTask.getServiceKeySet();

0 commit comments

Comments
 (0)