/**
* @Title: TimeTest.java
* @Package org.csun.oc.mqtt
* @Description: TODO
* @author chisj chisj@foxmail.com
* @date 2017年5月5日
*/
package org.csun.oc.mqtt;
import java.io.IOException;
import java.util.Timer;
/**
* ClassName: TimeTest
*
* @Description: 定时器测试程序
* @author chisj chisj@foxmail.com
* @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");
}
}
}
