线程池——Executor、Executors、ExecutorService、ThreadPoolExecutor、ThreadPoolTaskExecutor之间的区别

逃离我推掉我的手 2024-03-27 15:17 81阅读 0赞

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RpYW44MzA5Mzc_size_16_color_FFFFFF_t_70]  
层次关系：

public interface ExecutorService extends Executor {
        }
    public abstract class AbstractExecutorService implements ExecutorService {
        }
    public interface ScheduledExecutorService extends ExecutorService {
        }
    
    public class ThreadPoolExecutor extends AbstractExecutorService {
        }
    public class ScheduledThreadPoolExecutor extends ThreadPoolExecutor implements ScheduledExecutorService {
        }

##### ExecutorService 接口继承了Executor 接口，是Executor 的子接口。 #####

*  1.Executor接口中定义了execute()方法，用来接收一个Runnable接口的对象，  
    　　 　　 而ExecutorService接口中定义的submit()方法可以接收Runnable和Callable接口对象。
 *  2.Executor接口中execute()方法不返回任何结果，而ExecutorService接口中submit()方法可以通过一个 Future 对象返回运算结果。
 *  3.Executor和ExecutorService除了允许客户端提交一个任务，ExecutorService 还提供用来控制线程池的方法。  
    　　 　　比如：调用 shutDown() 方法终止线程池。

##### Executors 类提供工厂方法用来创建不同类型的[线程池][Link 1]。 #####

比如:  
　　 　Executors.newSingleThreadExecutor() 创建一个只有一个线程的线程池，  
　　　 Executors.newFixedThreadPool(int numOfThreads)来创建固定线程数的线程池，  
　　 Executors.newCachedThreadPool()创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。  
　　 Executors.newScheduledThreadPool(int corePoolSize) 创建一个线程池，它可安排在给定延迟后运行命令或者定期地执行。

##### ThreadPoolExecutor #####

这个类是JDK中的线程池类，继承自Executor,里面有一个execute()方法，用来执行线程，线程池主要提供一个线程队列，队列中保存着所有等待状态的线程。

使用方式有两种,可以通过工具类或者构造方法.

**线程池创建方式一:构造方法(传入相应的参数即可).**

private static final ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 2, 300, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(1200), new DiscardOldestPolicy());

**线程池创建方式二:**  
通过Executors工具类.  
Executors类，提供了一系列工厂方法用于创建线程池，返回的线程池都实现了ExecutorService接口.

1、public static ExecutorService newFiexedThreadPool(int Threads)  
创建固定数目线程的线程池。

2、public static ExecutorService newCachedThreadPool()：  
创建一个可缓存的线程池，调用execute 将重用以前构造的线程（如果线程可用）。如果没有可用的线程，则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。

3、public static ExecutorService newSingleThreadExecutor()：  
创建一个单线程化的Executor。

4、public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)  
创建一个支持定时及周期性的任务执行的线程池，多数情况下可用来替代Timer类。

##### ThreadPoolTaskExecutor #####

这个类则是spring包下的，是sring为我们提供的线程池类,可以使用基于xml配置的方式创建.

或者 注解config  
**线程池创建方式三**

@Bean("yzzxTaskAsyncPool")
        public Executor getAsyncExecutor() {
        
            ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
            executor.setCorePoolSize(10);
            executor.setMaxPoolSize(50);
            executor.setThreadNamePrefix("async-pool-");
            // 这一步是关键，异步Task装饰器
            executor.setTaskDecorator(new ContextDecorator());
            executor.initialize();
            return executor;
        }

注:ThreadPoolTaskExecutor中的excute和submit方法的区别?

无返回值的任务使用execute方法提交；

有返回值的任务使用submit(Callable) 方法提交。

使用submit提交任务，提交后只要有从Future取数据的操作，那么主线程在子线程结束后才会结束.

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RpYW44MzA5Mzc_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/cc06cc93a8f6480086e22ffb82e8bb61.png
[Link 1]: https://so.csdn.net/so/search?q=%E7%BA%BF%E7%A8%8B%E6%B1%A0&spm=1001.2101.3001.7020