转载

关于Java多线程及线程池的使用看这篇就够了

来源丨gongxiongzhuang

hacpai.com/article/1557481151073

在项目里面为了提高性能往往会在主线程里面开启一个新线程去执行，这种做法最方便快捷，但是当用户量数据上涨，很显然每次去开启新的线程服务器往往会吃不消，这时就需要线程池来管理和监控线程的状态。

创建多线程的三种姿势

java 多线程很常见，如何使用多线程，如何创建线程，java 中有三种方式：

通过继承Thread接口

通过实现Runnable接口

通过实现Callable接口

启动上面三个线程

上面三种方式更推荐通过实现 Runnable 接口和实现 Callable接口 ，因为面向接口编程拓展性更好，而且可以防止 java 单继承的限制。

线程类型的简单说明

java 中线程一共有两种类型：守护线程（ daemon thread ）和用户线程（ user thread ），又叫非守护线程

守护线程

可以通过 thread.setDaemon(true) 方法设置线程是否为守护线程， thread.setDaemon(true) 必须在 thread.start() 之前设置，否则会抛出一个 IllegalThreadStateException 异常。在守护线程中开启的新线程也将是守护线程。守护线程顾名思义是用来守护的，是给所有得非守护进程提供服务的，所以在 jvm 执行完所有的非守护进程之后， jvm 就会停止，守护线程也不会再运行，最典型的守护线程就是 java 的垃圾回收机制 ( GC )。

非守护线程

java 线程默认设置是非守护线程 thread.setDaemon(false) 。当主线程运行完之后，只要主线程里面有非守护线程 jvm 就不会退出，直到所有的非守护线程执行完之后 jvm 才会退出。

总结：如果把一个线程设置成守护线程，则 jvm 的退出就不会关心当前线程的执行状态。

线程池的使用

上面代码中可以直接新起线程，如果 100 个并发同时访问主线程也就是短时间就启动了 200 个线程，200 个线程同时工作，逻辑上是没有任何问题的，但是这样做对系统资源的开销很大。基于这样的考虑，就要考虑启用线程池，线程池里有很多可用线程资源，如果需要就直接从线程池里拿就是。当不用的时候，线程池会自动帮我们管理。

所以使用线程池主要有以下两个好处：

减少在创建和销毁线程上所花的时间以及系统资源的开销
如不使用线程池，有可能造成系统创建大量线程而导致消耗完系统内存。

自定义线程池

定义单例线程池：

创建线程池的主要参数说明:

corePoolSize（int） ：线程池中保持的线程数量，包括空闲线程在内。也就是线程池释放的最小线程数量界限。
maximumPoolSize（int） : 线程池中嫩容纳最大线程数量。
keepAliveTime(long) : 空闲线程保持在线程池中的时间，当线程池中线程数量大于 corePoolSize 的时候。
unit(TimeUnit枚举类) : 上面参数时间的单位，可以是分钟，秒，毫秒等等。
workQueue（BlockingQueue） : 任务队列，当线程任务提交到线程池以后，首先放入队列中，然后线程池按照该任务队列依次执行相应的任务。可以使用的 workQueue 有很多，比如：LinkedBlockingQueue 等等。
threadFactory(ThreadFactory类) : 新线程产生工厂类。
handler（RejectedExecutionHandler类） : 当提交线程拒绝执行、异常的时候，处理异常的类。该类取值如下：(注意都是内部类)

ThreadPoolExecutor.AbortPolicy : 丢弃任务并抛出RejectedExecutionException 异常。

ThreadPoolExecutor.DiscardPolicy ：也是丢弃任务，但是不抛出异常。

ThreadPoolExecutor.DiscardOldestPolicy ：丢弃队列最前面的任务，然后重新尝试执行任务，重复此过程。

ThreadPoolExecutor.CallerRunsPolicy ：由调用线程处理该任务。

获取线程池并添加任务:

JDK 提供的常用线程池

java 提供了几种常用的线程池，可以快捷的供程序员使用

newFixedThreadPool 创建固定大小数量线程池，数量通过传入的参数决定。
newSingleThreadExecutor 创建一个线程容量的线程池，所有的线程依次执行，相当于创建固定数量为 1 的线程池。
newCachedThreadPool 创建可缓存的线程池，没有最大线程限制（实际上是 Integer.MAX_VALUE）。如果用空闲线程等待时间超过一分钟，就关闭该线程。
newScheduledThreadPool 创建计划 (延迟) 任务线程池, 线程池中的线程可以让其在特定的延迟时间之后执行，也可以以固定的时间重复执行（周期性执行）。相当于以前的 Timer 类的使用。
newSingleThreadScheduledExecutor 创建单线程池延迟任务，创建一个线程容量的计划任务。