共计 2221 个字符,预计需要花费 6 分钟才能阅读完成。
导读 | 这篇文章主要介绍了 springBoot @Scheduled 实现多个任务同时开始执行,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教 |
@Scheduled 多个任务同时开始执行
只需在 springBoot 启动类上添加
如下代码即可:
@Bean
public TaskScheduler taskScheduler() {ThreadPoolTaskScheduler taskExecutor = new ThreadPoolTaskScheduler();
taskExecutor.setPoolSize(50);
return taskExecutor;
}
@Scheduled 多定时任务,重叠执行
@Scheduled 如果有两个定时任务
定时任务重复时,只有一个可以执行。
如下
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
@Component
public class MyScheduled {@Scheduled(cron = "0/5 * * * * ?")
public void execute1(){String curName = Thread.currentThread().getName() ;
System.out.println("当前时间:"+LocalDateTime.now()+"任务 execute1 对应的线程名:"+curName);
try {Thread.sleep(1000);
} catch (Exception e) {e.printStackTrace();
}
}
@Scheduled(cron = "0/5 * * * * ?")
public void execute2(){String curName = Thread.currentThread().getName() ;
System.out.println("当前时间:"+LocalDateTime.now()+"任务 execute2 对应的线程名:"+curName);
try {Thread.sleep(1000);
} catch (InterruptedException e) {e.printStackTrace();
}
}
}
通过执行可以看到,打印线程名称为同一个。即如果不手动指定线程池,则默认启动单线程,进行执行定时任务。
如果想要多个定时任务重叠执行
需要手动指定线程池,如下
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
@Component
@EnableScheduling
public class MyScheduled {
@Bean
public TaskScheduler taskScheduler() {ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(50);
return taskScheduler;
}
@Scheduled(cron = "0/5 * * * * ?")
public void execute1(){String curName = Thread.currentThread().getName() ;
System.out.println("当前时间:"+LocalDateTime.now()+"任务 execute1 对应的线程名:"+curName);
try {Thread.sleep(1000);
} catch (Exception e) {e.printStackTrace();
}
}
@Scheduled(cron = "0/5 * * * * ?")
public void execute2(){String curName = Thread.currentThread().getName() ;
System.out.println("当前时间:"+LocalDateTime.now()+"任务 execute2 对应的线程名:"+curName);
try {Thread.sleep(1000);
} catch (InterruptedException e) {e.printStackTrace();
}
}
}
此时,多个定时任务,是不通的线程执行,同时,定时任务可以重叠执行。
正文完
星哥说事-微信公众号
![post-qrcode](https://www.xgss.net/wp-content/uploads/2023/07/二维码-微信公众号256x256.jpg)