乐趣区

关于java:面试突击30线程池是如何执行的拒绝策略有哪些

聊到线程池就肯定会聊到线程池的执行流程,也就是当有一个工作进入线程池之后,线程池是如何执行的?咱们明天就来聊聊这个话题。线程池是如何执行的?线程池的回绝策略有哪些?

线程池执行流程

想要真正的理解线程池的执行流程,就得先从线程池的执行办法 execute() 说起,execute() 实现源码如下:

public void execute(Runnable command) {if (command == null)
        throw new NullPointerException();
    int c = ctl.get();
    // 当前工作的线程数小于外围线程数
    if (workerCountOf(c) < corePoolSize) {
        // 创立新的线程执行此工作
        if (addWorker(command, true))
            return;
        c = ctl.get();}
    // 查看线程池是否处于运行状态,如果是则把工作增加到队列
    if (isRunning(c) && workQueue.offer(command)) {int recheck = ctl.get();
        // 再次检线程池是否处于运行状态,避免在第一次校验通过后线程池敞开
        // 如果是非运行状态,则将刚退出队列的工作移除
        if (! isRunning(recheck) && remove(command))
            reject(command);
        // 如果线程池的线程数为 0 时(当 corePoolSize 设置为 0 时会产生)else if (workerCountOf(recheck) == 0)
            addWorker(null, false); // 新建线程执行工作
    }
    // 外围线程都在忙且队列都已爆满,尝试新启动一个线程执行失败
    else if (!addWorker(command, false)) 
        // 执行回绝策略
        reject(command);
}

从上述源码咱们能够看出,当工作来了之后, 线程池的执行流程是:先判断以后线程数是否大于外围线程数?如果后果为 false,则新建线程并执行工作;如果后果为 true,则判断工作队列是否已满?如果后果为 false,则把工作增加到工作队列中期待线程执行,否则则判断以后线程数量是否超过最大线程数?如果后果为 false,则新建线程执行此工作,否则将执行线程池的回绝策略 ,如下图所示:

线程池回绝策略

当工作过多且线程池的工作队列已满时,此时就会执行线程池的回绝策略,线程池的回绝策略默认有以下 4 种:

  1. AbortPolicy:停止策略,线程池会抛出异样并中止执行此工作;
  2. CallerRunsPolicy:把工作交给增加此工作的(main)线程来执行;
  3. DiscardPolicy:疏忽此工作,疏忽最新的一个工作;
  4. DiscardOldestPolicy:疏忽最早的工作,最先退出队列的工作。

默认的回绝策略为 AbortPolicy 停止策略。

DiscardPolicy 回绝策略

接下来咱们以 DiscardPolicy 疏忽此工作,疏忽最新的一个工作为例,演示一下回绝策略的具体应用,实现代码如下:

public static void main(String[] args) {
    // 工作的具体方法
    Runnable runnable = new Runnable() {
        @Override
        public void run() {System.out.println("当前任务被执行, 执行工夫:" + new Date() +
                               "执行线程:" + Thread.currentThread().getName());
            try {
                // 期待 1s
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {e.printStackTrace();
            }
        }
    };
    // 创立线程, 线程的工作队列的长度为 1
    ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1,
                                                           100, TimeUnit.SECONDS, new LinkedBlockingQueue<>(1),
                                                           new ThreadPoolExecutor.DiscardPolicy());
    // 增加并执行 4 个工作
    threadPool.execute(runnable);
    threadPool.execute(runnable);
    threadPool.execute(runnable);
    threadPool.execute(runnable);
    // 线程池执行完工作,敞开线程池
    threadPool.shutdown();}

以上程序的执行后果如下:

从上述执行后果能够看出,给线程池增加了 4 个工作,而线程池只执行了 2 个工作就完结了,其余两个工作执行了回绝策略 DiscardPolicy 被忽略了,这就是回绝策略的作用。

AbortPolicy 回绝策略

为了和 DiscardPolicy 回绝策略比照,咱们来演示一下 JDK 默认的回绝策略 AbortPolicy 停止策略,线程池会抛出异样并中止执行此工作,示例代码如下:

public static void main(String[] args) {
    // 工作的具体方法
    Runnable runnable = new Runnable() {
        @Override
        public void run() {System.out.println("当前任务被执行, 执行工夫:" + new Date() +
                               "执行线程:" + Thread.currentThread().getName());
            try {
                // 期待 1s
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {e.printStackTrace();
            }
        }
    };
    // 创立线程, 线程的工作队列的长度为 1
    ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1,
                                                           100, TimeUnit.SECONDS, new LinkedBlockingQueue<>(1),
                                                           new ThreadPoolExecutor.AbortPolicy()); // 显式指定回绝策略,也能够疏忽此设置,它为默认回绝策略
    // 增加并执行 4 个工作
    threadPool.execute(runnable);
    threadPool.execute(runnable);
    threadPool.execute(runnable);
    threadPool.execute(runnable);
    // 线程池执行完工作,敞开线程池
    threadPool.shutdown();}

以上程序的执行后果如下:

从后果能够看出,给线程池增加了 4 个工作,线程池失常执行了 2 个工作,其余两个工作执行了停止策略,并抛出了拒绝执行的异样 RejectedExecutionException。

自定义回绝策略

当然除了 JDK 提供的四种回绝策略之外,咱们还能够实现通过 new RejectedExecutionHandler,并重写 rejectedExecution 办法来实现自定义回绝策略,实现代码如下:

public static void main(String[] args) {
    // 工作的具体方法
    Runnable runnable = new Runnable() {
        @Override
        public void run() {System.out.println("当前任务被执行, 执行工夫:" + new Date() +
                               "执行线程:" + Thread.currentThread().getName());
            try {
                // 期待 1s
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {e.printStackTrace();
            }
        }
    };
    // 创立线程, 线程的工作队列的长度为 1
    ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1,
                                                           100, TimeUnit.SECONDS, new LinkedBlockingQueue<>(1),
                                                           new RejectedExecutionHandler() {
                                                               @Override
                                                               public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                                                                   // 执行自定义回绝策略的相干操作
                                                                   System.out.println("我是自定义回绝策略~");
                                                               }
                                                           });
    // 增加并执行 4 个工作
    threadPool.execute(runnable);
    threadPool.execute(runnable);
    threadPool.execute(runnable);
    threadPool.execute(runnable);
}

以上程序的执行后果如下:

总结

线程池的执行流程有 3 个重要的判断点(判断程序顺次往后):判断以后线程数和外围线程数、判断当前任务队列是否已满、判断以后线程数是否已达到最大线程数。如果通过以上 3 个判断,失去的后果都会 true,则会执行线程池的回绝策略。JDK 提供了 4 种回绝策略,咱们还能够通过 new RejectedExecutionHandler 并重写 rejectedExecution 办法来实现自定义回绝策略。

是非审之于己,毁誉听之于人,得失安之于数。

公众号:Java 面试真题解析

面试合集:https://gitee.com/mydb/interview

退出移动版