|
@@ -175,7 +175,6 @@ public class HystrixContextScheduler extends Scheduler {
|
|
|
sa.addParent(subscription);
|
|
sa.addParent(subscription);
|
|
|
|
|
|
|
|
ThreadPoolExecutor executor = (ThreadPoolExecutor) threadPool.getExecutor();
|
|
ThreadPoolExecutor executor = (ThreadPoolExecutor) threadPool.getExecutor();
|
|
|
- LOGGER.info("创建新线程...............");
|
|
|
|
|
Runnable runnable = TtlRunnable.get(sa);
|
|
Runnable runnable = TtlRunnable.get(sa);
|
|
|
FutureTask<?> f = (FutureTask<?>) executor.submit(runnable);
|
|
FutureTask<?> f = (FutureTask<?>) executor.submit(runnable);
|
|
|
sa.add(new FutureCompleterWithConfigurableInterrupt(f, shouldInterruptThread, executor));
|
|
sa.add(new FutureCompleterWithConfigurableInterrupt(f, shouldInterruptThread, executor));
|