import java.time.LocalDateTime;
import java.util.Timer;
import java.util.TimerTask;

public class Schedule {
    public static void main(String[] args) {
        TimerTask timerTask = new TimerTask() {
            @Override
            public void run() {
                System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + " 當(dāng)前時(shí)間" + LocalDateTime.now());
            }
        };
        // 在指定延遲0毫秒后開始，隨后地執(zhí)行以2000毫秒間隔執(zhí)行timerTask 
        new Timer().schedule(timerTask, 0L, 2000L);
        System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + " 當(dāng)前時(shí)間" + LocalDateTime.now());
    }
}

import java.time.LocalDateTime;
import java.util.concurrent.*;

public class Schedule {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)ScheduledThreadPoolExecutor線程池，核心線程數(shù)為5
        ScheduledExecutorService scheduledExecutorService = new ScheduledThreadPoolExecutor(5);
        // 創(chuàng)建Runnable打印當(dāng)前線程和當(dāng)前時(shí)間
        Runnable r = () -> System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + " 當(dāng)前時(shí)間" + LocalDateTime.now());
        /**
         * schedule：只執(zhí)行一次調(diào)度
         * scheduleAtFixedRate：一開始就計(jì)算間隔時(shí)間，如果任務(wù)超過間隔時(shí)間，那么就直接開始下一個(gè)任務(wù)
         * scheduleWithFixedDelay：任務(wù)無(wú)論執(zhí)行多久，都要等待上一輪任務(wù)完成之后再間隔指定時(shí)間，然后才開始下一個(gè)任務(wù)
         */
         // 在指定1秒延遲后執(zhí)行r,之后每?jī)擅雸?zhí)行一次
        scheduledExecutorService.scheduleAtFixedRate(r, 1, 2, TimeUnit.SECONDS);
    }
}

String cron() default "";  // 支持cron表達(dá)式

long fixedDelay() default -1;  // 在最后一次調(diào)用結(jié)束和下一次調(diào)用開始之間的時(shí)間間隔，以毫秒為單位
String fixedDelayString() default "";  // 同上，類似ScheduledExecutorService的scheduleWithFixedDelay

long fixedRate() default -1;  // 在調(diào)用之前的時(shí)間間隔，以毫秒為單位
String fixedRateString() default "";  // 同上，類似ScheduledExecutorService的scheduleAtFixedRate

long initialDelay() default -1;  // 在第一次執(zhí)行fixedRate()或fixedDelay()任務(wù)之前要延遲的毫秒數(shù)
String initialDelayString() default "";  // 同上

import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component
@EnableScheduling
public class Schedule {
    @Scheduled(fixedRate = 2000L)
    public void task() {
        System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + " 當(dāng)前時(shí)間" + LocalDateTime.now());
    }
}

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component
@EnableAsync  // 開啟異步多線程
@EnableScheduling
public class Schedule {

    @Async
    @Scheduled(fixedRate = 2000L)
    public void task() {
        System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + " 當(dāng)前時(shí)間" + LocalDateTime.now());
    }
}

import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.concurrent.Executor;

@Component
@EnableAsync
@EnableScheduling
public class Schedule {

    @Async
    @Scheduled(fixedRate = 2000L)
    public void task() {
        System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + " 當(dāng)前時(shí)間" + LocalDateTime.now());
    }


    @Bean("taskExecutor")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(10);
        taskExecutor.setMaxPoolSize(50);
        taskExecutor.setQueueCapacity(200);
        taskExecutor.setKeepAliveSeconds(60);
        taskExecutor.setThreadNamePrefix("自定義-");
        taskExecutor.setAwaitTerminationSeconds(60);
        return taskExecutor;
    }
}