5

我正在使用第三方库来处理大量数据集。该过程偶尔会进入无限循环(或被阻止 - 不知道为什么并且无法进入代码)。我想在设定的时间后杀死它并继续下一个案例。一个简单的例子是:

for (Object data : dataList) {
    Object result = TheirLibrary.processData(data);
    store(result);
}

processData 通常最多需要 1 秒。我想设置一个计时器,它会在 10 秒后杀死 processData()

编辑我会很感激一个代码片段(我没有使用线程练习)。Executor 方法看起来很有用,但我不太清楚如何开始。此外,更传统方法的伪代码对我来说太笼统了,无法编码。

@Steven Schlansker - 建议除非第三方应用程序预期中断,否则它将无法工作。再次详细说明和示例将不胜感激

编辑我从同事 Sam Adams 那里得到了我想要的精确解决方案,我将其作为答案附加。它比其他答案更详细,但我会给他们两个投票。我会将 Sam 标记为已批准的答案

4

3 回答 3

10

ExecutorService.invokeAll(...)方法之一采用超时参数。创建一个调用库的 Callable,并将其包装在 List 作为该方法的参数。未来返回表明它是如何进行的。

(注:未经我测试)

于 2010-08-15T22:27:04.047 回答
7

将对库的调用放在另一个线程中,并在超时后终止该线程。这样,如果它们不相互依赖,您也可以同时处理多个对象。


编辑:演示代码请求

这是伪代码,因此您必须改进和扩展它。错误检查天气呼叫是否成功也会有所帮助。

for (Object data : dataList) {
    Thread t = new LibThread(data);
    // store the thread somewhere with an id
    // tid and starting time tstart 
    // threads
    t.start();
    }

while(!all threads finished)
{
    for (Thread t : threads)
    {
        // get start time of thread
        // and check the timeout
        if (runtime > timeout)
        {
            t.stop();
        }
    }
}

class LibThread extends Thread {
    Object data;

    public TextThread(Object data) 
    {
        this.data = data;
    }

    public void processData() 
    {
        Object result = TheirLibrary.processData(data);
        store(result);
    }
}
于 2010-08-15T22:06:18.440 回答
2

Sam Adams 给我发了以下答案,这是我接受的答案

Thread thread = new Thread(myRunnableCode);
thread.start();
thread.join(timeoutMs);
if (thread.isAlive()) {
  thread.interrupt();
}

myRunnableCode定期检查Thread.isInterrupted(),如果返回 true,则干净地退出。

或者,您可以这样做:

Thread thread = new Thread(myRunnableCode);
thread.start();
thread.join(timeoutMs);
if (thread.isAlive()) {
  thread.stop();
}

但是这种方法已被弃用,因为它很危险。

http://download.oracle.com/javase/1.4.2/docs/api/java/lang/Thread.html#stop() “这种方法本质上是不安全的。用 Thread.stop 停止线程会导致它解锁所有它锁定的监视器(作为未检查的 ThreadDeath 异常沿堆栈传播的自然结果)。如果以前受这些监视器保护的任何对象处于不一致状态,则损坏的对象对其他线程可见,可能导致任意行为。”

我已经实现了第二个,它做了我目前想要的。

于 2010-08-16T12:10:43.710 回答