4

我不能使用 Executor 和 Future 来捕获 TimeOutException，因为它是 1.4，如果方法不完整，我需要在 30 秒后超时。

//Caller class
public static void main() {

EJBMethod() // has to timeout after 30 seconds

}

//EJB method in some other class
public void EJBMethod() {

}

我正在考虑的一种方法是将此方法调用包装在 Runnable 中，并在方法结束后从 run() 设置一些 volatile 布尔值。那么，在调用者中，我们可以在调用该方法后休眠 30 秒，一旦醒来，我将检查调用者中的布尔值是否为 SET。如果没有设置，那么我们需要停止该线程。

4

1 回答 1

2

在最简单的情况下，您可以使用 Thread + 任意 Runnable。

如果你想从调用者的角度使调用阻塞，你可以创建一个运行工作线程的“服务”类，并使用Thread.join(long)等待操作完成或在指定超时后放弃它（特别注意正确处理 InterruptedException 以免事情搞砸）。

Thread.isAlive()会告诉你线程是否完成。

检索结果是一个单独的问题；我想你可以处理它...

[编辑]

简单粗暴的例子（不要按原样在生产中使用！）：

/**
 * Actually needs some refactoring
 * Also, did not verify for atomicity - should be redesigned
 */
public V theServiceCall(final T param) {
    final MyResultBuffer<V> buffer = new MyResultBuffer<V>();
    Runnable task = new Runnable() {
        public void run() {
            V result = ejb.process(param);
            buffer.putResult(result);
        }
    }
    Thread t = new Thread(task);
    t.setDaemon(true);
    t.start();
    try {
        t.join(TASK_TIMEOUT_MILLIS);
    } catch (InterruptedException e) {
        // Handle it as needed (current thread is probably asked to terminate)
    }
    return (t.isAlive()) ? null : buffer.getResult();
}

注意：您可以在 Runnable 中实现关闭标志而不是 Thread.setDaemon()，因为这将是一个更好的解决方案。

[/编辑]

于 2013-03-06T12:51:03.450 回答