• 스레드가 작업을 실행하고 있을 때 강제로 멈추도록 하는 방법은 없지만, 특정 스레드에게 작업을 멈춰 달라고 인터럽트 (interrupt) 요청을 할 수 있다.
• 작업이나 서비스를 실행하는 부분의 코드를 작성할 때 멈춰달라는 요청을 받으면, 진행 중이던 작업을 모두 정리한 다음 종료하도록 만들어야 한다.
  • 작업을 진행하던 스레드가 직접 마무리하는 것이 가장 적절하다.

7.1 작업 중단

취소 가능 (cancellable)

외부 프로그램이 특정 작업의 정상적인 실행 진행 순서를 뛰어 넘어 종료 상태에 이르도록 할 수 있다면, 해당 작업은 취소 가능하다.

• 실행 중인 작업을 취소하는 경우
  • 사용자가 취소하기를 요청한 경우
  • 시간이 제한된 작업을 작성한 경우
  • 애플리케이션 이벤트
    • 여러 작업을 동시에 실행시키고 원하는 값을 얻었다면 나머지 작업을 모두 취소한다.
  • 오류
  • 종료

협력적인 방법 (cooperative mechanism)

작업을 실행하는 스레드와 작업을 취소했으면 요청하는 스레드가 함께 작업을 멈추는 협력적인 방법을 사용해야만 한다. 협력적인 방법 가운데 가장 기본적인 형태는 취소 요청이 들어왔다는 플래그를 설정하고, 실행 중인 작업은 취소 요청 플래그를 주기적으로 확인하는 방법이다.

• 취소 요청 플래그를 설정하고 주기적으로 확인하도록 작성하기

  @ThreadSafe
  public class PrimeGenerator implements Runnable {
      @GuardedBy("this")
      private final List<BigInteger> primes = new ArrayList<BigInteger>();
      // 취소 요청 플래그를 설정
      private volatile boolean cancelled;
  
      public void run() {
          BigInteger p = BigInteger.ONE;
          // 취소 요청 플래그를 주기적으로 확인
          while (!cancelled) {
              p = p.nextProbablePrime();
              synchronized (this) {
                  primes.add(p);
              }
          }
      }
  
      public void cancel() {
          cancelled = true;
      }
  
      public synchronized List<BigInteger> get() {
          return new ArrayList<BigInteger>(primes);
      }
  }
  

• 취소 요청을 1초 후에 멈추기

  List<BigInteger> aSecondOfPrime() throws InterruptedException {
      PrimeGenerator generator = new PrimeGenerator();
      new Thread(generator).start();
      try {
          SECONDS.sleep(1);
      } finally {
          generator.cancel();
      }
      return generator.get();
  }
  

취소 정책 (cancellation policy)

작업을 취소하려할 때 어떻게, 언제, 어떤 일을 해야하는지 취소 정책을 정의하면 작업을 쉽게 취소할 수 있다.

7.1.1 인터럽트

• BlockingQueue 에서 프로듀서가 블록되었을 때, 컨슈머가 프로듀서의 작업을 취소하는 경우

  • 프로듀서가 put() 하는 속도가 컨슈머가 take() 하는 속도보다 빨라 put() 에서 블로킹되었을 때, 컨슈머가 프로듀서의 cancel() 로 작업을 취소해도 cancelled 변수를 확인할 수 없다.

    class BrokenPrimeProducer extends Thread {
        private final BlockingQueue<BigInteger> queue;
        private volatile boolean cancelled = false;
    
        BrokenPrimeProducer(BlockingQueue<BigInteger> queue) {
            this.queue = queue;
        }
    
        public void run() {
            try {
                BigInteger p = BigInteger.ONE;
                while (!cancelled)
                    queue.put(p = p.nextProbablePrime());
            } catch (InterruptedException consumed) {
            }
        }
    
        public void cancel() {
            cancelled = true;
        }
    }
    
    void consumePrimes() throws InterruptedException {
        BlockingQueue<BigInteger> primes = ...;
        BrokenPrimeProducer producer = new BrokenPrimeProducer(primes);
        producer.start();
        try {
            while (needMorePrimes())
                consume(primes.take());
        } finally {
            producer.cancel();
        }
    }
    

  • 단, 블로킹될 수 있는 라이브러리 가운데 일부는 인터럽트를 걸 수 있다.