當(dāng)前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

java之 Timer 类的使用以及深入理解

發(fā)布時間：2024/4/14 编程问答 29 豆豆

生活随笔收集整理的這篇文章主要介紹了 java之 Timer 类的使用以及深入理解小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

最近一直在看線程知識，然后看到Timer定時器使用了線程實現(xiàn)的定時功能，于是了解了解；

本文從Time類的使用和源碼分析兩個方面講解：

1---Timer類使用

2---源碼分析

1、Time類使用：

?????

1 根據(jù)是否循環(huán)執(zhí)行分為兩類： 2 3 //只執(zhí)行一次 4 public void schedule(TimerTask task, long delay); 5 public void schedule(TimerTask task, Date time); 6 7 //循環(huán)執(zhí)行 8 // 在循環(huán)執(zhí)行類別中根據(jù)循環(huán)時間間隔又可以分為兩類 9 public void schedule(TimerTask task, long delay, long period) ; 10 public void schedule(TimerTask task, Date firstTime, long period) ; 11 12 13 public void scheduleAtFixedRate(TimerTask task, long delay, long period) 14 public void scheduleAtFixedRate(TimerTask task, Date firstTime, long period)

示例：

只執(zhí)行一次：

1 Timer timer = new Timer(); 2 3 //延遲1000ms執(zhí)行程序 4 timer.schedule(new TimerTask() { 5 @Override 6 public void run() { 7 System.out.println("IMP 當(dāng)前時間" + this.scheduledExecutionTime()); 8 } 9 }, 1000); 10 //延遲10000ms執(zhí)行程序 11 timer.schedule(new TimerTask() { 12 @Override 13 public void run() { 14 System.out.println("IMP 當(dāng)前時間" + this.scheduledExecutionTime()); 15 } 16 }, new Date(System.currentTimeMillis() + 10000));

循環(huán)執(zhí)行：

1 Timer timer = new Timer(); 2 3 //前一次執(zhí)行程序結(jié)束后 2000ms 后開始執(zhí)行下一次程序 4 timer.schedule(new TimerTask() { 5 @Override 6 public void run() { 7 System.out.println("IMP 當(dāng)前時間" + this.scheduledExecutionTime()); 8 } 9 }, 0,2000); 10 11 //前一次程序執(zhí)行開始后 2000ms后開始執(zhí)行下一次程序 12 timer.scheduleAtFixedRate(new TimerTask() { 13 @Override 14 public void run() { 15 System.out.println("IMP 當(dāng)前時間" + this.scheduledExecutionTime()); 16 } 17 },0,2000);

2、源碼分析：

Timer 源碼：

程序運行：

在初始化Timer時，開啟一個線程循環(huán)提取任務(wù)數(shù)組中的任務(wù)，如果任務(wù)數(shù)組為空，線程等待直到添加任務(wù)；

當(dāng)添加任務(wù)時，喚醒線程，提取數(shù)組中標(biāo)記為1的任務(wù)，

如果該任務(wù)狀態(tài)為CANCELLED，則從數(shù)組中刪除任務(wù)，continue ，繼續(xù)循環(huán)提取任務(wù)；

然后將當(dāng)前時間與任務(wù)執(zhí)行時間點比較標(biāo)記taskFired=executionTime<=currentTime;

taskFired =false ，說明任務(wù)執(zhí)行時間還沒到，則調(diào)用wait等待(executionTime-currentTime) 時間長度，然后循環(huán)重新提取該任務(wù)；

taskFired =true，說明任務(wù)執(zhí)行時間已經(jīng)到了，或者過去了。繼續(xù)判斷任務(wù)循環(huán)時間間隔period；

???????????????????????? period=0時，說明此次任務(wù)是非循環(huán)任務(wù)，直接將該任務(wù)從數(shù)組中刪除，并將狀態(tài)置為EXECUTED，然后執(zhí)行任務(wù)的run方法！

???????????????????????? period！=0時，說明此次任務(wù)時循環(huán)任務(wù)，將該任務(wù)的執(zhí)行時間點向前推進，具體推進時間根據(jù)調(diào)用的方法判斷；

??????????????????????????????????????????????? 如果是schedule方法，則在當(dāng)前時間基礎(chǔ)上向前推進period時間長度；

??????????????????????????????????????????????? 如果是scheduleAtFixedRate方法，則在當(dāng)前任務(wù)執(zhí)行時間點基礎(chǔ)上向前推進period時間長度，

??????????????????????????????????????????????? 最后執(zhí)行任務(wù)的run方法；循環(huán)提取任務(wù)

?????????????????????????????????????????????

1 package java.util; 2 import java.util.Date; 3 import java.util.concurrent.atomic.AtomicInteger; 4 5 6 public class Timer { 7 8 private final TaskQueue queue = new TaskQueue(); 9 10 11 private final TimerThread thread = new TimerThread(queue); 12 13 14 private final Object threadReaper = new Object() { 15 protected void finalize() throws Throwable { 16 synchronized(queue) { 17 thread.newTasksMayBeScheduled = false; 18 queue.notify(); // In case queue is empty. 19 } 20 } 21 }; 22 23 24 private final static AtomicInteger nextSerialNumber = new AtomicInteger(0); 25 private static int serialNumber() { 26 return nextSerialNumber.getAndIncrement(); 27 } 28 29 30 public Timer() { 31 this("Timer-" + serialNumber()); 32 } 33 34 35 public Timer(boolean isDaemon) { 36 this("Timer-" + serialNumber(), isDaemon); 37 } 38 39 40 public Timer(String name) { 41 thread.setName(name); 42 thread.start(); 43 } 44 45 //在初始化Timer時，確定線程名稱，以及是否是守護線程，開啟線程 46 public Timer(String name, boolean isDaemon) { 47 thread.setName(name); 48 thread.setDaemon(isDaemon); 49 thread.start(); 50 } 51 52 53 public void schedule(TimerTask task, long delay) { 54 if (delay < 0) 55 throw new IllegalArgumentException("Negative delay."); 56 sched(task, System.currentTimeMillis()+delay, 0); 57 } 58 59 60 public void schedule(TimerTask task, Date time) { 61 sched(task, time.getTime(), 0); 62 } 63 64 65 public void schedule(TimerTask task, long delay, long period) { 66 if (delay < 0) 67 throw new IllegalArgumentException("Negative delay."); 68 if (period <= 0) 69 throw new IllegalArgumentException("Non-positive period."); 70 sched(task, System.currentTimeMillis()+delay, -period); 71 } 72 73 74 public void schedule(TimerTask task, Date firstTime, long period) { 75 if (period <= 0) 76 throw new IllegalArgumentException("Non-positive period."); 77 sched(task, firstTime.getTime(), -period); 78 } 79 80 81 public void scheduleAtFixedRate(TimerTask task, long delay, long period) { 82 if (delay < 0) 83 throw new IllegalArgumentException("Negative delay."); 84 if (period <= 0) 85 throw new IllegalArgumentException("Non-positive period."); 86 sched(task, System.currentTimeMillis()+delay, period); 87 } 88 89 90 public void scheduleAtFixedRate(TimerTask task, Date firstTime, 91 long period) { 92 if (period <= 0) 93 throw new IllegalArgumentException("Non-positive period."); 94 sched(task, firstTime.getTime(), period); 95 } 96 97 98 private void sched(TimerTask task, long time, long period) { 99 if (time < 0) 100 throw new IllegalArgumentException("Illegal execution time."); 101 102 // Constrain value of period sufficiently to prevent numeric 103 // overflow while still being effectively infinitely large. 104 if (Math.abs(period) > (Long.MAX_VALUE >> 1)) 105 period >>= 1; 106 107 synchronized(queue) { 108 if (!thread.newTasksMayBeScheduled) 109 throw new IllegalStateException("Timer already cancelled."); 110 111 synchronized(task.lock) { 112 if (task.state != TimerTask.VIRGIN) 113 throw new IllegalStateException( 114 "Task already scheduled or cancelled"); 115 task.nextExecutionTime = time; 116 task.period = period; 117 task.state = TimerTask.SCHEDULED; 118 } 119 120 queue.add(task); 121 if (queue.getMin() == task) 122 queue.notify(); 123 } 124 } 125 126 127 public void cancel() { 128 synchronized(queue) { 129 thread.newTasksMayBeScheduled = false; 130 queue.clear(); 131 queue.notify(); // In case queue was already empty. 132 } 133 } 134 135 //凈化，清除timer中標(biāo)記為CANCELLED的TIMETASK,? 返回值為清除個數(shù) 136 public int purge() { 137 int result = 0; 138 139 synchronized(queue) { 140 for (int i = queue.size(); i > 0; i--) { 141 if (queue.get(i).state == TimerTask.CANCELLED) { 142 queue.quickRemove(i); 143 result++; 144 } 145 } 146 147 if (result != 0) 148 queue.heapify(); 149 } 150 151 return result; 152 } 153 } 154 155 //自定義線程 156 class TimerThread extends Thread { 157 158 boolean newTasksMayBeScheduled = true; 159 160 161 private TaskQueue queue; 162 163 TimerThread(TaskQueue queue) { 164 this.queue = queue; 165 } 166 167 public void run() { 168 try { 169 mainLoop(); 170 } finally { 171 // Someone killed this Thread, behave as if Timer cancelled 172 synchronized(queue) { 173 newTasksMayBeScheduled = false; 174 queue.clear(); // Eliminate obsolete references 175 } 176 } 177 } 178 179 180 private void mainLoop() { 181 while (true) { 182 try { 183 TimerTask task; 184 boolean taskFired; 185 synchronized(queue) { 186 // Wait for queue to become non-empty 187 while (queue.isEmpty() && newTasksMayBeScheduled) 188 queue.wait(); 189 if (queue.isEmpty()) 190 break; // Queue is empty and will forever remain; die 191 192 // Queue nonempty; look at first evt and do the right thing 193 long currentTime, executionTime; 194 task = queue.getMin(); 195 synchronized(task.lock) { 196 if (task.state == TimerTask.CANCELLED) {//移除狀態(tài)為已執(zhí)行完畢的任務(wù) 197 queue.removeMin(); 198 continue; 199 } 200 currentTime = System.currentTimeMillis(); 201 executionTime = task.nextExecutionTime; 202 if (taskFired = (executionTime<=currentTime)) { 203 if (task.period == 0) { // 循環(huán)條件為0時，直接清除任務(wù)，并將任務(wù)狀態(tài)置為非循環(huán)任務(wù)，并執(zhí)行一次任務(wù)！ 204 queue.removeMin(); 205 task.state = TimerTask.EXECUTED; 206 } else { //區(qū)分兩種循環(huán)類別的關(guān)鍵 207 queue.rescheduleMin( 208 task.period<0 ? currentTime - task.period 209 : executionTime + task.period); 210 } 211 } 212 } 213 if (!taskFired) // 當(dāng)下次執(zhí)行任務(wù)時間大于當(dāng)前時間等待 214 queue.wait(executionTime - currentTime); 215 } 216 if (taskFired) // 執(zhí)行任務(wù) 217 task.run(); 218 } catch(InterruptedException e) { 219 } 220 } 221 } 222 } 223 224 /** 225 * 226 * 任務(wù)管理內(nèi)部類 227 */ 228 class TaskQueue { 229 230 //初始化 128個空間，實際使用127個位置編號為0的位置不使用 231 private TimerTask[] queue = new TimerTask[128]; 232 233 234 private int size = 0; 235 236 237 int size() { 238 return size; 239 } 240 241 //添加任務(wù)，如果空間不足，空間*2，，然后排序（將nextExecutionTime最小的排到1位置） 242 void add(TimerTask task) { 243 // Grow backing store if necessary 244 if (size + 1 == queue.length) 245 queue = Arrays.copyOf(queue, 2*queue.length); 246 247 queue[++size] = task; 248 fixUp(size); 249 } 250 251 //得到最小的nextExecutionTime的任務(wù) 252 TimerTask getMin() { 253 return queue[1]; 254 } 255 256 //得到指定位置的任務(wù) 257 TimerTask get(int i) { 258 return queue[i]; 259 } 260 261 //刪除最小nextExecutionTime的任務(wù)，排序(將nextExecutionTime最小的排到1位置) 262 void removeMin() { 263 queue[1] = queue[size]; 264 queue[size--] = null; // Drop extra reference to prevent memory leak 265 fixDown(1); 266 } 267 268 //快速刪除指定位置的任務(wù) 269 void quickRemove(int i) { 270 assert i <= size; 271 272 queue[i] = queue[size]; 273 queue[size--] = null; // Drop extra ref to prevent memory leak 274 } 275 276 //重新設(shè)置最小nextExecutionTime的任務(wù)的nextExecutionTime，排序(將nextExecutionTime最小的排到1位置) 277 void rescheduleMin(long newTime) { 278 queue[1].nextExecutionTime = newTime; 279 fixDown(1); 280 } 281 282 //數(shù)組是否為空 283 boolean isEmpty() { 284 return size==0; 285 } 286 287 //清空數(shù)組 288 void clear() { 289 // Null out task references to prevent memory leak 290 for (int i=1; i<=size; i++) 291 queue[i] = null; 292 293 size = 0; 294 } 295 296 //將nextExecutionTime最小的排到1位置 297 private void fixUp(int k) { 298 while (k > 1) { 299 int j = k >> 1; 300 if (queue[j].nextExecutionTime <= queue[k].nextExecutionTime) 301 break; 302 TimerTask tmp = queue[j]; queue[j] = queue[k]; queue[k] = tmp; 303 k = j; 304 } 305 } 306 307 //將nextExecutionTime最小的排到1位置 308 private void fixDown(int k) { 309 int j; 310 while ((j = k << 1) <= size && j > 0) { 311 if (j < size && 312 queue[j].nextExecutionTime > queue[j+1].nextExecutionTime) 313 j++; // j indexes smallest kid 314 if (queue[k].nextExecutionTime <= queue[j].nextExecutionTime) 315 break; 316 TimerTask tmp = queue[j]; queue[j] = queue[k]; queue[k] = tmp; 317 k = j; 318 } 319 } 320 321 //排序（將nextExecutionTime最小的排到1位置）在快速刪除任務(wù)后調(diào)用 322 void heapify() { 323 for (int i = size/2; i >= 1; i--) 324 fixDown(i); 325 } 326 }

TimerTask源碼：

?功能：用戶任務(wù)，Timer執(zhí)行任務(wù)實體（任務(wù)狀態(tài)，任務(wù)下次執(zhí)行時間點，任務(wù)循環(huán)時間間隔，任務(wù)本體【run】）

1 package java.util; 2 /** 3 * 雖然實現(xiàn)了Runnable接口但是在Timer中直接調(diào)用run方法， 4 * */ 5 public abstract class TimerTask implements Runnable { 6 7 final Object lock = new Object(); 8 9 int state = VIRGIN; //狀態(tài) ，未使用，正在使用，非循環(huán)，使用完畢 10 11 12 static final int VIRGIN = 0; //未使用 13 14 static final int SCHEDULED = 1;//正在使用 15 16 17 static final int EXECUTED = 2;//非循環(huán) 18 19 20 static final int CANCELLED = 3;//使用完畢 21 22 23 long nextExecutionTime; //下載調(diào)用任務(wù)時間 24 25 26 long period = 0;// 循環(huán)時間間隔 27 28 protected TimerTask() { 29 } 30 31 32 public abstract void run();//自定義任務(wù) 33 34 //退出任務(wù)執(zhí)行完畢后，退出返回 true ，未執(zhí)行完就退出返回false 35 public boolean cancel() { 36 synchronized(lock) { 37 boolean result = (state == SCHEDULED); 38 state = CANCELLED; 39 return result; 40 } 41 } 42 //返回時間 43 public long scheduledExecutionTime() { 44 synchronized(lock) { 45 return (period < 0 ? nextExecutionTime + period 46 : nextExecutionTime - period); 47 } 48 } 49 }

轉(zhuǎn)載于:https://www.cnblogs.com/xiaotaoqi/p/6874713.html

總結(jié)

以上是生活随笔為你收集整理的java之 Timer 类的使用以及深入理解的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。

JAVA
timer

上一篇：二叉树节点个数，叶子个数，第K层个数，最
下一篇：正规短信验证码