亚洲精品久久久中文字幕-亚洲精品久久片久久-亚洲精品久久青草-亚洲精品久久婷婷爱久久婷婷-亚洲精品久久午夜香蕉

您的位置:首頁技術文章
文章詳情頁

java定時任務實現(xiàn)的4種方式小結

瀏覽:20日期:2022-08-23 14:21:49

1. java自帶的Timer

Timer timer = new Timer(); timer.schedule(new TimerTask() { @Override public void run() {System.out.println('Time’s up!'); } },3*1000,1000);

2.ScheduledThreadPool-線程池

ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(2); scheduledThreadPool.scheduleAtFixedRate(new Runnable() { @Override public void run() {System.out.println('========================='); } }, 1000, 2000, TimeUnit.MILLISECONDS); scheduledThreadPool.scheduleAtFixedRate(new Runnable() { @Override public void run() {System.out.println(System.currentTimeMillis()+'<><>'+System.nanoTime()); } }, 1000, 2000, TimeUnit.MILLISECONDS);

3.使用注解的形式:@Scheduled

@Componentpublic class SpringScheduled { @Scheduled(initialDelay = 2000,fixedDelay = 5000) public void doSomething() { System.out.println('Spring自帶的Scheduled執(zhí)行了======================='); }} //下面是開啟@SpringBootApplication@EnableSchedulingpublic class DemoApplication { public static void main(String[] args) throws InterruptedException { SpringApplication application = new SpringApplication(DemoApplication.class); application.addListeners(new ContextRefreshedEventListener()); application.run(args); }}

4.使用Quartz定時任務調(diào)度器

配置

@Configurationpublic class QuartzConfig { @Resource private ScheduleTask scheduleTask; /** * 配置定時任務1 * @return */ @Bean(name='firstJobDetail') public MethodInvokingJobDetailFactoryBean firstJobDetail(){ MethodInvokingJobDetailFactoryBean method = new MethodInvokingJobDetailFactoryBean(); // 為需要執(zhí)行的實體類對應的對象 method.setTargetObject(scheduleTask); // 需要執(zhí)行的方法 method.setTargetMethod('test'); // 是否并發(fā)執(zhí)行 method.setConcurrent(false); return method; } /** * 配置觸發(fā)器1 * @param firstJobDetail * @return */ @Bean(name='firstTrigger') public SimpleTriggerFactoryBean firstTrigger(JobDetail firstJobDetail){ SimpleTriggerFactoryBean simpleBean = new SimpleTriggerFactoryBean(); simpleBean.setJobDetail(firstJobDetail); // 設置任務啟動延遲 simpleBean.setStartDelay(1000); // 每1秒執(zhí)行一次 simpleBean.setRepeatInterval(1000); //設置重復計數(shù) //simpleBean.setRepeatCount(0); return simpleBean; } /** * 配置Scheduler */ @Bean(name = 'scheduler') public SchedulerFactoryBean schedulerFactoryBean(Trigger firstTrigger){ SchedulerFactoryBean factoryBean = new SchedulerFactoryBean(); factoryBean.setTriggers(firstTrigger); return factoryBean; } }

要執(zhí)行的任務

@Componentpublic class ScheduleTask { public void test() { System.out.println('===================================='); } }

總結:

還有其他方式可以實現(xiàn)定時任務的方式,可以貼出來,討論討

補充知識:SpringBoot定時任務簡單使用和自定義開啟關閉修改周期

一、簡單使用

1.pom加入基本springboot基本的starter即可

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <optional>true</optional> </dependency>

2.@Scheduled 參數(shù)可以接受兩種定時的設置,一種是我們常用的cron='*/6 * * * * ?',一種是 fixedRate = 6000,兩種都表示每隔六秒打印一下內(nèi)容。

fixedRate 說明

@Scheduled(fixedRate = 6000) :上一次開始執(zhí)行時間點之后6秒再執(zhí)行

@Scheduled(fixedDelay = 6000) :上一次執(zhí)行完畢時間點之后6秒再執(zhí)行

@Scheduled(initialDelay=1000, fixedRate=6000) :第一次延遲1秒后執(zhí)行,之后按fixedRate的規(guī)則每6秒執(zhí)行一次

@Componentpublic class TimingTask { private static final SimpleDateFormat dateFormat = new SimpleDateFormat('HH:mm:ss'); @Scheduled(cron='*/6 * * * * ?') private void process(){ System.out.println('this is scheduler task runing '+new Date()); } @Scheduled(fixedRate = 6000) public void reportCurrentTime() { System.out.println('現(xiàn)在時間:' + dateFormat.format(new Date())); }}

3.啟動類加上@EnableScheduling注解。

@SpringBootApplication(exclude = MongoAutoConfiguration.class)@EnableSchedulingpublic class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } }

4.運行結果

this is scheduler task runing Thu Jul 18 10:59:06 CST 2019現(xiàn)在時間:10:59:10this is scheduler task runing Thu Jul 18 10:59:12 CST 2019現(xiàn)在時間:10:59:16this is scheduler task runing Thu Jul 18 10:59:18 CST 2019現(xiàn)在時間:10:59:22this is scheduler task runing Thu Jul 18 10:59:24 CST 2019現(xiàn)在時間:10:59:28

以上就是定時任務的簡單使用。但是有時候,定時任務需要關閉,和開啟,或者修改定時任務的運行周期,可以使用下面的方式實現(xiàn).

二、高級使用,自定義定時任務,關閉,開啟,修改周期

1.說明

ThreadPoolTaskScheduler:線程池任務調(diào)度類,能夠開啟線程池進行任務調(diào)度。

ThreadPoolTaskScheduler.schedule()方法會創(chuàng)建一個定時計劃ScheduledFuture,在這個方法需要添加兩個參數(shù),Runnable(線程接口類) 和CronTrigger(定時任務觸發(fā)器)

在ScheduledFuture中有一個cancel可以停止定時任務。

@RestController@RequestMapping('/time')public class DynamicScheduledTask { private static String DEFAULT_CRON = '0/5 * * * * ?'; @Autowired private ThreadPoolTaskScheduler threadPoolTaskScheduler; private ScheduledFuture<?> future; @Bean public ThreadPoolTaskScheduler threadPoolTaskScheduler() { return new ThreadPoolTaskScheduler(); } @RequestMapping('/{id}/startCron') public String startCron(@PathVariable('id') String id) { future = threadPoolTaskScheduler.schedule(new MyRunnable(), new CronTrigger(DEFAULT_CRON)); System.out.println('DynamicTask.startCron()'+'------'+id); return 'startCron'; } @RequestMapping('/{id}/stopCron') public String stopCron(@PathVariable('id') String id) { if (future != null) { future.cancel(true); } System.out.println('DynamicTask.stopCron()'+'------'+id); return 'stopCron'; } @RequestMapping('/{id}/changeCron10') public String startCron10(@PathVariable('id') String id) { stopCron(id);// 先停止,在開啟. future = threadPoolTaskScheduler.schedule(new MyRunnable(), new CronTrigger('*/10 * * * * *')); System.out.println('DynamicTask.startCron10()'+'------'+id); return 'changeCron10'; } private class MyRunnable implements Runnable { @Override public void run() { System.out.println('DynamicTask.MyRunnable.run(),' + new Date()); } }}

如果想,做成后臺管理,添加刪除定時任務,可以將定時任務,持久化到數(shù)據(jù)庫,自定義開發(fā)MyRunnable定時任務的業(yè)務類,也持久化到數(shù)據(jù)庫,然后,threadPoolTaskScheduler.schedule要的業(yè)務類,可通過反射實例化出來,傳遞,然后,通過url,id參數(shù),來開啟,關閉,刪除,對應的定時任務。

以上這篇java定時任務實現(xiàn)的4種方式小結就是小編分享給大家的全部內(nèi)容了,希望能給大家一個參考,也希望大家多多支持好吧啦網(wǎng)。

標簽: Java
相關文章:
主站蜘蛛池模板: 一级特黄aaa大片在线观看视频 | 日韩中文在线观看 | 国产午夜精品片一区二区三区 | 精品在线一区 | 美女亚洲精品一区 | 成人久久久| 韩国无遮挡三级伦在线大全 | 成人国产精品一级毛片天堂 | 欧美激情艳三级 | 成人高清在线视频 | chinese国产videoxx实拍 | 国产在线短视频 | 一级做a爰全过程免费视频 一级做a爰性色毛片 | 国产精品久久久久久久毛片 | 好看的亚洲视频 | 一级毛片黄色片 | 亚洲国产精品线在线观看 | 国美女福利视频午夜精品 | 欧美日韩国产一区 | 日本免费毛片在线高清看 | 国产区精品视频 | 二级黄绝大片中国免费视频0 | 国产91精品不卡在线 | 精品不卡 | 99国产精品免费视频观看 | 亚洲精品亚洲人成在线观看麻豆 | 欧洲美女大片免费播放器视频 | 国产一区二区三区在线观看视频 | 久久er热在这里只有精品66 | 豆国产97在线 | 中国 | 国产精品日韩欧美亚洲另类 | 日韩欧美在线视频观看 | 欧美日韩中文字幕在线视频 | 日韩精品中文字幕在线 | 日本亚洲精品成人 | 99精品免费在线 | 久久r精品 | 欧美天天射 | 免费国产片| 天天综合网天天综合色不卡 | 亚洲一区二区三 |