本文介紹了Java將作業調度為在特定時間運行最長時間段的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
我正在嘗試安排一個應該每10秒運行一次的任務。但是，此任務應該具有動態允許的周期執行時間。換句話說，如果允許的最大時間為5秒，并且任務運行時間超過5秒，則應終止/關閉該任務。
我曾嘗試使用具有cron時間的@Schedule，但無論我嘗試什么，一旦它運行，我就無法終止它。但是，有人建議我不要使用@Schedule，而使用ScheduledExecutorService創建一個普通任務，但我不知道如何操作。
我原來的方法是這樣的：
@Scheduled(cron = "0/10 * * * * ?")
@Transactional
public void testMethod(Integer period) {
ThreadPoolTaskScheduler scheduler;
scheduler.setAwaitTerminationSeconds(period);
scheduler.setWaitForTasksToCompleteOnShutdown(false);
importantMethod();
}
我嘗試將其重寫如下：
public void testMethod(){
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
scheduler.scheduleAtFixedRate(importantMethod(), delay,
period, TimeUnit.SECONDS);
}
但是，我不確定如何將其設置為每10秒或每5分鐘運行一次，并且僅在超過允許的最大時間后才將其關閉。
我們將非常感謝您的幫助。
推薦答案
根據描述，我的假設：
-
任務應每10秒運行一次
任務的最大超時時間應為5秒
最大超時應可配置
應用程序中的配置。屬性
scheduler.timeout = 5000
代碼
@Value("${scheduler.timeout}")
private Long timeout;
@Scheduled(cron = "0/10 * * * * ?")
public void taskScheduler() {
System.out.println("Task Started: " + LocalDateTime.now());
this.executeTask((Callable<Object>) () -> {
TimeUnit.MILLISECONDS.sleep(3000);//Change values for testing: sleep time
System.out.println("Task Worked: " + LocalDateTime.now());
return true;
}, timeout);
}
ExecutorService service = Executors.newFixedThreadPool(1);
ScheduledExecutorService canceller = Executors.newSingleThreadScheduledExecutor();
public <T> Future<T> executeTask(Callable<T> c, long timeoutMS) {
final Future<T> future = service.submit(c);
canceller.schedule(() -> {
if (!future.isDone())
System.out.println("Task Cancelled: " + LocalDateTime.now());
future.cancel(true);
return "done";
}, timeoutMS, TimeUnit.MILLISECONDS);
return future;
}
輸出
任務在3秒內完成時(休眠時間)
Task Started: 2022-02-06T22:42:30.010704200
Task Worked: 2022-02-06T22:42:33.014775100
任務在6秒內完成時(睡眠時間)
Task Started: 2022-02-06T22:47:30.003249500
Task Cancelled: 2022-02-06T22:47:35.013195900
這篇關于Java將作業調度為在特定時間運行最長時間段的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
