ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别?

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

ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别?

1. 区别

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

2. ThreadPoolTaskExecutor 源码

成员变量与构造函数

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);
    }

设置完配置需要调用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 ，更加简洁方便一些

昵称

邮箱

网址

按正序
按倒序
按热度

ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别?

# ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别?

# 1. 区别

# 2. ThreadPoolTaskExecutor 源码

# 3. 推荐

预览:

ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别?

1. 区别

2. ThreadPoolTaskExecutor 源码

3. 推荐