java线程池

1、

之前做异步的工具类，经常使用Executors.newSingleThreadExecutor()，但是这样做并不推荐：
阿里不允许使用 Executors 创建线程池！那怎么使用，怎么监控？
因为其默认为无界队列（无界队列也没有rejectHandler了），可能oom，但是之前做虽然是大量数据，但是有采样逻辑倒是也没有太大影响。【对于大量数据的场景，采样是一种非常常用的方法】。

2、

最好用自定义的线程池来做，在自定义的时候，需要确定几个参数：
（1）核心线程数/最大线程数
这个和该线程池所执行的任务有关系，比如db读写数据，调其他的dubbo接口等是io密集型的；一些计算量较大的任务（类似flink处理中大量数据转换的任务）是cpu密集型的。这个网上文章很多，怎么设置可以参考。
（2）keepAliveTime 空闲线程存活时间/时间单位
一个线程如果处于空闲状态，并且当前的线程数量大于corePoolSize，那么在指定时间后，这个空闲线程会被销毁，这里的指定时间由keepAliveTime来设定。
keepAliveTime的计量单位为毫秒级别。按照不同的任务场景设置，我经常设置为0。
（3）workQueue 工作队列
新任务被提交后，会先进入到此工作队列中，任务调度时再从队列中取出任务。jdk中提供了四种工作队列：
①ArrayBlockingQueue （常用，可以指定大小）
基于数组的有界阻塞队列，按FIFO排序。新任务进来后，会放到该队列的队尾，有界的数组可以防止资源耗尽问题。当线程池中线程数量达到corePoolSize后，再有新任务进来，则会将任务放入该队列的队尾，等待被调度。如果队列已经是满的，则创建一个新线程，如果线程数量已经达到maxPoolSize，则会执行拒绝策略。

②LinkedBlockingQuene
基于链表的无界阻塞队列（其实最大容量为Interger.MAX），按照FIFO排序。由于该队列的近似无界性，当线程池中线程数量达到corePoolSize后，再有新任务进来，会一直存入该队列，而基本不会去创建新线程直到maxPoolSize（很难达到Interger.MAX这个数），因此使用该工作队列时，参数maxPoolSize其实是不起作用的。

③SynchronousQuene（常用）
一个不缓存任务的阻塞队列，生产者放入一个任务必须等到消费者取出这个任务。也就是说新任务进来时，不会缓存，而是直接被调度执行该任务，如果没有可用线程，则创建新线程，如果线程数量达到maxPoolSize，则执行拒绝策略。

④PriorityBlockingQueue
具有优先级的无界阻塞队列，优先级通过参数Comparator实现。

（4）threadFactory 线程工厂

创建一个新线程时使用的工厂，可以用来设定线程名、是否为daemon线程等等。一般用defaultThreadFactory

（5）handler 拒绝策略
可以自定义，也可以使用已经够建好的几种策略。
自定义只要实现了他的接口就行：

new ThreadPoolExecutor(8, 16,
            0L, TimeUnit.MILLISECONDS,
            new SynchronousQueue<>(), Executors.defaultThreadFactory(), (r, executor) -> {
        log.info(xxxx)
        throw new RejectedExecutionException("自定义的handler");
    });
1
2
3
4
5
6

也可以根据执行拒绝策略的线程是否抛出异常来决定使用那个策略。比如不想抛出异常，则使用DiscardPolicy策略。

如果使用AbortPolicy，则会丢弃任务，并抛出RejectedExecutionException异常。

其他：
当一个线程池里面的线程异常后:

• 当执行方式是 execute 时,可以看到堆栈异常的输出。
• 当执行方式是 submit 时,堆栈异常没有输出。但是调用 Future.get()方法时，可以捕获到异常。不会影响线程池里面其他线程的正常执行。
• 线程池会把这个线程移除掉，并创建一个新的线程放到线程池中。

线程池异常相关

在平时写代码的时候，throw异常到上层函数，如果没有catch，线程还是会停止运行的；这里的线程池就是这样，会停止该线程并新起一个线程，可以在threadFactory线程工厂设置异常处理器：java线程/线程池异常处理机制
或：Java线程池系列–全局异常处理的方法(有实例)