spring schedule 多线程,@scheduled是否为多线程执行

　　00-1010 1.前言2。关于计划任务调度的说明@Scheduled 3。使用@Async实现异步调度，建立spring线程池。为异步调度方法指定线程池。

　　00-1010技术的介绍大多比较简单。复制别人的代码，删改改，基本就能实现一个功能。看一个API，大概就知道怎么实现几个功能了。但是，如果你足够了解一项技术，你就必须知道它的优缺点，以及它存在的问题。这些都需要大量的时间和思考。只有懂得足够多，才能临危不惧。

目录

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

　　@ Scheduled(fixed delay=2000)@ Scheduled(fixed rate=2000)@ Scheduled(initial delay=1000，fixed delay=2000)@ Scheduled(cron= */5 * * * * * )使用过定时任务的童鞋应该都是使用过以上集中注解，现在简单介绍一下

　　@Scheduled(fixedDelay=2000)等待2s后执行最后一个任务@Scheduled(fixedRate=2000)。从上一个任务开始后2s开始，将执行下一个任务@Scheduled(initialDelay=1000，fixedDelay=2000)方法不会立即执行。在执行@ scheduled (cron= */5 * * * * )之前等待initialDelay。选择执行时间。让我们来关注一下@Scheduled(fixedRate=2000)。他的指令是从上一个任务后2s开始执行下一个任务，但真的是这样吗？我们来验证一下。

　　创建一个定时任务类，及定时任务方法：

　　/* * * Spring的计划任务*/@ component @ enableSchedulingPublic类计划作业{ @ auto wired private task service task service；/* * *且上一个方法的开始和下一个方法的开始都固定为2s *此方法适用于独立任务*/@ scheduled(固定费率=2000)public void fixed rate taskr(){ taskservice . say hello(固定费率)；}创建接口：

　　公共接口task service { void say hello(String类型)；}具体实现类：

　　@ Override public void say hello(String type){ try { long start time=system . current time millis()/1000；system . out . println(type = start time -task start )；System.out.println(type= 任务正在进行)；thread . sleep(5000)；} catch(Exception e){ e . printstacktrace()；}}我在延迟任务线程的执行，每次执行它都会休眠5s。如果我每两秒执行一次，那么该方法的间隔时间将被打印为2s。当我们执行它的时候，

　　看下结果：

　　fixed rate=1632646194-任务开始固定速率=任务执行固定速率=1632646197-任务开始固定速率=任务执行固定速率=1632646199-任务开始

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

　　="maodian">

三、使用@Async实现异步调度

建立spring线程池

/** * @Description spring线程池配置类 */@EnableAsync@Configurationpublic 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的原因，验证一下，将线程数修改为3个。

　　看下控制台输出：

fixedRate => 1632647147 - 任务开始fixedRate => 任务执行中fixedRate => 1632647149 - 任务开始fixedRate => 任务执行中fixedRate => 1632647151 - 任务开始fixedRate => 任务执行中

 

　　

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

　　到此这篇关于Spring多线程通过@Scheduled实现定时任务的文章就介绍到这了,更多相关Spring定时任务内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。