电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術(shù)文章
文章詳情頁

Java 定時(shí)器的多種實(shí)現(xiàn)方式

瀏覽:23日期:2022-08-11 10:08:35
目錄一、前言(1)Timer(2)DelayedQueue 延遲隊(duì)列(3)ScheduledThreadPoolExecutor(4)ScheduledThreadPoolExecutor一、前言

定時(shí)器有三種表現(xiàn)形式:

按固定周期定時(shí)執(zhí)行 延遲一定時(shí)間后執(zhí)行 指定某個(gè)時(shí)刻執(zhí)行

JDK 提供了三種常用的定時(shí)器實(shí)現(xiàn)方式,分別為:

Timer DelayedQueue 延遲隊(duì)列 ScheduledThreadPoolExecutor(1)Timer

發(fā)現(xiàn) eureka 中大量使用了 Timer 定時(shí)器:

Timer 屬于 JDK 比較早期版本的實(shí)現(xiàn),它可以實(shí)現(xiàn)固定周期的任務(wù),以及延遲任務(wù)。 Timer 會(huì)起動(dòng)一個(gè)異步線程去執(zhí)行到期的任務(wù),任務(wù)可以只被調(diào)度執(zhí)行一次,也可以周期性反復(fù)執(zhí)行多次。

Timer 是如何使用的,示例代碼如下:

Timer timer = new Timer();timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() {// 業(yè)務(wù)代碼 }}, 5000, 5000); // 5s 后調(diào)度一個(gè)周期為 5s 的定時(shí)任務(wù) TimerTask 是實(shí)現(xiàn)了 Runnable 接口的抽象類 Timer 負(fù)責(zé)調(diào)度和執(zhí)行 TimerTask

Timer 的內(nèi)部構(gòu)造,如下:

public class Timer { // 小根堆,run操作 O(1)、新增 O(logn)、cancel O(logn) private final TaskQueue queue = new TaskQueue(); // 創(chuàng)建另外線程,任務(wù)處理,會(huì)輪詢 queue private final TimerThread thread = new TimerThread(queue); public Timer(String name) {thread.setName(name);thread.start(); }}

Timer 它是存在不少設(shè)計(jì)缺陷的,所以并不推薦用戶使用:

Timer 是單線程模式,如果某個(gè) TimerTask 執(zhí)行時(shí)間很久,會(huì)影響其他任務(wù)的調(diào)度。 Timer 的任務(wù)調(diào)度是基于系統(tǒng)絕對(duì)時(shí)間的,如果系統(tǒng)時(shí)間不正確,可能會(huì)出現(xiàn)問題。 TimerTask 如果執(zhí)行出現(xiàn)異常,Timer 并不會(huì)捕獲,會(huì)導(dǎo)致線程終止,其他任務(wù)永遠(yuǎn)不會(huì)執(zhí)行。(2)DelayedQueue 延遲隊(duì)列

特征如下:

DelayedQueue 是 JDK 中一種可以延遲獲取對(duì)象的阻塞隊(duì)列,其內(nèi)部是采用優(yōu)先級(jí)隊(duì)列 PriorityQueue 存儲(chǔ)對(duì)象 DelayQueue 中的每個(gè)對(duì)象都必須實(shí)現(xiàn) Delayed 接口,并重寫 compareTo 和 getDelay 方法

DelayedQueue 的使用方法如下:

public class DelayQueueTest { public static void main(String[] args) throws Exception {BlockingQueue<SampleTask> delayQueue = new DelayQueue<>();long now = System.currentTimeMillis();delayQueue.put(new SampleTask(now + 1000));delayQueue.put(new SampleTask(now + 2000));delayQueue.put(new SampleTask(now + 3000));for (int i = 0; i < 3; i++) { System.out.println(new Date(delayQueue.take().getTime()));} } static class SampleTask implements Delayed {long time;public SampleTask(long time) { this.time = time;}public long getTime() { return time;}@Overridepublic int compareTo(Delayed o) { return Long.compare(this.getDelay(TimeUnit.MILLISECONDS), o.getDelay(TimeUnit.MILLISECONDS));}@Overridepublic long getDelay(TimeUnit unit) { return unit.convert(time - System.currentTimeMillis(), TimeUnit.MILLISECONDS);} }}(3)ScheduledThreadPoolExecutor

JDK 提供了功能更加豐富的 ScheduledThreadPoolExecutor

public class ScheduledExecutorServiceTest { public static void main(String[] args) {ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);executor.scheduleAtFixedRate(() -> System.out.println('Hello World'), 1000, 2000, TimeUnit.MILLISECONDS); // 1s 延遲后開始執(zhí)行任務(wù),每 2s 重復(fù)執(zhí)行一次 }}

ScheduledThreadPoolExecutor 使用了阻塞隊(duì)列 DelayedWorkQueue。

(4)ScheduledThreadPoolExecutor

線程應(yīng)該是最常見的實(shí)現(xiàn)方案,創(chuàng)建一個(gè)線程執(zhí)行任務(wù)即可,舉例幾個(gè)不同的寫法,代碼如下

4.1.使用thread + runnable

package com.yezi_tool.demo_basic.test;import org.springframework.stereotype.Component;import java.util.Date;@Componentpublic class ThreadTest { private Integer count = 0; public ThreadTest() {test1(); } public void test1() {new Thread(() -> { while (count < 10) {System.out.println(new Date().toString() + ': ' + count);count++;try { Thread.sleep(3000);} catch (InterruptedException e) { e.printStackTrace();} }}).start(); }}

4.2.使用線程池 + runnable

package com.yezi_tool.demo_basic.test;import org.springframework.stereotype.Component;import java.util.Date;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;@Componentpublic class ThreadTest { private static final ExecutorService threadPool = Executors.newFixedThreadPool(5);// 線程池 private Integer count = 0; public ThreadTest() {test2(); } public void test2() {threadPool.execute(() -> { while (count < 10) {System.out.println(new Date().toString() + ': ' + count);count++;try { Thread.sleep(3000);} catch (InterruptedException e) { e.printStackTrace();} }}); }}

以上就是Java 定時(shí)器的多種實(shí)現(xiàn)方式的詳細(xì)內(nèi)容,更多關(guān)于Java 定時(shí)器的實(shí)現(xiàn)的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章!

標(biāo)簽: Java
相關(guān)文章:
主站蜘蛛池模板: 滚筒烘干机_转筒烘干机_滚筒干燥机_转筒干燥机_回转烘干机_回转干燥机-设备生产厂家 | 电竞学校_电子竞技培训学校学院-梦竞未来电竞学校官网 | 电子厂招聘_工厂招聘_普工招聘_小时工招聘信息平台-众立方招工网 | 酶联免疫分析仪-多管旋涡混合仪|混合器-莱普特科学仪器(北京)有限公司 | 高压负荷开关-苏州雷尔沃电器有限公司 | 上海物流公司,上海货运公司,上海物流专线-优骐物流公司 | 真空上料机(一种真空输送机)-百科| 膜结构停车棚-自行车棚-膜结构汽车棚加工安装厂家幸福膜结构 | 慢回弹测试仪-落球回弹测试仪-北京冠测精电仪器设备有限公司 | 纯化水设备-EDI-制药-实验室-二级反渗透-高纯水|超纯水设备 | 河北凯普威医疗器材有限公司,高档轮椅系列,推车系列,座厕椅系列,协步椅系列,拐扙系列,卫浴系列 | 刮板输送机,粉尘加湿搅拌机,螺旋输送机,布袋除尘器 | 氨水-液氨-工业氨水-氨水生产厂家-辽宁顺程化工| 流量检测仪-气密性检测装置-密封性试验仪-东莞市奥图自动化科技有限公司 | app开发|app开发公司|小程序开发|物联网开发||北京网站制作|--前潮网络 | 匀胶机旋涂仪-声扫显微镜-工业水浸超声-安赛斯(北京)科技有限公司 | 模具硅橡胶,人体硅胶,移印硅胶浆厂家-宏图硅胶科技 | 钢结构厂房造价_钢结构厂房预算_轻钢结构厂房_山东三维钢结构公司 | 板框压滤机-隔膜压滤机配件生产厂家-陕西华星佳洋装备制造有限公司 | 啤酒设备-小型啤酒设备-啤酒厂设备-济南中酿机械设备有限公司 | 西安展台设计搭建_西安活动策划公司_西安会议会场布置_西安展厅设计西安旭阳展览展示 | 阀门智能定位器_电液动执行器_气动执行机构-赫尔法流体技术(北京)有限公司 | 无锡网站建设_企业网站定制-网站制作公司-阿凡达网络 | 恒温油槽-恒温水槽-低温恒温槽厂家-宁波科麦仪器有限公司 | 六维力传感器_三维力传感器_二维力传感器-南京神源生智能科技有限公司 | 早报网| 广州二手电缆线回收,旧电缆回收,广州铜线回收-广东益福电缆线回收公司 | 艺术涂料_进口艺术涂料_艺术涂料加盟_艺术涂料十大品牌 -英国蒙太奇艺术涂料 | 动物麻醉机-数显脑立体定位仪-北京易则佳科技有限公司 | 冷油器-冷油器换管改造-连云港灵动列管式冷油器生产厂家 | 防爆大气采样器-防爆粉尘采样器-金属粉尘及其化合物采样器-首页|盐城银河科技有限公司 | 三效蒸发器_多效蒸发器价格_四效三效蒸发器厂家-青岛康景辉 | 电车线(用于供电给电车的输电线路)-百科 | 振动传感器,检波器-威海广达勘探仪器有限公司| 电动不锈钢套筒阀-球面偏置气动钟阀-三通换向阀止回阀-永嘉鸿宇阀门有限公司 | 进口试验机价格-进口生物材料试验机-西安卡夫曼测控技术有限公司 | 智能化的检漏仪_气密性测试仪_流量测试仪_流阻阻力测试仪_呼吸管快速检漏仪_连接器防水测试仪_车载镜头测试仪_奥图自动化科技 | 全自动端子机|刺破式端子压接机|全自动双头沾锡机|全自动插胶壳端子机-东莞市傅氏兄弟机械设备有限公司 | 深圳高新投三江工业消防解决方案提供厂家_服务商_园区智慧消防_储能消防解决方案服务商_高新投三江 | 有机肥设备生产制造厂家,BB掺混肥搅拌机、复合肥设备生产线,有机肥料全部加工设备多少钱,对辊挤压造粒机,有机肥造粒设备 -- 郑州程翔重工机械有限公司 | 实木家具_实木家具定制_全屋定制_美式家具_圣蒂斯堡官网 |