java scheduled

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

public class ScheduledTaskExample {

    public static void main(String[] args) {
        // 创建一个ScheduledExecutorService实例，线程池大小为1
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

        // 定义一个Runnable任务
        Runnable task = () -> System.out.println("任务执行时间: " + System.currentTimeMillis());

        // 安排任务在初始延迟为0秒后，每隔2秒执行一次
        scheduler.scheduleAtFixedRate(task, 0, 2, TimeUnit.SECONDS);

        // 让主线程等待一段时间，以确保调度的任务有足够的时间执行
        try {
            Thread.sleep(10000); // 等待10秒
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 关闭调度器
        scheduler.shutdown();
    }
}

解释说明：

• ScheduledExecutorService：这是一个接口，提供了方法来安排命令的未来执行。它支持定时和周期性任务的执行。
• Executors.newScheduledThreadPool(int corePoolSize)：创建一个线程池，可以安排命令在给定的延迟后运行，或者定期执行。
• scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)：安排指定的 Runnable 命令，在初始延迟后开始，并且以固定的频率重复执行。
• Thread.sleep(long millis)：使当前正在执行的线程暂停执行指定的毫秒数。
• shutdown()：启动一次顺序关闭，执行以前提交的任务，但不接受新任务。

这段代码会每2秒打印一次当前时间戳，持续10秒后结束。