Java分布式应用学习笔记05多线程下的并发同步器----前篇(三)

2014-11-24 02:03:56 · 作者: · 浏览: 2
System.out.println(Thread.currentThread().getName() + ":"

+ new Date() + "士兵巡视来了" + (++count));

}

};

// 1秒钟后运行,并每隔2秒运行一次

final ScheduledFuture beeperHandle1 = scheduler.scheduleAtFixedRate(

soldier, 1, 1, SECONDS);

// 5秒钟后运行,并每隔2秒运行一次

final ScheduledFuture beeperHandle2 = scheduler.scheduleWithFixedDelay(

general, 5, 5, SECONDS);

// 30秒后结束关闭任务,并且关闭Scheduler

scheduler.schedule(new Runnable() {

public void run() {

beeperHandle1.cancel(true);

beeperHandle2.cancel(true);

scheduler.shutdown();

}

}, 60, SECONDS);

}

}

程序的注释已经明白了,在此不再赘述。