@@ -1,58 +0,0 @@ ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别? | 凤凰涅槃进阶之路

ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别?

Abel sun2022年12月24日约 305 字大约 1 分钟

ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别?

1. 区别

  1. 所属包不同:
    • ThreadPoolTaskExecutor 在 spring core包中
    • ThreadPoolExecutor 是JDK中的JUC
  2. ThreadPoolTaskExecutor 是对ThreadPoolExecutor进行了封装处理
  3. 相比 ThreadPoolExecutor,ThreadPoolTaskExecutor 增加了 submitListenable 方法,该方法返回 ListenableFuture 接口对象。
    • ListenableFuture 接口对象,增加了线程执行完毕后成功和失败的回调方法。从而避免了 Future 需要以阻塞的方式调用 get,然后再执行成功和失败的方法。

2. ThreadPoolTaskExecutor 源码

  1. 成员变量与构造函数
public class ThreadPoolTaskExecutor extends ExecutorConfigurationSupport implements AsyncListenableTaskExecutor, SchedulingTaskExecutor {
    private final Object poolSizeMonitor = new Object();
    private int corePoolSize = 1;
    private int maxPoolSize = 2147483647;
    private int keepAliveSeconds = 60;
    private int queueCapacity = 2147483647;
    private boolean allowCoreThreadTimeOut = false;
    @Nullable
    private TaskDecorator taskDecorator; 
    @Nullable
    private ThreadPoolExecutor threadPoolExecutor;//这里就用到了ThreadPoolExecutor
    private final Map<Runnable, Object> decoratedTaskMap;

    public ThreadPoolTaskExecutor() {
        this.decoratedTaskMap = new ConcurrentReferenceHashMap(16, ReferenceType.WEAK);
    }
  1. 设置完配置需要调用initialize方法初始化。最终实例化了ThreadPoolExecutor

        protected ExecutorService initializeExecutor(ThreadFactory threadFactory, RejectedExecutionHandler rejectedExecutionHandler) {
            BlockingQueue<Runnable> queue = this.createQueue(this.queueCapacity);
            ThreadPoolExecutor executor;
            if (this.taskDecorator != null) {
                executor = new ThreadPoolExecutor(this.corePoolSize, this.maxPoolSize, (long)this.keepAliveSeconds, TimeUnit.SECONDS, queue, threadFactory, rejectedExecutionHandler) {
                    public void execute(Runnable command) {
                        Runnable decorated = ThreadPoolTaskExecutor.this.taskDecorator.decorate(command);
                        if (decorated != command) {
                            ThreadPoolTaskExecutor.this.decoratedTaskMap.put(decorated, command);
                        }
    
                        super.execute(decorated);
                    }
                };
            } else {
                executor = new ThreadPoolExecutor(this.corePoolSize, this.maxPoolSize, (long)this.keepAliveSeconds, TimeUnit.SECONDS, queue, threadFactory, rejectedExecutionHandler);
            }
    
            if (this.allowCoreThreadTimeOut) {
                executor.allowCoreThreadTimeOut(true);
            }
    
            this.threadPoolExecutor = executor;
            return executor;
        }
    

    3. 推荐

    推荐直接使用spring封装好的 ThreadPoolTaskExecutor ,更加简洁方便一些

评论
  • 按正序
  • 按倒序
  • 按热度
Powered by Waline v2.9.1