在java中杀死一个无限循环

Question

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

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

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

编辑 我会很感激一个代码 sn-p （我没有使用线程练习）。 Executor 方法看起来很有用，但我不太清楚如何开始。此外，更传统方法的伪代码对我来说太笼统了。

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

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

Answer 1

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

（注：未经我测试）

Answer 2

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

---

编辑：演示代码请求

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

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

Answer 3

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 异常在堆栈上传播的自然结果）。如果以前受保护的任何对象这些监视器处于不一致的状态，损坏的对象对其他线程可见，可能导致任意行为。”

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