Java的线程池饱、拒绝策略与异常处理机制案例分析

这篇文章主要讲解了"Java的线程池饱、拒绝策略与异常处理机制案例分析"，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习"Java的线程池饱、拒绝策略与异常处理机制案例分析"吧！

public ThreadPoolExecutor(int corePoolSize,                              int maximumPoolSize,                              long keepAliveTime,                              TimeUnit unit,                              BlockingQueue workQueue,                              ThreadFactory threadFactory,                              RejectedExecutionHandler handler) {       ...    }

线程饱和策略

1. 什么时候会饱和？

当核心线程corePoolSize满且阻塞队列也满时才会判断当前线程数是否小于最大线程数，并决定是否创建新线程，如果创建的线程总数大于maximumPoolSize的时候，就会触发RejectedExecetionHandler。

2.饱和策略有哪些？

JDK主要提供了4种饱和策略供选择。4种策略都做为静态内部类在ThreadPoolExcutor中进行实现。

AbortPolicy中止策略、DiscardPolicy抛弃策略、DiscardOldestPolicy抛弃旧任务策略、CallerRunsPolicy调用者运行

ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
ThreadPoolExecutor.DiscardPolicy：也是丢弃任务，但是不抛出异常。
ThreadPoolExecutor.DiscardOldestPolicy：丢弃队列最前面的任务，然后重新尝试执行任务（重复此过程）
ThreadPoolExecutor.CallerRunsPolicy：由调用线程处理该任务

3.JUC封装的4种线程池

newCachedThreadPool、newFixedThreadPool、newScheduledThreadPool、newSingleThreadExecutor

线程异常处理

先说结论：

1. runnable里面的 run 函数里面的逻辑必须 try...catch

//如果用的是submit,如果这里不加try catch 会导致异常被"吃掉" PULL_TASK_EXECUTOR.execute(new Runnable() {            @Override public void run() {                try{                                    }catch (Exception e){                                    }            }        });

意思就是说二者最大的区别就是异常处理上，在execute的时候，如果你没有实现一个handler，那么他就使用默认的handler来处理异常，你要是实现了一个handler

他就会使用的实例化的handler，但是对于submit来说，异常是绑定到Future上了，但是调用future.get()的时候，这些异常才会给你抛出来，意味着你自己定义的handler

其实是无效的

public static void main(String[] args) {        System.out.println("start");        try{             Executors.ASYNC_SERVICE_EXECUTOR.submit(() -> {                System.out.println("task start...");                Object obj = null;                String str = obj.toString();                System.out.println("str=");            });            System.out.println("end");        }catch(Exception e){            log.error(e.getMessage());        }    }

2. 线程直接重写整个方法

       //如果是线程模式       Thread t = new Thread();       t.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {            public void uncaughtException(Thread t, Throwable e) {              LOGGER.error(t + " throws exception: " + e);           }        });                //如果是线程池的模式:        ExecutorService threadPool = Executors.newFixedThreadPool(1, r -> {            Thread t = new Thread(r);            t.setUncaughtExceptionHandler(                (t1, e) -> LOGGER.error(t1 + " throws exception: " + e));            return t;        });

感谢各位的阅读，以上就是"Java的线程池饱、拒绝策略与异常处理机制案例分析"的内容了，经过本文的学习后，相信大家对Java的线程池饱、拒绝策略与异常处理机制案例分析这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是，小编将为大家推送更多相关知识点的文章，欢迎关注！