Java/Java이론

LinkedBlockingQueue: 스레드 안전한 FIFO 큐의 강력한 도구

P_eli 2024. 11. 15. 15:49
728x90
반응형

LinkedBlockingQueue는 Java에서 제공하는 FIFO(First-In-First-Out) 방식의 스레드 안전 큐로, 멀티스레드 환경에서 매우 유용하게 사용됩니다. 특히 생산자-소비자 패턴을 구현할 때 효과적이며, 데이터 스트림 처리나 비동기 작업 큐를 구현하는 데도 적합합니다.

 

1. 주요 특징

  1. 스레드 안전성
    • LinkedBlockingQueue는 내부적으로 락을 사용하여 동기화되므로 멀티스레드 환경에서도 안전하게 사용할 수 있습니다.
    • 생산자(Producer)와 소비자(Consumer)가 각각 다른 락을 사용해 효율성을 높였습니다.
  2. FIFO 방식
    • 큐에 데이터를 추가하면 가장 먼저 추가된 데이터가 가장 먼저 처리됩니다.
    • 이는 작업의 순서를 보장해야 하는 환경에 적합합니다.
  3. 유한 또는 무한 큐 크기
    • 생성 시 큐의 용량을 설정할 수 있습니다. 기본적으로 무한 크기로 설정되지만, 용량을 설정하면 큐가 가득 찼을 때 생산자는 대기 상태로 전환됩니다.
  4. 차단(Blocking) 동작 지원
    • 큐가 비어 있거나 가득 찬 경우, 데이터를 가져오거나 추가하려는 스레드는 자동으로 대기 상태로 전환됩니다.
    • 이는 스레드가 효율적으로 자원을 사용할 수 있게 합니다.

2. 주요 메서드

메서드 설명
put(E e) 큐가 가득 찬 경우 대기하며, 데이터 삽입이 가능한 상태가 되면 데이터를 추가합니다.
take() 큐가 비어 있는 경우 대기하며, 데이터가 추가되면 가장 오래된 데이터를 가져옵니다.
offer(E e) 데이터를 즉시 추가하며, 큐가 가득 찬 경우 실패합니다.
poll() 데이터를 즉시 가져오며, 큐가 비어 있는 경우 null을 반환합니다.
size() 큐에 있는 현재 요소의 개수를 반환합니다.

 

3. 사용 예제

아래는 LinkedBlockingQueue를 이용한 간단한 생산자-소비자 패턴의 예제입니다.

import java.util.concurrent.LinkedBlockingQueue;

public class ProducerConsumerExample {
    public static void main(String[] args) throws InterruptedException {
        // LinkedBlockingQueue 생성
        LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>();

        // 생산자 스레드
        Thread producer = new Thread(() -> {
            try {
                for (int i = 1; i <= 5; i++) {
                    String task = "Task " + i;
                    System.out.println("Producing: " + task);
                    queue.put(task); // 큐에 데이터 추가 (차단 모드)
                    Thread.sleep(500); // 작업 간격
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        // 소비자 스레드
        Thread consumer = new Thread(() -> {
            try {
                while (true) {
                    String task = queue.take(); // 큐에서 데이터 가져오기 (차단 모드)
                    System.out.println("Consuming: " + task);
                    Thread.sleep(1000); // 처리 시간
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        // 스레드 시작
        producer.start();
        consumer.start();

        // 메인 스레드에서 두 스레드가 작업을 마칠 때까지 대기
        producer.join();
        consumer.interrupt(); // 소비자 스레드 종료
    }
}

 

결과

위 코드의 실행 결과는 다음과 같습니다.

 

4. 동작 설명

  • 생산자(Producer): put 메서드를 통해 큐에 데이터를 추가합니다. 큐가 가득 차면 공간이 생길 때까지 대기합니다.
  • 소비자(Consumer): take 메서드를 통해 큐에서 데이터를 가져옵니다. 큐가 비어 있으면 데이터가 추가될 때까지 대기합니다.
  • 스레드 간 동기화: LinkedBlockingQueue는 자체적으로 동기화를 관리하므로, 추가적인 락이나 동기화 코드가 필요 없습니다.

5. 주요 활용 사례

  1. 생산자-소비자 패턴
    멀티스레드 환경에서 작업을 분리하고 큐를 사용해 작업 순서를 보장할 수 있습니다.
  2. 비동기 작업 처리
    서버 요청을 비동기로 처리하거나, 백그라운드 작업 큐로 활용할 수 있습니다.
  3. 데이터 스트림 처리
    실시간 데이터 처리에서 데이터를 안전하게 수집하고 처리할 수 있습니다.

6. 장단점

장점

  • 스레드 안전성 보장
  • 차단 메서드 제공으로 대기와 통지를 손쉽게 구현 가능
  • 큐 용량 제한으로 메모리 사용 제어 가능

단점

  • 동기화 오버헤드로 인해 단일 스레드 환경에서는 성능이 저하될 수 있음

7. 마무리

LinkedBlockingQueue는 스레드 간 안전한 데이터 교환을 제공하며, 복잡한 멀티스레드 환경에서도 손쉽게 사용할 수 있는 강력한 도구입니다. 차단 메서드와 FIFO 구조를 활용하면 효율적이고 안정적인 데이터 처리를 구현할 수 있습니다.

이 큐를 사용하면 코드의 가독성과 안정성이 크게 향상되며, 특히 멀티스레드 프로그램에서 발생할 수 있는 동기화 문제를 자연스럽게 해결할 수 있습니다.

728x90
반응형