ScheduledExecutorService在超時後中斷

Question

我需要實現一個計劃的執行器服務，該服務每隔x秒在一個時間間隔內運行一個線程。 如果線程執行時間超過了y秒，則應該中斷線程。 我試圖使用ScheduledExecutorService實現解決方案，該解決方案具有間隔的可配置參數，但沒有用於超時的參數。 我有一些想法，我想聽聽你對實現/技術的建議。

Answer 1

這是否有幫助？任務每10秒開始一次，需要5秒鐘完成，當超時（3秒）時您將得到InterruptedException。

import com.google.common.util.concurrent.Futures; 
import com.google.common.util.concurrent.ListenableFuture; 
import com.google.common.util.concurrent.ListeningExecutorService; 
import com.google.common.util.concurrent.MoreExecutors; 
import java.util.Date; 
import java.util.concurrent.Executors; 
import java.util.concurrent.ScheduledExecutorService; 
import java.util.concurrent.TimeUnit; 

public class Worker implements Runnable { 
    ListeningExecutorService listeningExecutorService; 
    ScheduledExecutorService scheduledExecutorService; 
    Runnable task; 

    public Worker(ListeningExecutorService listeningExecutorService, ScheduledExecutorService scheduledExecutorService, Runnable task) { 
     this.listeningExecutorService = listeningExecutorService; 
     this.scheduledExecutorService = scheduledExecutorService; 
     this.task = task; 
    } 

    @Override 
    public void run() { 
     ListenableFuture future = listeningExecutorService.submit(task); 
     Futures.withTimeout(future, 3, TimeUnit.SECONDS, scheduledExecutorService); 
    } 

    public static void main(String[] args) { 
     ListeningExecutorService listeningExecutorService = MoreExecutors 
      .listeningDecorator(Executors.newCachedThreadPool()); 
     ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5); 
     Worker worker = new Worker(listeningExecutorService, scheduledExecutorService, new Runnable() { 
      @Override 
      public void run() { 
       System.out.println("Now begin: " + new Date()); 
       try { 
        Thread.sleep(5000); 
       } catch (InterruptedException e) { 
        e.printStackTrace(); 
       } 
       System.out.println("Now end: " + new Date()); 
      } 
     }); 
     scheduledExecutorService.scheduleAtFixedRate(worker, 0, 10, TimeUnit.SECONDS); 
    } 
}