Java定時任務

• JDK定時器Timer使用及原理分析
• • 小頂堆
  • 時間輪算法
  • Timer
• 定時任務線程池解析
• • Schedule
  • Leader-Follower模式
• 定時任務框架Quartz
• • quartz demo
  • JobDataMap
  • job并發(fā)及持久化
  • 觸發(fā)器
  • 調度器
  • 整合springboot

成都創(chuàng)新互聯(lián)公司主營嵊州網(wǎng)站建設的網(wǎng)絡公司,主營網(wǎng)站建設方案,app軟件定制開發(fā),嵊州h5微信小程序開發(fā)搭建,嵊州網(wǎng)站營銷推廣歡迎嵊州等地區(qū)企業(yè)咨詢JDK定時器Timer使用及原理分析 小頂堆

完全二叉樹：只有最后一層節(jié)點數(shù)不滿
堆：是一顆完全二叉樹，元素滿足每個節(jié)點的值都大于或者小于其父節(jié)點的值
數(shù)組存儲結構：
小頂堆：最上面的最小
更好的找到父節(jié)點是誰，除以2
插入元素、刪除元素

缺點：插入和刪除要移動比較全部的元素，需要耗費大量性能浪費
適合比較偏小量的

時間輪算法

鏈表或者數(shù)組實現(xiàn)時間輪：遍歷數(shù)組，每個下標放置一個鏈表，鏈表節(jié)點放置任務，遍歷到了就取出執(zhí)行
round型時間輪：任務上記錄一個round，遍歷到了就將round減一，為0時取出執(zhí)行
缺點：需要遍歷所有的任務，效率較低
分層時間輪：使用多個不同時間維度的輪。天輪記錄幾點執(zhí)行。月輪記錄幾號執(zhí)行。月輪遍歷到了。將任務取出放到天輪里面，即可實現(xiàn)幾號幾點執(zhí)行。

Timer

Timer：任務啟動：new（）、任務添加：.schedule()
小頂堆里面添加任務、從小頂堆里獲取最近的任務、獲取當前時間和這個任務下一次要執(zhí)行的時間，若、要把任務刪除掉重新入隊、預設的時間，任務真正執(zhí)行時間取決于上一個任務執(zhí)行完的時間
scheduleAtFixRate()：
TimerTask：寫業(yè)務邏輯、再啟動線程池去執(zhí)行
單線程：任務阻塞、任務超時

定時任務線程池解析 Schedule

ScheduledExecutorService scheduledThreadPool = Excutors.newScheduledThreadPool()
scheduleAtFixedRate

Leader-Follower模式

避免沒必要的喚醒和阻塞操作，更有效，更節(jié)省資源

定時任務框架Quartz quartz demo

Job：業(yè)務邏輯
-JobBuilder、JobDataMap
execute()

JobDetail：Job的包裝
JobBuilder.newJob().withIdentity().build()

Trigger：觸發(fā)器
-TriggerBuilder 、JobDataMap、ScheduleBuilder simple、
.startNow()
.withSchedule()

Scheduler：按照觸發(fā)器定義的時間去執(zhí)行Job
-SchedulerFactory：StdSchedulerFactory properties配置
.shcheduleJob(jobDetail,triggerr)

JobDataMap

存儲一些變量

job并發(fā)及持久化

Scheduler每次執(zhí)行，都會根據(jù)JobDetail創(chuàng)建一個新的Job實例，這樣就可以規(guī)避并發(fā)訪問的問題

@DisallowConcurrentExecution:禁止并發(fā)地執(zhí)行同一個job定義的多個實例
前一個任務執(zhí)行完了，才會執(zhí)行下一個任務

@PersistJobDataAfterExecution： 將JobDataMap進行持久化

觸發(fā)器

優(yōu)先級：同時觸發(fā)的比較優(yōu)先級
錯過觸發(fā)：到達觸發(fā)時間時沒有被執(zhí)行、可以配置延遲的閾值
simple：
cron：

調度器

JobStore
默認存儲在內存中

整合springboot

集群處理。每個節(jié)點執(zhí)行一些任務
節(jié)點間互相不通信，通過數(shù)據(jù)庫來
quartz.properties
QRTZ

配置文件、建表語句

QuartzJobBean
executeInternal(JobExecutionContext context)

SchedulerConfig
Scheduler按照配置文件創(chuàng)建調度器

@Bean
Scheduler scheduler()

@Bean
SchedulerFactoryBean
factory.setSchedulerName(“”)
factory.setDataSource()
factory.setApplicationContextSchedulerContextKey(“applicaiton”)
factory.setQuartzProperties(quartzProperties())
factory.setTaskExecutor(schedulerThreadPool())
factory.setStarter

@Bean
DataSource

@Bean
Executor schedulerThreadPool{
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor
executor.setCorePoolSize
executor.setMaxPoolSize
executor.setQueue

@Bean
Properties quartzProperties()
PropertiesFactoryBean propertiesFactoryBean
propertiesFactoryBean.setLocation(new ClassPathResource(“quartz.properties”))
propertiesFactoryBean.afterpeopertiesSet()
return propertiesFactoryBean.getObject

通過監(jiān)聽器啟動調度
StarterApplocationListener implements ApplicationListener()

@Autowired
Scheduler

IOC容器啟動起來以后啟動調度
onApplicationEvent(ContextRefreshedEvent event){
TriggerKey triggerKey=TriggerKey.triggerKey()
scheduler.getTrigger(triggerKey);
if(trigger == null) {
trigger=TriggerBuilder.newTrigger()
.withIdentity(triggerKey)
.withSchedule(CronScheduleBuiler.cronSchedule(“0/10 * * * * ?”))
.build();

JobDetail jobDetail = JobBuilder.newJob(QuartzJob.class)
.withIdentity()
.build()

scheduler.scheduleJob(jobDetail,trigger);
sheduler.start();
}

@SpringBootApplication

數(shù)據(jù)庫里存儲了一些歷史數(shù)據(jù)

一個JobDetail在一個節(jié)點

你是否還在尋找穩(wěn)定的海外服務器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機房具備T級流量清洗系統(tǒng)配攻擊溯源，準確流量調度確保服務器高可用性，企業(yè)級服務器適合批量采購，新人活動首月15元起，快前往官網(wǎng)查看詳情吧

名稱欄目：Java定時任務-創(chuàng)新互聯(lián)
URL分享：http://weahome.cn/article/hodpp.html