Java 的线程池 ExecutorService 简单介绍

缺乏、安全感 2022-06-07 14:05 228阅读 0赞

做java的开发，线程是经常用的。最简单的使用大家都应该清楚，如继承Thread类、实现Runnable接口。这样，是没有问题。但是当我们需要频繁的处理一些任务时候，就要多次创建线程和处理线程关闭等回收工作。 这样比较麻烦。并且如果同时不限制线程个数，很多个任务一起执行，对性能有一定影响。所以，java提供了Executor线程池来处理并发任务，并且可以支持4种模式：

1.new CachedThreadPool： 创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。  
2.new FixedThreadPool：创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。  
3.new ScheduledThreadPool： 创建一个定长线程池，支持定时及周期性任务执行。  
4.new SingleThreadExecutor： 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。

一 创建线程池

**\[java\]** [ view plain][view plain] [ copy][view plain]

1.  // 创建可以容纳3个线程的线程池
2.  ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
3.  
4.  // 线程池的大小会根据执行的任务数动态分配
5.  ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
6.  
7.  // 创建单个线程的线程池，如果当前线程在执行任务时突然中断，则会创建一个新的线程替代它继续执行任务
8.  ExecutorService singleThreadPool = Executors.newSin
9.  // 效果类似于Timer定时器 ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

二 启动线程池

启动线程提供了2个方法：ExecutorService 的submit（） 与execute（），定义如下：

**\[java\]** [ view plain][view plain] [ copy][view plain]

1.  <T> Future<T> submit(Callable<T> var1);
2.  <T> Future<T> submit(Runnable var1, T var2);
3.  Future<?> submit(Runnable var1);
4.  void execute(Runnable var1);

三 关闭线程池

使用以下的方法：  
1.shutdown() 方法: 关闭线程池资源。不再接受新的任务，之前提交的任务等待执行结束再关闭。并且回收资源。  
2.shutdownNow(): 立即关闭，通过调用Thread.interrupt来实现线程的立即退出。执行该方法，线程池的状态立刻变成STOP状态，并试图停止所有正在执行的线程，不再处理还在池队列中等待的任务。并且回收资源。

四 new Thread和线程池创建线程区别

new Thread的弊端如下：  
a. 每次new Thread新建对象性能差。  
b. 线程缺乏统一管理，可能无限制新建线程，相互之间竞争，及可能占用过多系统资源导致死机或oom。  
c. 缺乏更多功能，如定时执行、定期执行、线程中断。  
相比new Thread，Java提供的四种线程池的好处在于：  
a. 重用存在的线程，减少对象创建、消亡的开销，性能佳。  
b. 可有效控制最大并发线程数，提高系统资源的使用率，同时避免过多资源竞争，避免堵塞。  
c. 提供定时执行、定期执行、单线程、并发数控制等功能。

[view plain]: http://blog.csdn.net/skycnlr/article/details/60479647#