Java BlockingQueue while() while 루프

Question

put()을 사용하여 스레드에 의해 채워지는 BlockingQueue가 있습니다. 하지만 BlockingQueue를 take()하는 방법에 대해서는 혼란 스럽다. 현재 다음과 같이 구현했습니다.

String link; 
try { 
    while(!(link = links.take()).isEmpty()) { 
     System.out.println(link); 
    } 
} catch(InterruptedException ex) { 
    ex.printStackTrace(); 
} 

맞습니까? 조건문 안에 있지 않으면 큐를 반복하고 문자열 변수를 어떻게 할당 할 수 있습니까?

Answer 1

정확하게 이해했다면, 조건 외의 take 방법을 요청 했습니까? 글쎄, 그 어렵지 않다 :

while (!links.isEmpty()) { 
    try { 
     String link = links.take(); 
     // Do stuff. 
    } catch (InterruptedException e) { 
     // Exception handling. 
    } 
} 

현재 상태 !(link = links.take()).isEmpty() 검사 반환 값이-A가 아닌 큐 (길이가 0 일) 빈 문자열-경우.

어쨌든 위의 코드는 atomic이 아니므로 links.isEmpty()과 links.take() 사이에 아무 것도 발생하지 않는다고 보장 할 수 없습니다.

편집 :

BlockingQueue<Integer> numbers = new ArrayBlockingQueue<>(10); 
AtomicBoolean flag = new AtomicBoolean(true); 

// Producer. 
new Thread(() -> { 
    for (int i = 0; i < 10; i++) { 
     try { 
      numbers.put(i); 
     } catch (InterruptedException e) { /* NOP */ } 
    } 
    flag.set(false); 
}).start(); 

// Consumer. 
while (flag.get() || !numbers.isEmpty()) { 
    try { 
     System.out.println(numbers.take()); 
    } catch (InterruptedException e) { /* NOP */ } 
} 

AtomicBoolean 여기에 필요하지 않지만 여러 제작자 및/또는 소비자가 있다면 그것은 편리한 될 수 있습니다 당신은 플래그와 함께 시작하는 동안 race conditions를 처리 할 수 ​​있습니다. 또한 체크 아웃해야하는 java.util.concurrent의 일부입니다.

Answer 2

내 이해는 좋은 방법으로 BlockingQueue를 종료하는 방법을 묻는 것입니다. 내가 생각할 수있는 두 가지 시나리오가 있습니다. 어떤 경우 든 메시지 생성자 A와 메시지 소비자 B가 있습니다.

1. 메시지 생성자는 "정지"와 같은 터미널 값 형식을 보냅니다. 당신은 그것을 확인하고 while주기가 끝납니다.
2. 소비자 측에서 InterruptedException을 throw하는 메시지 생성자를 중단 할 수 있습니다. 터미널 입력을 피하는 방법입니다. 여기서 문제는 소비자가 큐에있는 모든 것을 실제로 사용했다면 제어 할 수 없다는 것입니다. 그래서 인터 럽션은 소비가 즉시 종료되어야하는 조건이있는 경우에 주로 사용됩니다.