正文

Java计时器中断技巧：轻松掌握暂停与恢复方法

/0 浏览量
1028

在Java编程中，计时器（如Thread或ScheduledExecutorService）的中断和恢复是处理异步任务和长时间运行任务时常用的技巧。掌握这些技巧可以帮助开发者更有效地管理程序流程，提高代码的健壮性和响应性。本文将详细介绍Java中计时器中断的技巧，包括如何暂停和恢复计时器。

暂停计时器

使用Thread类

在Java中，你可以通过调用Thread对象的interrupt()方法来中断一个线程。当线程处于阻塞状态时，如sleep()、join()或等待某个对象锁时，interrupt()方法会抛出InterruptedException。

以下是一个使用Thread类暂停计时器的示例：

public class Timer {
    public static void main(String[] args) throws InterruptedException {
        Thread timerThread = new Thread(() -> {
            try {
                while (true) {
                    System.out.println("Timer is running...");
                    Thread.sleep(1000); // 模拟计时器运行
                }
            } catch (InterruptedException e) {
                System.out.println("Timer thread was interrupted.");
            }
        });

        timerThread.start();

        // 暂停计时器
        Thread.sleep(5000);
        timerThread.interrupt();
    }
}

使用ScheduledExecutorService

对于ScheduledExecutorService，你可以通过调用shutdown()方法来暂停所有已提交的任务，并通过awaitTermination()等待直到所有任务完成。

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledTimer {
    public static void main(String[] args) throws InterruptedException {
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

        // 添加一个周期性任务
        scheduler.scheduleAtFixedRate(() -> {
            System.out.println("Scheduled task is running...");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                System.out.println("Scheduled task was interrupted.");
            }
        }, 0, 1, TimeUnit.SECONDS);

        // 暂停计时器
        Thread.sleep(5000);
        scheduler.shutdown();
        scheduler.awaitTermination(1, TimeUnit.SECONDS);
    }
}

恢复计时器

使用Thread类

要恢复被中断的线程，你可以简单地再次调用interrupt()方法。但是，如果线程已经处理了InterruptedException，你可能需要重新设置中断状态。

public class Timer {
    public static void main(String[] args) {
        Thread timerThread = new Thread(() -> {
            try {
                while (true) {
                    System.out.println("Timer is running...");
                    Thread.sleep(1000); // 模拟计时器运行
                }
            } catch (InterruptedException e) {
                System.out.println("Timer thread was interrupted.");
                Thread.currentThread().interrupt(); // 重新设置中断状态
            }
        });

        timerThread.start();

        // 中断计时器
        timerThread.interrupt();

        // 恢复计时器
        timerThread.interrupt();
    }
}

使用ScheduledExecutorService

对于ScheduledExecutorService，一旦调用shutdown()，你无法直接恢复。但是，你可以创建一个新的ScheduledExecutorService实例来重新启动任务。

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledTimer {
    public static void main(String[] args) throws InterruptedException {
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

        // 添加一个周期性任务
        scheduler.scheduleAtFixedRate(() -> {
            System.out.println("Scheduled task is running...");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                System.out.println("Scheduled task was interrupted.");
            }
        }, 0, 1, TimeUnit.SECONDS);

        // 暂停计时器
        scheduler.shutdown();
        scheduler.awaitTermination(1, TimeUnit.SECONDS);

        // 恢复计时器
        scheduler = Executors.newScheduledThreadPool(1);
        scheduler.scheduleAtFixedRate(() -> {
            System.out.println("Scheduled task is running...");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                System.out.println("Scheduled task was interrupted.");
            }
        }, 0, 1, TimeUnit.SECONDS);
    }
}

通过上述方法，你可以轻松地在Java中暂停和恢复计时器。这些技巧对于处理长时间运行的任务和异步操作非常有用，可以帮助你更好地控制程序流程。

-- 展开阅读全文 --