javax.management.timer.Timer#start ( )源码实例Demo

下面列出了javax.management.timer.Timer#start ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： jdk8u-dev-jdk 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码2 项目： dragonwell8_jdk 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码3 项目： TencentKona-8 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码4 项目： TencentKona-8 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码5 项目： jdk8u60 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码6 项目： jdk8u60 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码7 项目： openjdk-jdk8u 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码8 项目： jdk8u-jdk 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码9 项目： openjdk-jdk8u-backup 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码10 项目： openjdk-jdk8u-backup 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码11 项目： openjdk-jdk9 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码12 项目： jdk8u-jdk 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码13 项目： jdk8u-jdk 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码14 项目： jdk8u-jdk 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码15 项目： hottub 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码16 项目： hottub 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码17 项目： openjdk-8-source 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码18 项目： openjdk-8-source 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

源代码19 项目： jdk8u_jdk 文件： StartTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test on timer start method with past notifications.");

    System.out.println(">>> Create a Timer object.");
    Timer timer = new Timer();

    System.out.println(
        ">>> Set the flag (setSendPastNotification) to true.");
    timer.setSendPastNotifications(true);

    timer.addNotificationListener(myListener, null, null);

    System.out.println(">>> Add notifications: " + SENT);

    Date date = new Date();
    for (int i = 0; i < SENT; i++) {
        timer.addNotification(
            "testType" + i, "testMsg" + i, "testData" + i, date);
    }

    System.out.println(">>> The notifications should be sent at " + date);
    System.out.println(">>> Sleep 100 ms to have past notifications.");
    Thread.sleep(100);

    System.out.println(">>> Start the timer at " + new Date());
    timer.start();

    System.out.println(">>> Stop the timer.");
    Thread.sleep(100);
    stopping = true;
    timer.stop();

    if (received != SENT) {
        throw new RuntimeException(
            "Expected to receive " + SENT + " but got " + received);
    }

    System.out.println(">>> Received all expected notifications.");

    System.out.println(">>> Bye bye!");
}

源代码20 项目： jdk8u_jdk 文件： MissingNotificationTest.java

public static void main(String[] args) throws Exception {
    System.out.println(
        ">>> Test for missing notifications.");

    System.out.println(">>> Create a Timer object.");
    final Timer timer = new Timer();

    timer.start();

    NotifListener listener = new NotifListener();
    timer.addNotificationListener(listener, null, null);

    ExecutorService executor = Executors.newFixedThreadPool(100);
    final Random rand = new Random();


    for (int i = 0; i < TASK_COUNT; i++) {
        executor.execute(new Runnable() {
            public void run() {
                long dateMillis = System.currentTimeMillis() + fixedDelay + rand.nextInt(2000);
                Date date = new Date(dateMillis);
                timer.addNotification("type", "msg", "userData", date);
            }
        });

    }

    executor.shutdown();
    executor.awaitTermination(20, TimeUnit.SECONDS);

    waitForNotificationsToEnd(listener);

    timer.stop();

    if (listener.count < TASK_COUNT) {
        throw new RuntimeException("Not fired: " + (TASK_COUNT - listener.count));
    } else {
        System.out.println(">>> All notifications handled OK");
    }

    System.out.println(">>> Bye bye!");
}

方法所在类

javax.management.timer.Timer