/**  
 * @Title: TimeTest.java
 * @Package org.csun.oc.mqtt
 * @Description: TODO
 * @author chisj [email protected]
 * @date 2017年5月5日
 */
package org.csun.oc.mqtt;

import java.io.IOException;
import java.util.Timer;

/**
 * ClassName: TimeTest
 * 
 * @Description: 定時器測試程式
 * @author chisj [email protected]
 

 * @date 2017年5月5日
 */
public class TimerTest {

	private static int pubTime = 30;
	
	public static void main(String[] args) {
		Timer timer = new Timer();
		// 在1秒後執行此任務,每次間隔2秒執行一次,如果傳遞一個Data引數,就可以在某個固定的時間執行這個任務.
		timer.schedule(new MyTask(), 1000, pubTime * 1000);
		// 這個是用來停止此任務的,否則就一直迴圈執行此任務
		while (true) {
			try {
				int in = System.in.read();
				if (in == 's') {
					// 使用這個方法退出任務
					timer.cancel();
					break;
				}
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

	static class MyTask extends java.util.TimerTask {
		int count = 0;
		@SuppressWarnings("static-access")
		public void run() {
			System.out.println("run times = " + count++);
			Publisher.getPublisher().msgInviteData("10013");
		}
	}
}