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); 
    } 
}