자바에서 무한 루프를 죽이는

Question

제 3 자 라이브러리를 사용하여 많은 데이터 세트를 처리하고 있습니다. 이 프로세스는 매우 가끔씩 무한 루프에 빠지거나 차단됩니다. 이유는 모르지만 코드에 들어갈 수는 없습니다. 정해진 시간 후에 이것을 죽이고 다음 사건으로 넘어 가고 싶습니다. 간단한 예는 다음과 같습니다.

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

processData는 일반적으로 최대 1 초가 걸립니다. 10 초 후에 processData()를 죽이는 타이머를 설정하고 싶습니다.

EDIT (실 사용에 익숙하지 않습니다.) 코드 스 니펫을 고맙게 생각합니다. Executor 접근법은 유용하게 보이지만 시작할 방법을 잘 모릅니다. 또한 더 일반적인 접근 방식의 의사 코드는 코딩하기에는 너무 일반적입니다.

@Steven Schlansker - 타사 앱이 인터럽트를 예상하지 않으면 작동하지 않는다고 제안합니다. 다시 세부 사항과 예제가 인정 될 것입니다.

EDIT 제 동료 인 샘 애덤스가 원했던 정확한 해결책을 얻었습니다. 그것은 다른 답변보다 더 자세한 내용을 가지고 있지만, 나는 그들에게 두 표를 줄 것이다. Sam을 승인 된 응답으로 표시합니다.

Answer 1

샘 아담스는 나에게 다음과 같은 답을 보내, 내 하나의

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 예외의 자연적인 결과로) 로크되었음을 모니터 모두 해제시킨다 어떤 경우. 스레드를 중지 이전에 이러한 모니터로 보호 된 개체가 일관성이없는 상태 였기 때문에 손상된 개체가 다른 스레드에서 볼 수있게되어 잠재적 인 결과가 발생할 수 있습니다. "

나는 두 번째를 구현했으며 현재 내가 원하는 것을 수행한다.

Answer 2

다른 스레드에서 라이브러리 호출을 호출하고 시간 초과 후이 스레드를 종료합니다. 그렇게하면 서로 종속적이지 않으면 여러 객체를 동시에 처리 할 수 ​​있습니다.

---

편집 : 당신은 개선하고 확장 할 수 있도록 Democode 요청

이것은 의사 코드입니다. 또한 전화가 성공적인지 여부를 확인하는 데 오류가 발생했는지 여부는 도움이됩니다.

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

ExecutorService.invokeAll(...) 중 하나는 시간 초과 인수를 사용합니다. 라이브러리를 호출하는 하나의 Callable을 작성하여 List에 랩핑하여 해당 메소드의 인수로 사용하십시오. 반환 된 미래는 그것이 어떻게 진행되었는지 나타냅니다.

(참고 : 나에 의하여 검증되지 않은)