如何在超时 x 次后停止任务答案

【问题标题】：How to stop a task after it's timed out x times如何在超时 x 次后停止任务
【发布时间】：2013-03-11 00:18:00
【问题描述】：

我尝试执行 runnable 几次，如果它没有在 x 秒内完成 3 次，我将取消它。

我用来模拟需要取消任务的情况的代码如下。从输出中我可以看到一个 InterruptedException 被抛出并被相应地捕获，但任务继续运行。

似乎前两次任务在 TimeoutException 被抛出 3 次之前运行，这两次运行一直运行直到它们完成。我想知道是否有办法阻止这两次运行完成？

public class SomeClass {

private static int c =0;

public static void main(String[] args){
    Runnable dummyRunnable = new Runnable() {

        @Override
        public void run() {
            System.out.println("Hello from dummyRunnable!");        

                for (int i =0; i< 10; i++){
                    try {
                        //simulate work here
                        if (!Thread.currentThread().isInterrupted()) Thread.sleep(5000);
                        System.out.println("thread sleeps for the " + i + " time!");    
                    } catch (InterruptedException ie){
                        System.out.println("InterruptedException catched in dummyRunnable!");   
                        //Thread.currentThread().interrupt(); //this has no effects
                        break;

                    }
                }



        }
    }; 


    BlockingQueue<Runnable> blockingQueue = new ArrayBlockingQueue<Runnable>(10 * 3, true);
    ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 3, Long.MAX_VALUE, TimeUnit.MILLISECONDS, blockingQueue);

    for (int i =0; i< 5; i++){
        Future<?> task = executor.submit(dummyRunnable);

        try{
            Thread.sleep(1000);
            task.get(2000, TimeUnit.MILLISECONDS);
        } catch (TimeoutException te){
            c++;
            System.out.println("TimeoutException from a task!");
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (ExecutionException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            if (c==3){
                System.out.println("cancelling task...");
                task.cancel(true);
                break;
            }
        }
    }
     }
}

【问题讨论】：

OP被封禁了！我们应该回答这个问题吗？ :\

标签： java multithreading

【解决方案1】：

我不明白你真正想要模拟的是什么。我希望有一个模拟，比如用卡支付（60 秒超时来完成一项任务），或者可能是医生和病人情况下的秘书。

按照现在的方式，您正在未来创建 5 个对象。如果你想更多地控制你的线程，你应该考虑使用同步方法和一个为你处理线程的监视器。

通常在启动线程时应该使用

new Thread(new Task(object or generics)).start();
Thread.sleep(2000); // calls this thread to wait 2 secs before doing other task(s)

在做一些核心并发（多线程）之前，你应该阅读一些java教程以获得一些灵感...... http://docs.oracle.com/javase/tutorial/essential/concurrency/index.html

【讨论】：