云主机测评网云主机测评网云主机测评网

云主机测评网
www.yunzhuji.net

java线程池拒绝策略

Java线程池拒绝策略是指当任务数量超过线程池的处理能力时,线程池如何处理这些额外的任务,Java线程池提供了四种拒绝策略,分别是:

(图片来源网络,侵删)

1、AbortPolicy(默认策略)

2、CallerRunsPolicy

3、DiscardOldestPolicy

4、DiscardPolicy

下面是对这些策略的详细解释:

1. AbortPolicy(默认策略)

当线程池和队列都满了,无法处理新的任务时,AbortPolicy策略会抛出一个RejectedExecutionException异常,这是默认的拒绝策略。

2. CallerRunsPolicy

当线程池和队列都满了,无法处理新的任务时,CallerRunsPolicy策略会直接在调用者线程中执行这个任务,换句话说,它会将任务放回调用者的队列中,让调用者自己处理。

3. DiscardOldestPolicy

当线程池和队列都满了,无法处理新的任务时,DiscardOldestPolicy策略会丢弃队列中最旧的任务,然后将新任务加入队列。

4. DiscardPolicy

当线程池和队列都满了,无法处理新的任务时,DiscardPolicy策略会直接丢弃新任务,不做任何处理。

下面是一个简单的示例代码,展示了如何使用不同的拒绝策略:

import java.util.concurrent.*;
public class ThreadPoolDemo {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 4, 60, TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(2), new ThreadPoolExecutor.AbortPolicy());
        // 提交任务
        for (int i = 0; i < 10; i++) {
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println("Task executed by: " + Thread.currentThread().getName());
                }
            });
        }
        // 关闭线程池
        executor.shutdown();
    }
}

在上面的代码中,我们创建了一个固定大小为2的线程池,队列大小为2,拒绝策略为AbortPolicy,然后提交了10个任务,由于线程池和队列的大小限制,最后会有8个任务被拒绝。

打赏
版权声明:主机测评不销售、不代购、不提供任何支持,仅分享信息/测评(有时效性),自行辨别,请遵纪守法文明上网。
文章名称:《java线程池拒绝策略》
文章链接:https://www.yunzhuji.net/jishujiaocheng/67305.html

评论

  • 验证码