|
|
@ -75,8 +75,10 @@ public class DefaultThreadPoolCheckAlarmHandler implements Runnable, ThreadPoolC
|
|
|
|
private final AtomicInteger count = new AtomicInteger();
|
|
|
|
private final AtomicInteger count = new AtomicInteger();
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public Thread newThread(Runnable r) {
|
|
|
|
public Thread newThread(Runnable runnable) {
|
|
|
|
return new Thread("client.execute.timeout.alarm_" + count.incrementAndGet());
|
|
|
|
Thread thread = new Thread(runnable, "client.execute.timeout.alarm_" + count.incrementAndGet());
|
|
|
|
|
|
|
|
thread.setDaemon(true);
|
|
|
|
|
|
|
|
return thread;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
},
|
|
|
|
},
|
|
|
|
new ThreadPoolExecutor.AbortPolicy());
|
|
|
|
new ThreadPoolExecutor.AbortPolicy());
|
|
|
|