環(huán)境：Spring Boot3.2.5

1. 簡介

在本篇文章中，我們將學(xué)習(xí)如何控制定時任務(wù)僅運(yùn)行一次。定時任務(wù)是自動化諸如報告生成或發(fā)送通知等過程的常見做法。通常，我們設(shè)置這些任務(wù)定期運(yùn)行。然而，在某些情況下，我們可能希望一個任務(wù)在未來的某個時間點(diǎn)僅執(zhí)行一次，例如初始化資源或進(jìn)行數(shù)據(jù)遷移等操作。

接下來將探討在Spring Boot應(yīng)用中如何控制定時任務(wù)僅運(yùn)行一次的幾種方法。本文將通過帶有初始延遲的@Scheduled注解，到更靈活的方法，如TaskScheduler和自定義觸發(fā)器來避免任務(wù)的重復(fù)執(zhí)行。

2. 實(shí)戰(zhàn)案例

2.1 僅指定開始時間

雖然@Scheduled注解提供了一種直接的任務(wù)調(diào)度方式，但在靈活性方面做的不夠好。當(dāng)需要對任務(wù)規(guī)劃進(jìn)行更多控制（比如針對一次性執(zhí)行的任務(wù)）時，Spring的TaskScheduler接口提供了多功能的替代方案。使用TaskScheduler，我們可以以編程方式安排任務(wù)，并指定任務(wù)的開始時間，從而為動態(tài)調(diào)度場景提供了更大的靈活性。

TaskScheduler中最簡單的方法允許我們定義一個Runnable任務(wù)和一個Instant，表示我們希望任務(wù)執(zhí)行的具體時間。這種方法使我們能夠動態(tài)地安排任務(wù)，而不必依賴于固定的注解，如下示例：

public class TaskComponent {
  private TaskScheduler taskScheduler = new SimpleAsyncTaskScheduler() ;
  public void schedule(Runnable task, Instant startTime) {
    taskScheduler.schedule(task, startTime) ;
  }
}

TaskScheduler中的所有其他方法都是用于周期性執(zhí)行的，因此這個方法對于一次性任務(wù)很有幫助。

注：這里我們使用了SimpleAsyncTaskScheduler，如果你的環(huán)境是Spring6.1以上版本，那么你還可以通過設(shè)置為虛擬線程執(zhí)行任務(wù)。

SimpleAsyncTaskScheduler scheduler = new SimpleAsyncTaskScheduler();
scheduler.setVirtualThreads(true) ;

接下來，我們可以通過如下方式測試該種方式的定時任務(wù)執(zhí)行

@Test
public void testOnceTask() {
  CountDownLatch cdl = new CountDownLatch(1) ;


  scheduler.schedule(() -> {
    cdl.countDown();
    // TODO, 任務(wù)Action
  }, Instant.now().plus(Duration.ofSeconds(1))) ;
  latch.await() ;
}

這里僅僅是因?yàn)橥ㄟ^單元測試時需要通過CountDownLatch進(jìn)行協(xié)助測試。生產(chǎn)環(huán)境無需這樣。

2.2 通過@Scheduled方式

我們還可以使用@Scheduled注解并設(shè)置初始延遲時間，同時不要設(shè)置fixedDelay或fixedRate屬性，如下示例：

@Component
public class TaskComponent {
  @Scheduled(initialDelay = 3000)
  public void task() {
    // TODO, 任務(wù)Action
  }
}

該方法在指定的初始化3s后執(zhí)行任務(wù)之后不會重復(fù)執(zhí)行。

2.3 自定義觸發(fā)器

我們還可以通過實(shí)現(xiàn)PeriodicTrigger，使用PeriodicTrigger我們可以進(jìn)行更多的控制任務(wù)執(zhí)行。通過重寫nextExecution()方法，以便僅在我們尚未觸發(fā)的情況下返回下一個執(zhí)行時間，如下示例：

public class PackTrigger extends PeriodicTrigger {
  public PackTrigger(Instant when) {
    super(Duration.ofSeconds(1)) ;
    Duration difference = Duration.between(Instant.now(), when) ;
    setInitialDelay(difference) ;
  }
  
  @Override
  public Instant nextExecution(TriggerContext triggerContext) {
    if (triggerContext.lastCompletion() == null) {
      return super.nextExecution(triggerContext) ;
    }
    // 返回null后將不會再執(zhí)行
    return null;
  }
}

由于我們只希望它執(zhí)行一次，因此可以將周期設(shè)置為任意值。最終，需要為我們的初始延遲傳遞一個Duration，因此我們需要計算任務(wù)期望執(zhí)行時刻與當(dāng)前時間之間的差值。

重寫nextExecution方法，如果完成狀態(tài)為null，則表示它尚未觸發(fā)，因此允許它調(diào)用默認(rèn)實(shí)現(xiàn)。否則，返回null，這將使此觸發(fā)器僅執(zhí)行一次，調(diào)用示例如下：

TaskScheduler taskScheduler = new SimpleAsyncTaskScheduler() ;
taskScheduler.schedule(() -> {
  System.out.printf("%s, 執(zhí)行任務(wù)%n", Thread.currentThread().getName()) ;
}, new PackTrigger(Instant.now().plusSeconds(2))) ;

通過此種自定義觸發(fā)器的方式更加的靈活控制定時任務(wù)的執(zhí)行，也是當(dāng)前最優(yōu)的選擇。