jdk线程池的四种拒绝策略

Posted 2022-08-09 好大的月亮

概述

ThreadPoolExecutor中有四种处理策略。

1.CallerRunsPolicy：当核心线程上限 && 缓冲队列满了，后续再有任务提交过来就让当前主线程去处理这个任务。
2. AbortPolicy：当核心线程上限 && 缓冲队列满了，后续再有任务提交过来就抛异常给主线程。
3. DiscardPolicy：当核心线程上限 && 缓冲队列满了，后续再有任务提交过来就将此任务直接丢弃。
4. DiscardOldestPolicy：当核心线程上限 && 缓冲队列满了，后续再有任务提交过来，会将缓冲队列队首的任务移除，然后在队末加入新任务。

代码demo

demo中DiscardPolicy策略由于是直接丢弃,没啥好展示，有兴趣可以改下策略查看打印结果

public class SendNoticeTask implements Runnable


    Logger log = LoggerFactory.getLogger(SendNoticeTask.class);


    private int count;

    public SendNoticeTask(int count) 
        this.count = count;
    

    @Override
    public void run() 
        String name = Thread.currentThread().getName();
        log.info( name + " start to send" + count);

        try 
            Thread.sleep(10000);
         catch (InterruptedException e) 
            e.printStackTrace();
        

        log.info("finish " + name);

    





/**
  * 有界队列默认异常处理
  * 当核心线程上线 && 缓冲队列满了，后续再有任务提交过来就抛异常给主线程
  */
 public static void workQueueDefaultReject() 
     ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(2, 4, 1000, TimeUnit.MICROSECONDS, workQueue);


     for (int i = 0; i < 10; i++) 

         SendNoticeTask task = new SendNoticeTask(i);
         threadPoolExecutor.execute(task);
     

     log.info("主线程结束");
 


 /**
  * 有界队列拒绝策略 -> 由调用线程处理任务
  * 当核心线程上线 && 缓冲队列满了，后续再有任务提交过来就让当前主线程去处理这个任务
  */
 public static void callerRunsPolicy() 

     ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
             2,
             4,
             1000,
             TimeUnit.MICROSECONDS,
             workQueue,
             new ThreadPoolExecutor.CallerRunsPolicy()
     );


     for (int i = 0; i < 10; i++) 

         SendNoticeTask task = new SendNoticeTask(i);
         threadPoolExecutor.execute(task);
     

     log.info("主线程结束");
 




/**
  * 有界队列拒绝策略 -> 由调用线程处理任务
  * 当核心线程上线 && 缓冲队列满了，后续再有任务提交过来就,会将缓冲队列队首的任务移除，然后在队末加入新任务
  */
 public static void discardOldestPolicy() 
     ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
             2,
             4,
             1000,
             TimeUnit.MICROSECONDS,
             workQueue,
             new ThreadPoolExecutor.DiscardOldestPolicy()
     );


     for (int i = 0; i < 10; i++) 

         SendNoticeTask task = new SendNoticeTask(i);
         threadPoolExecutor.execute(task);
     

     log.info("主线程结束");