ScheduledExecutorService延时线程池的简单使用

public class TimerTest {
  private static Logger logger = LoggerFactory.getLogger(TimerTest.class);
  public static void main(String[] args) {
    Timer timer = new Timer();
    timer.schedule(new TimerTask() {
      @Override
      public void run() {
        logger.info("线程启动2s后执行");
      }
    }, 2000);

    timer.scheduleAtFixedRate(new TimerTask() {
      @Override
      public void run() {
        logger.info("项目启动1s后执行，执行周期为2s");
      }
    }, 1000, 2000);
  }
}

public class ScheduledThreadPoolTest {
  private static Logger logger = LoggerFactory.getLogger(ScheduledThreadPoolTest.class);

  public static void main(String[] args) throws ExecutionException, InterruptedException {

    ScheduledExecutorService scheduled = new ScheduledThreadPoolExecutor(1);
    // ①schedule方法之callable接口
    ScheduledFuture<String> ret = scheduled.schedule(new Callable<String>() {
      @Override
      public String call() throws Exception {
        return "callable接口返回";
      }
    }, 1, TimeUnit.SECONDS);
    logger.info(ret.get());


    // ②schedule方法之runable接口
    scheduled.schedule(new Runnable() {
      @Override
      public void run() {
        logger.info("线程启动后1s再执行");

      }
    }, 1, TimeUnit.SECONDS);

    
    // ③周期性执行，来不及消费的会存在队列中
    scheduled.scheduleAtFixedRate(() -> {
      // 每2s产生一个任务，如果任务来不及消费，会存储在对应的队列中
      logger.info("在线程启动的1s后执行，且随后周期执行的时间为2s");
      try {
        // 线程执行时间为3s：3<2，所以任务执行完了马上进行下一个任务
        TimeUnit.SECONDS.sleep(3);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }, 1, 2, TimeUnit.SECONDS);

    // ④周期性执行，来不及消费的阻塞，等消费完成
    scheduled.scheduleWithFixedDelay(() -> {
      try {
        // 任务间隔时间为5s：业务时间+周期时间
        TimeUnit.SECONDS.sleep(3);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      logger.info("线程启动后1s再执行，且随后的执行周期为2s。注意：这个2s是在前一个任务执行完成之后的2s，并不会堆积到队列中");
    }, 1, 2, TimeUnit.SECONDS);
  }
}

// 延时队列的构造方法
public ScheduledThreadPoolExecutor(int corePoolSize) {
    super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
          new DelayedWorkQueue());
}