Timer为定时周期性执行调度性能没有concurrent包下的高,不过原理还是需要了解下的,手续看下使用:
Timer timer = new Timer("Fetch thread");timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() { try { Thread.sleep(10000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("**Fetch thread1 run**" + this.scheduledExecutionTime()); }}, 1000, 10);timer.schedule(new TimerTask() { @Override public void run() { try { Thread.sleep(10000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("**Fetch thread2 run**" + this.scheduledExecutionTime()); }}, 1000, 10);
执行打印结果:
schedule:**Fetch thread2 run**1387522409123**Fetch thread2 run**1387522419125**Fetch thread2 run**1387522429126scheduleAtFixedRate:**Fetch thread1 run**1387522551056**Fetch thread1 run**1387522551066**Fetch thread1 run**1387522551076
总结:
schedule方法:在上次执行结束之后开始按某固定的rate执行
scheduleAtFixedRate方法:在上次执行开始时开始按某固定的rate执行,也就是说不关心上次是否执行完成此次执行就已经开始了so要注意并发。
实现原理:
Timer里维护了一个TimerThread,而TimerThread里维护了一个TaskQueue,所有的TimerTask都放在此TaskQueue种,在TimerThread中执行while(ture)通过对TaskQueue的notify wait来实现操作。