Java에서 루핑 스레드 중지 중

Question

대기열에서 계속해서 읽는 스레드를 사용하고 있습니다.

public void run() { 
    Object obj; 
    while(true) { 
     synchronized(objectsQueue) { 
      if(objectesQueue.isEmpty()) { 
       try { 
        objectesQueue.wait(); 
       } catch (InterruptedException e) { 
        e.printStackTrace(); 
       } 

       obj = objectesQueue.poll(); 
      } 
     } 

     // Do something with the Object obj 
    } 
} 

이 스레드를 중지하는 가장 좋은 방법은 무엇입니까 : 같은

는

뭔가? - Thread.stop()는되지 않기 때문에, I는 N 원자 체크 조건 변수를 이용하는 stopThisThread() 방법을 구현할 수

1

I는 두 가지 옵션을 참조.

2 - Death Event 개체 또는 그와 비슷한 것을 큐에 보냅니다. 스레드가 종료 이벤트를 가져 오면 종료합니다.

나는 첫 번째 방법을 선호하지만 stopThisThread() 메서드를 호출해야 할 때를 알지 못합니다. 뭔가 큐에있을 수 있고 중지 신호가 먼저 도착할 수 있습니다 (바람직하지 않음).

제안 사항?

Answer 1

DeathEvent (또는 "poison pill"이라고도 함) 접근 방식은 종료하기 전에 대기열에서 모든 작업을 완료해야하는 경우 잘 작동합니다. 문제는 이것이 오랜 시간이 걸릴 수 있다는 것입니다.

가능한 한 빨리 중지하려면

, 나는 당신이 그 run 방법으로 인스턴스화 스레드 t를 중지하려면이

BlockingQueue<O> queue = ... 

... 

public void run() { 
    try { 
     // The following test is necessary to get fast interrupts. If 
     // it is replaced with 'true', the queue will be drained before 
     // the interrupt is noticed. (Thanks Tim) 
     while (!Thread.interrupted()) { 
      O obj = queue.take(); 
      doSomething(obj); 
     } 
    } catch (InterruptedException ex) { 
     // We are done. 
    } 
} 

을 제안, 단순히 t.interrupt();를 호출합니다.

위의 코드를 다른 답변과 비교하면 BlockingQueue 및 Thread.interrupt()을 사용하면 솔루션을 단순화하는 방법을 알 수 있습니다.

나는 또한 여분의 stop 플래그가 불필요하며 큰 그림에서는 잠재적으로 유해하다고 주장 할 것입니다. 잘 작동하는 작업자 스레드는 인터럽트를 존중해야합니다. 예기치 않은 인터럽트는 단순히 원래 프로그래머가 예상하지 못한 상황에서 작업자가 실행되고 있음을 의미합니다. 가장 좋은 방법은 작업자가 수행해야 할 작업을 수행하는 것입니다. 즉, 원래 프로그래머의 개념에 부합하는지 여부와 상관없이 중지해야합니다.

Answer 2

접근법 1이 선호됩니다.

휘발성 stop 필드를 true로 설정하고 실행중인 스레드에서 interrupt()을 호출하기 만하면됩니다. 이것은 InterruptedException을 리턴하기 위해 기다리는 모든 I/O 메소드를 강제 실행합니다 (라이브러리가 올바르게 작성된 경우 정상적으로 처리됩니다).

Answer 3

두 사례가 실제로 같은 잠재적 인 행동을한다고 생각합니다. 두 번째 경우에는 스레드 A가 DeathEvent를 추가 한 후 스레드 B가 FooEvent를 추가하는 것으로 간주합니다. 작업 스레드가 DeathEvent를 받으면 그 뒤에는 여전히 FooEvent가 있습니다. 반환하기 전에 대기열을 지우려고하지 않는 한 옵션 1에서 설명한 것과 같은 시나리오입니다.하지만 실제로 스레드를 유지하고 있습니다. 그것을 막으려 고 노력하고 있습니다.

첫 번째 옵션이 더 바람직하다는 데 동의합니다. 잠재적 인 솔루션은 대기열이 채워지는 방식에 따라 다릅니다.

MyThread extends Thread{ 
    boolean running = true; 

    public void run(){ 
    while(running){ 
     try{ 
     //process queue... 
     }catch(InterruptedExcpetion e){ 
     ... 
     } 
    } 
    } 

    public void stopThisThread(){ 
    running = false; 
    interrupt(); 
    } 

    public boolean enqueue(Object o){ 
    if(!running){ 
     return false; 
     OR 
     throw new ThreadNotRunningException(); 
    } 
    queue.add(o); 
    return true; 
    } 
} 

그것은 다음과 같다 :이 작업 스레드 클래스의 일부분 인 경우에는 해당 stopThisThread을() 메소드는 대기열을 넣는 호출 예에서 적절한 값 (또는 던져 예외) 반환 플래그를 설정 할 수 이벤트를 적절하게 처리하기 위해 이벤트를 큐에 넣으려고하는 객체의 책임.하지만 적어도 이벤트가 대기열에 있지 않고 처리되지 않는다는 것을 알게됩니다.

Answer 4

나는 보통 쓰레드가있는 클래스에 깃발을 넣고, 쓰레드 코드에서는 그렇게 할 것이다. (참고 : while (true) 대신 while (flag))

그런 다음 플래그를 false로 설정하는 클래스의 메서드를 만듭니다.

private volatile bool flag = true; 

public void stopThread() 
{ 
    flag = false; 
} 

    public void run() { 
     Object obj; 
     while(flag) { 
      synchronized(objectsQueue) { 
       if(objectesQueue.isEmpty()) { 
        try { 
         objectesQueue.wait(); 
        } catch (InterruptedException e) { 
         e.printStackTrace(); 
        } 

        obj = objectesQueue.poll(); 
       } 
      } 

      // Do something with the Object obj 
     } 
    } 

Answer 5

리더 스레드에 부울 변수 정지가 있습니다. 이 스레드를 중지하고 thius를 true로 설정하고 스레드를 인터럽트하려는 경우 판독기 스레드 내에서 안전하지 않은 경우 (처리되지 않은 오브젝트가없는 경우) 정지 변수의 상태를 점검하고 설정된 경우 루프에서 리턴하십시오. 아래와 같이

public class readerThread extends Thread{ 
    private volitile boolean stop = false; 
    public void stopSoon(){ 
     stop = true; 
     this.interrupt(); 
    } 
    public void run() { 
     Object obj; 
     while(true) { 
      if(stop){ 
       return; 
      } 
      synchronized(objectsQueue) { 
      if(objectesQueue.isEmpty()) { 
       try { 
        objectesQueue.wait(); 
       } catch (InterruptedException e) { 
        e.printStackTrace(); 
       } 
       if(stop){ 
        return; 
       }  
       obj = objectesQueue.poll(); 
       // Do something with the Object obj 
      } 
     } 
    } 


} 
public class OtherClass{ 
    ThreadReader reader; 
    private void start(){ 
      reader = ...; 
      reader.start(); 
    } 

    private void stop(){ 
      reader.stopSoon(); 
      reader.join();  // Wait for thread to stop if nessasery. 
    } 
} 

Answer 6

왜 필요할 때 간단히 중지 할 수있는 스케줄러를 사용하지 않으시겠습니까? 표준 스케쥴러는 새로운 실행을 다시 스케줄하기 전에 작업자 스레드가 완료되기를 기다리는 반복 스케줄링을 지원합니다.

ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(); 
service.scheduleWithFixedDelay(myThread, 1, 10, TimeUnit.SECONDS); 

이 샘플은 하나의 실행이 완료되면, 그것은 10 초 후에 다시 시작합니다 의미 10 초 지연으로 스레드를 실행됩니다. 그리고 바퀴를 재발 명할 필요없이

service.shutdown() 

while (true)는 더 이상 필요하지 않습니다.

ScheduledExecutorService Javadoc