1.视界

1.概述

kafka启动的时候，初始化了kafkaSchedule
定时调度器：kafkaScheduler，该调度器是全局共享的。承担了logManager模块中的日志归档，日志刷新、检查点恢复，日志的offset检查，过期日志的删除。ReplicaManager模块中的高水位检查，ISR过期检查，ISR变更处理，空闲ISR停止

2. 入口

kafka.server.KafkaServer#startup/** start scheduler*  daemon定时任务处理线程池* */
kafkaScheduler = new KafkaScheduler(config.backgroundThreads)
kafkaScheduler.startup()

3.startup方法

/*** JDK提供的定时任务线程池实现*/private var executor: ScheduledThreadPoolExecutor = nullprivate val schedulerThreadId = new AtomicInteger(0)override def sta

95-10-030-启动-deamon定时任务相关推荐

【Local/docker-compose】安装Celery并启动beat定时任务-20220823
settings.py(redis由container产生,不引用外部redis) """ Django settings for GAGA project.Genera ...
[UWP小白日记-10]程序启动屏（ios解锁既视感）
[UWP小白日记-10]程序启动屏(ios解锁既视感) 原文:[UWP小白日记-10]程序启动屏(ios解锁既视感) 讲一下微软爸爸的开发者大会2016又暴了个表达式动画和Windows.UI.Co ...
AI一分钟 | 柯洁战胜AI“求报道”，期待正式与围棋AI下让子棋；小米MIUI 10全面启动，主打人工智能人机交互
一分钟AI 柯洁战胜AI求报道称与zero下差距不会超过3子小米MIUI 10全面启动主打人工智能人机交互 AI医药研发公司晶泰科技完成1500万美元B轮融资,红杉领投,谷歌跟投,腾讯追加投资 ...
广东春运安保工作提前10天启动
中新网广州1月17日电 (索有为粤交警)2019年春运将于1月21日正式拉开序幕.广东省道路交通安全工作联席会议办公室(下称"广东省道安办")副主任.广东省公安厅交管局局长申勇强 ...
关于Suse Linux 10的启动过程(转)
关于Suse Linux 10的启动过程(转)[@more@] Novell公司宣布,关于下一代开放企业平台SUSE? Linux Enterprise 10,已经在市场上和媒体方面得到世界范围的广泛 ...
License Manager 10.3启动失败解决方法
License Manager 10.3启动失败解决方法参考文章: (1)License Manager 10.3启动失败解决方法 (2)https://www.cnblogs.com/xixihu ...
单EFI分区Archlinux + Windows 10 双启动安装记录
单EFI分区Archlinux + Windows 10 双启动安装记录前言一些规范一.安装前准备 1.下载ISO 2.用USB启动二.开始安装 1.检查是否是UEFI启动 2.检查网络 3. ...
学会这10种实用的定时任务，拿捏所有业务场景
前言最近有几个读者私信给我,问我他们的业务场景,要用什么样的定时任务.确实,在不用的业务场景下要用不同的定时任务,其实我们的选择还是挺多的.我今天给大家总结10种非常实用的定时任务,总有一种是适合你 ...
微软Windows 7实现10秒启动的背后
实际上,早在Windows 7处于M3阶段的时候,微软就对Windows 7的表现非常自信.2009年11月初,微软展示了Windows Vista和Windows 7 M3之间的速度差异,结果表明, ...
linux开机磁盘检查启动慢,Ubuntu 7.10开机启动慢的完美解决
全新安装Ubuntu 7.10后启动速度变得异常缓慢,多方查找后发现是File System Check(Fsck)的问题解决方法如下: 1. 在Terminal中输入:sudo gedit /et ...

95-10-030-启动-deamon定时任务

1.视界

1.概述

2. 入口

3.startup方法

95-10-030-启动-deamon定时任务相关推荐

最新文章

热门文章