我的代碼是這樣的：ScheduledExecutorService executor = Executors.newScheduledThreadPool(8);//complex code that call this multiple times too add tasks:executor.schedule(() -> { doRealTask(); }, 0, TimeUnit.MICROSECONDS);//drain the pool on some condition, e.g. meets tasks that can't be parallelized:executor.shutdown();//without this, awaitTermination won't return since all the threads in the pool will be paused, not terminatedexecutor.awaitTermination(1000000, TimeUnit.SECONDS);//continue to add more tasks:executor.schedule(...);最后一個代碼拋出 java.util.concurrent.RejectedExecutionException 。原因似乎是執行器已關閉。但沒有“startAgain”功能。顯然創建一個新的 ScheduledExecutorService 是有效的，但我覺得我使用了錯誤的解決方案。如何在Java中實現這個？
2 回答
三國紛爭
TA貢獻1804條經驗 獲得超7個贊
將您的 future 存儲在列表中，然后使用 get 有效地加入。
List<Future<?>> futures = new ArrayList<>();
futures.add(executor.schedule(() -> { doRealTask(); }, 0, TimeUnit.MICROSECONDS));
而不是關閉。
for(Future<?> future: futures){
future.get();
}
futures.clear();
現在您需要處理異常，并且可能在獲取時包含超時。
心有法竹
TA貢獻1866條經驗 獲得超5個贊
關閉狀態是不可逆的，因此如果需要，只需創建一個新的執行器即可。沒有其他方法可以重用之前的方法。但是，如果您要再次創建它，為什么需要關閉它呢？如果它有太多任務，并且您可以犧牲它們來換取新任務，那么為每個任務配置合理的超時并配置池本身（例如池和任務隊列大小）是有意義的。
每次調用Executor.schedule(() -> { doRealTask(); }, 0, TimeUnit.MICROSECONDS);都會返回ScheduledFuture實例，您可以存儲它并稍后處理結果。
添加回答
舉報
0/150
提交
取消