schedule与scheduleAtFixedRate之Timer源码分析

执行Timer任务调度方法有如下几种：

这些方法最后调用的都是这个方法：

 private void sched(TimerTask task, long time, long period)

这个方法的作用是将task放入Timer实例的共享变量queue（TaskQueue类型）中。源码如下：

private void sched(TimerTask task, long time, long period) {if (time < 0)throw new IllegalArgumentException("Illegal execution time.");// Constrain value of period sufficiently to prevent numeric// overflow while still being effectively infinitely large.if (Math.abs(period) > (Long.MAX_VALUE >> 1))period >>= 1;synchronized(queue) {if (!thread.newTasksMayBeScheduled)throw new IllegalStateException("Timer already cancelled.");synchronized(task.lock) {if (task.state != TimerTask.VIRGIN)throw new IllegalStateException("Task already scheduled or cancelled");task.nextExecutionTime = time;task.period = period;task.state = TimerTask.SCHEDULED;}queue.add(task);if (queue.getMin() == task)queue.notify();}}

TaskQueue按照一个“完全二叉树堆”来进行排序，完全二叉树堆的中根节点的值最大（或者最小），每节点的值大于（或者小于）其两个子节点。

queue.add（task）时首先将该任务放到队列最后，会发生“上浮”动作，最终保持完全二叉树堆的根节点存放task.nextExecutionTime最小的那个task，如果要执行任务直接从TaskQueue的根节点获取那个值执行，执行完任务后从队列中移除。

这篇文章以图文的方式对二叉树堆算法讲解的很清晰 http://weixin.niurenqushi.com/article/2016-06-17/4326390.html，可以参考一下。

回到源码，sched(TimerTask task, long time, long period) 方法会将一个任务加入到TaskQueue队列后，如果这个任务在队列中的根节点（也就是nextExecutionTime最小的那个task），那就发出notify通知，激活其他占用了该任务由于wait()而阻塞状态的线程。

那这个线程主要涉及那一块呢？答案是Timer的线程体，源码如下：

public void run() {try {mainLoop();} finally {// Someone killed this Thread, behave as if Timer cancelledsynchronized(queue) {newTasksMayBeScheduled = false;queue.clear();  // Eliminate obsolete references}}}/*** The main timer loop.  (See class comment.)*/private void mainLoop() {while (true) {try {TimerTask task;boolean taskFired;synchronized(queue) {// Wait for queue to become non-empty，等待被notify激活while (queue.isEmpty() && newTasksMayBeScheduled)queue.wait();if (queue.isEmpty())break; // Queue is empty and will forever remain; die// Queue nonempty; look at first evt and do the right thinglong currentTime, executionTime;task = queue.getMin();synchronized(task.lock) {if (task.state == TimerTask.CANCELLED) {queue.removeMin();continue;  // No action required, poll queue again}currentTime = System.currentTimeMillis();executionTime = task.nextExecutionTime;// 任务执行时间已经到达if (taskFired = (executionTime<=currentTime)) {if (task.period == 0) { // 如果period=0，则任务进行一次便结束，并移出队列queue.removeMin();task.state = TimerTask.EXECUTED;} else { // 设置下一次执行的时间// task.period<0 对应 scheduleAtFixedRate 方法// task.period>0 对应 schedule 方法queue.rescheduleMin(task.period<0 ? currentTime   - task.period: executionTime + task.period);}}}// 任务执行时间没到，等待，直到下一次执行时间大于当前时间if (!taskFired) queue.wait(executionTime - currentTime);}// 执行任务时间到达，开始执行任务，没有加锁，并发执行if (taskFired)  // Task fired; run it, holding no lockstask.run();} catch(InterruptedException e) {}}}

转载于:https://www.cnblogs.com/chenjunjie12321/p/8671303.html

schedule与scheduleAtFixedRate之Timer源码分析相关推荐

【Android 异步操作】Timer 定时器 ( Timer 与 TimerTask 基本使用 | Timer 定时器常用用法 | Timer 源码分析 )
文章目录一.Timer 定时器基本使用二.Timer 定时器常用用法三.Timer 源码分析四.Timer 部分源码注释五.源码及资源下载参考文档 : Timer 定时器 API 文档 T ...
java刷卡计时计次源码美萍_Java 定时调配 Timer 类和定任务 TimerTask 类（一篇详细且完整的源码分析以及四种简单的使用方法）...
前言在我们日常生活中,我们常常会遇到有关计时器的事情.如商城类项目会在某年某月某日某时某分某秒进行特价活动,那么当时间到达这个时间点上的时候该事件就会触发. 1.Timer 类构造函数摘要 1 Ti ...
storm启动nimbus源码分析-nimbus.clj
storm启动nimbus源码分析-nimbus.clj nimbus是storm集群的"控制器",是storm集群的重要组成部分.我们可以通用执行bin/storm nimbus ...
Nimbus二storm启动nimbus源码分析-nimbus.clj
nimbus是storm集群的"控制器",是storm集群的重要组成部分.我们可以通用执行bin/storm nimbus >/dev/null 2>&1 &a ...
storm启动supervisor源码分析-supervisor.clj
storm启动supervisor源码分析-supervisor.clj supervisor是storm集群重要组成部分,supervisor主要负责管理各个"工作节点".sup ...
Java定时任务(一) Timer及TimerTask的案例解析及源码分析
Java定时任务(一) Timer及TimerTask的案例解析及源码分析一.概述: 定时任务这个概念在Java的学习以及项目的开发中并不陌生,应用场景也是多种多样.比如我们会注意到12306网站 ...
Zookeeper源码分析（二） ----- zookeeper日志
zookeeper源码分析系列文章: Zookeeper源码分析(一) ----- 源码运行环境搭建原创博客,纯手敲,转载请注明出处,谢谢! 既然我们是要学习源码,那么如何高效地学习源代码呢?答案就 ...
RocketMQ源码分析之延迟消息
文章目录前言一.延迟消息 1.特点 2.使用场景 3.demo 二.发送延迟消息三.broker端存储延迟消息四.总结 1.延迟消息工作原理 2.延迟消息在消费者消费重试中的应用前言本篇文 ...
Netty学习十七：源码分析之HashWheelTimer
一.常见定时任务实现定时器的使用场景包括:成月统计报表.财务对账.会员积分结算.邮件推送等,它一般有三种表现形式:按固定周期定时执行.延迟一定时间后执行.指定某个时刻执行. 定时器的本质是设计一种数 ...
golang源码分析-调度概述
golang源码分析-调度过程概述本文主要概述一下golang的调度器的大概工作的流程,众所周知golang是基于用户态的协程的调度来完成多任务的执行.在Linux操作系统中,以往的多线程执行都是通 ...

schedule与scheduleAtFixedRate之Timer源码分析

schedule与scheduleAtFixedRate之Timer源码分析相关推荐

最新文章

热门文章