线程池学习经验

什么是线程池？它有什么特点？ 线程池就是一些线程的集合。线程池可以很好的提升性能，线程池在启动时会创建大量空闲的线程，程序将一个任务传给线程池，线程池将该任务分配给其中的一个空闲的线程。当执行结束时，该线程不会死亡，而是继续回到线程池，等待下次被“赋予任务”。

为什么使用线程池？ 多线程运行时，系统不断关闭开启新线程，过度消耗资源，甚至导致资源的崩溃，线程池能很好地解决这个问题。

ExecutorService ExecutorService是线程的返回值，也是控制线程数量和重用线程的一个接口。

四个常用的线程池 1.Executors.newCacheThreadPool() 可缓存线程池，一般用于执行一些生存期很短的异步型任务。

public class newCacheThreadPool { public static void main(String[] args) { // 创建一个可缓存线程池 ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); for (int i = 0; i < 10; i++) { try { // 看到使用的是线程池里面以前的线程，没有创建新的线程 Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } cachedThreadPool.execute(new Runnable() { public void run() { // 打印正在执行的缓存线程信息 System.out.println(Thread.currentThread().getName() + "正在被执行"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }); } } }

输出结果为： pool-1-thread-1正在被执行 pool-1-thread-2正在被执行 pool-1-thread-2正在被执行 pool-1-thread-1正在被执行 pool-1-thread-1正在被执行 pool-1-thread-2正在被执行 pool-1-thread-1正在被执行 pool-1-thread-2正在被执行 pool-1-thread-1正在被执行 pool-1-thread-2正在被执行 2.Executors.newFixedThreadPool(int n)： 创建一个可重用固定个数的线程池，以共享的无界队列方式来运行这些线程。

public class NewFixedThreadPoolTest { public static void main(String[] args) { // 创建一个可重用固定个数的线程池 ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3); for (int i = 0; i < 10; i++) { fixedThreadPool.execute(new Runnable() { public void run() { try { // 打印正在执行的缓存线程信息 System.out.println(Thread.currentThread().getName() + "正在被执行"); Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } }); } } }

其结果为： pool-1-thread-1正在被执行 pool-1-thread-2正在被执行 pool-1-thread-3正在被执行 pool-1-thread-2正在被执行 pool-1-thread-3正在被执行 pool-1-thread-1正在被执行 pool-1-thread-1正在被执行 pool-1-thread-3正在被执行 pool-1-thread-2正在被执行 pool-1-thread-1正在被执行 3.Executors.newScheduledThreadPool(int n)： 创建一个定长线程池，可进行定时操作

public class NewScheduledThreadPoolTest { public static void main(String[] args) { //创建一个定长线程池，支持定时及周期性任务执行——延迟执行 ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5); //延迟1秒执行 /*scheduledThreadPool.schedule(new Runnable() { public void run() { System.out.println("延迟1秒执行"); } }, 1, TimeUnit.SECONDS);*/ //延迟1秒后每3秒执行一次 scheduledThreadPool.scheduleAtFixedRate(new Runnable() { public void run() { System.out.println("延迟1秒后每3秒执行一次"); } }, 1, 3, TimeUnit.SECONDS); } }

执行结果： 延迟1秒后每3秒执行一次 延迟1秒后每3秒执行一次 … 4.Executors.newSingleThreadExecutor()： 创建一个单线程化的线程池，有序执行。

public class NewSingleThreadExecutorTest { public static void main(String[] args) { //创建一个单线程化的线程池 ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor(); for (int i = 0; i < 10; i++) { final int index = i; singleThreadExecutor.execute(new Runnable() { public void run() { try { //结果依次输出，相当于顺序执行各个任务 System.out.println(Thread.currentThread().getName()+"正在被执行,打印的值是:"+index); Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } } }); } } }

执行结果： pool-1-thread-1正在被执行,打印的值是:0 pool-1-thread-1正在被执行,打印的值是:1 pool-1-thread-1正在被执行,打印的值是:2 pool-1-thread-1正在被执行,打印的值是:3 pool-1-thread-1正在被执行,打印的值是:4 pool-1-thread-1正在被执行,打印的值是:5 pool-1-thread-1正在被执行,打印的值是:6 pool-1-thread-1正在被执行,打印的值是:7 pool-1-thread-1正在被执行,打印的值是:8 pool-1-thread-1正在被执行,打印的值是:9