java计算时间间隔-间隔天数计算计算

前言

大多数技术介绍都比较简单。 复制别人的代码，删、删、改、改，基本可以实现一个功能。 查一个API，大概能知道几个功能是怎么实现的。 但是，如果你对一项技术有足够深入的了解，你需要知道一项技术的优缺点，以及它存在的问题。 这些都需要大量的时间和思考。 只有足够了解小草的力量，才能在危险面前不惧怕，才能在强如风的虫子来临时微笑。 绝对不掉！

定时任务调度注解@Scheduled

这个注解是spring定时任务中的主角，包含了几种类型

@Scheduled(fixedDelay = 2000) 
@Scheduled(fixedRate = 2000) 
@Scheduled(initialDelay = 1000, fixedDelay = 2000)   
@Scheduled(cron = "*/5 * * * * *")
复制代码

用过定时任务的童鞋应该都用过上面的集中注解，现在简单介绍一下

 @Scheduled(fixedDelay = 2000)   等上一个任务执行完2s后执行
 @Scheduled(fixedRate = 2000)    从上一个任务开始后的2s，下一个任务进行执行
 @Scheduled(initialDelay = 1000, fixedDelay = 2000)  方法不会立即执行 要等initialDelay后再执行
 @Scheduled(cron = "*/5 * * * * *")   选定时间进行执行
复制代码

我们重点看一下@Scheduled(fixedRate = 2000) 他的描述是上一个任务开始后2s，下一个任务才会执行，但是是不是真的呢java计算时间间隔，我们来验证一下

创建定时任务类和定时任务方法 /** * Spring的定时任务*/ @Component @EnableScheduling public class ScheduleJob { @Autowired private TaskService taskService; /** * 和上一个方法的启动和下一个方法的启动 固定速率为2s * 这种方法适用于独立的任务 */ @Scheduled(fixedRate = 2000) public void fixedRateTaskR() { taskService. sayHello("固定利率"); } 复制代码创建一个接口 public interface TaskService { void sayHello( String type); } 复制代码具体实现类@Override public void sayHello(String type) { try { long startTime = System.currentTimeMillis() / 1000; System.out.println(type + " => " + startTime + " - 任务开始"); System.out.println(type + " => " + "任务执行"); 线程.睡眠(5000); } catch (Exception e) { e.printStackTrace(); } }

我正在执行的任务线程正在执行延迟操作。 每次执行都会休眠 5s。 如果每两秒执行一次，那么该方法的间隔时间将被打印为2s。 让我们执行它并查看结果

fixedRate => 1632646194 - 任务开始
fixedRate => 任务执行中
fixedRate => 1632646197 - 任务开始
fixedRate => 任务执行中
fixedRate => 1632646199 - 任务开始
复制代码

结果很明显是每隔5s执行一次，而不是2s，也就是说下一个任务要等到上一个任务执行完才会执行，哇！ 既然有这样的问题，如果我不用等到最后一个任务执行完毕，只想2s执行一次，行不行！ 当然，我可以！ 现在做！

2.使用@Async实现异步调度，建立spring线程池

/**
 * @author 千云

 * @Description spring线程池配置类
 * @Date 2021/8/3
 */
@EnableAsync
@Configuration
public class SendMsgThreadPoolConfig {
    @Bean("schedule")
    public Executor schduleTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(2);
        executor.setMaxPoolSize(2);
        executor.setQueueCapacity(100);

        executor.setKeepAliveSeconds(60);
        executor.setThreadNamePrefix("schedule-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
    }
}
复制代码

为异步调度方法指定线程池

   @Override
    @Async("schedule")
    public void sayHello(String type) {
        try {
            long startTime = System.currentTimeMillis() / 1000;

            System.out.println(type + " => " + startTime + " - 任务开始");
            System.out.println(type + " => " + "任务执行中");
            Thread.sleep(5000);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
复制代码

让我们再次执行以下命令以查看输出

fixedRate => 任务执行中
fixedRate => 1632646666 - 任务开始

fixedRate => 任务执行中
fixedRate => 1632646668 - 任务开始
fixedRate => 任务执行中
fixedRate => 1632646671 - 任务开始
fixedRate => 任务执行中
fixedRate => 1632646673 - 任务开始
复制代码

看控制台，当前时间间隔是2s，2s，3s，小伙伴们可能会觉得奇怪，为什么会有3s的间隔，这是怎么回事，这是因为我们创建的线程池，我们的线程都是核心线程并且池中最大线程数为2，每两秒执行一次，前4s的两个线程都被占满了。 第三个任务执行的时候要等待，因为第一个任务线程的休眠时间是5s，那么第三个任务线程等待1s后就会执行，这就是间隔3s的原因java计算时间间隔，验证一下，并将线程数更改为 3。查看控制台输出

fixedRate => 1632647147 - 任务开始
fixedRate => 任务执行中
fixedRate => 1632647149 - 任务开始
fixedRate => 任务执行中
fixedRate => 1632647151 - 任务开始
fixedRate => 任务执行中
复制代码

这是执行时间间隔为2s。