Spring Bootで動的にジョブスケジューリングを作成する方法

Spring Bootにおける動的タスクスケジューリングの実装では、SpringのTaskSchedulerインターフェースを使用できます。TaskSchedulerインターフェースはタスクスケジューリングを作成、管理するためのメソッドを複数提供します。

まず、Spring Bootアプリケーションの中にTaskScheduler beanを設定する必要があります。ThreadPoolTaskSchedulerというクラスを使ってスレッドプールタスクスケジューラを作成することができます。

@Configuration
@EnableScheduling
public class SchedulerConfig {
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
scheduler.setPoolSize(10);
scheduler.setThreadNamePrefix("MyScheduler-");
scheduler.setAwaitTerminationSeconds(60);
scheduler.setWaitForTasksToCompleteOnShutdown(true);
return scheduler;
}
}

タスクスケジューラBeanをダイナミックなタスクのスケジュールが必要な場所に注入すれば、scheduleメソッドを用いてタスクを作成できるようになります。

@Service
public class MySchedulerService {
@Autowired
private TaskScheduler taskScheduler;
public void createScheduledTask() {
Runnable task = () -> {
// 任务逻辑
System.out.println("Executing scheduled task...");
};
// 创建任务并指定调度规则
Trigger trigger = new CronTrigger("0 0/5 * * * *"); // 每5分钟执行一次
taskScheduler.schedule(task, trigger);
}
}

createScheduledTaskメソッドは説明したコードサンプルのようにcron式を指定することで、定时タスクを生成します。必要に応じてスケジューリングルールを設定できます。

上記コードを実行するには、Springのスケジュール機能を有効にするために、アプリケーション起動時に起動するTaskScheduler beanの設定に@EnableSchedulingアノテーションを追加すること

最後に、createScheduledTask メソッドをアプリケーションの任意の場所で呼び出して、タスク スケジュールを動的に作成できます。

@Autowired
private MySchedulerService schedulerService;
public void someMethod() {
// 创建任务调度
schedulerService.createScheduledTask();
}

上記のコード例では、createScheduledTask メソッドを必要な任意の場所で呼び出すことで、スケジュール済みタスクを動的に作成できます。

bannerAds