本文介紹了Java將作業(yè)調(diào)度為在特定時間運行最長時間段的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)吧！
問題描述
我正在嘗試安排一個應(yīng)該每10秒運行一次的任務(wù)。但是，此任務(wù)應(yīng)該具有動態(tài)允許的周期執(zhí)行時間。換句話說，如果允許的最大時間為5秒，并且任務(wù)運行時間超過5秒，則應(yīng)終止/關(guān)閉該任務(wù)。
我曾嘗試使用具有cron時間的@Schedule，但無論我嘗試什么，一旦它運行，我就無法終止它。但是，有人建議我不要使用@Schedule，而使用ScheduledExecutorService創(chuàng)建一個普通任務(wù)，但我不知道如何操作。
我原來的方法是這樣的：
@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);
}
但是，我不確定如何將其設(shè)置為每10秒或每5分鐘運行一次，并且僅在超過允許的最大時間后才將其關(guān)閉。
我們將非常感謝您的幫助。
推薦答案
根據(jù)描述，我的假設(shè)：
-
任務(wù)應(yīng)每10秒運行一次
任務(wù)的最大超時時間應(yīng)為5秒
最大超時應(yīng)可配置
應(yīng)用程序中的配置。屬性
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;
}
輸出
任務(wù)在3秒內(nèi)完成時(休眠時間)
Task Started: 2022-02-06T22:42:30.010704200
Task Worked: 2022-02-06T22:42:33.014775100
任務(wù)在6秒內(nèi)完成時(睡眠時間)
Task Started: 2022-02-06T22:47:30.003249500
Task Cancelled: 2022-02-06T22:47:35.013195900
這篇關(guān)于Java將作業(yè)調(diào)度為在特定時間運行最長時間段的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
