Java 超时一组指令

Question

是否可以在java中为一组指令设置超时？我有以下几点：

    new Thread(new Runnable(){
            public void run() {
                    //instructions
                    for(...){
                     ....
                    }
                    //instructions2
            }}).start();

我想为循环设置超时，如果达到时间，则继续正常使用说明2。在循环中，我有几个函数调用（一个稍微复杂的组织），并且可能会在其中任何一个调用中被阻塞，从而导致长时间循环。

提前谢谢。

Answer 1

假设您的阻塞函数响应中断，您可以使用超时的未来。如果他们不这样做，你就无能为力了......请注意，使用下面的方法，您不再需要手动启动线程。

    ExecutorService forLoopExecutor = Executors.newSingleThreadExecutor();
    Future<?> future = forLoopExecutor.submit(new Runnable() {
        @Override
        public void run() {
            //your for loop here
        }
    });
    try {
        future.get(1, TimeUnit.SECONDS); //your timeout here
    } catch (TimeoutException e) {
        future.cancel(true);
    }
    forLoopExecutor.shutdownNow();
    //proceed with the rest of your code
    forLoopExecutor.submit(aRunnableForInstructions2);

Answer 2

也许这个例子可以帮助你

    long l = System.currentTimeMillis();
    final long TIMEOUTMILLIS = 1000;
    for(;;){
        System.out.println("bla bla bla");
        if(System.currentTimeMillis()>l+TIMEOUTMILLIS){
            break;
        }
    }

您可以计算花费的时间并离开循环。

另一种策略是在指定的时间后中断线程。我希望这有帮助

Answer 3

如果您要在 for 循环内的任何地方捕获InterruptedException，请删除所有这些 try/catch 块，取而代之的是围绕整个 for 循环的单个 try/catch。 这将允许整个 for 循环在您中断其线程时停止。

同样，如果您要捕捉IOException，请先捕捉InterruptedIOException并ClosedByInterruptException。 将这些捕获块移到 for 循环之外。 （如果您在内部捕获IOException，编译器将不允许这样做，因为在外部级别不会捕获任何内容。

如果阻塞调用没有抛出InterruptedException，则需要在每个调用之后添加一个检查，如下所示：

if (Thread.interrupted()) {
    break;
}

如果有多个级别的循环，则可能需要添加标签，以便直接从第一个"指令"循环中退出，无需添加很多标志变量：

instructions:
for ( ... ) {
    for ( ... ) {
        doLongOperation();
        if (Thread.interrupted()) {
            break instructions;
        }
    }
}

无论哪种方式，一旦处理了中断，您就可以让后台线程中断您的第一个 for 循环：

final Thread instructionsThread = Thread.currentThread();
Runnable interruptor = new Runnable() {
    public void run() {
        instructionsThread.interrupt();
    }
};
ScheduledExecutorService executor =
    Executors.newSingleThreadScheduledExecutor();
executor.schedule(interruptor, 5, TimeUnit.MINUTES);
// instructions
try {
    for ( ... ) {
    }
} catch (InterruptedException |
         InterruptedIOException |
         ClosedByInterruptException e) {
    logger.log(Level.FINE, "First loop timed out.", e);
} finally {
    executor.shutdown();
}
// instructions2