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毫秒后開(kāi)始，隨后地執(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：一開(kāi)始就計(jì)算間隔時(shí)間，如果任務(wù)超過(guò)間隔時(shí)間，那么就直接開(kāi)始下一個(gè)任務(wù)
? ? ? ? ?* scheduleWithFixedDelay：任務(wù)無(wú)論執(zhí)行多久，都要等待上一輪任務(wù)完成之后再間隔指定時(shí)間，然后才開(kāi)始下一個(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)用開(kāi)始之間的時(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 ?// 開(kāi)啟異步多線程
@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;
? ? }
}