Java(자바) BlockingQueue - Producer 및 Consumer 패턴 예제

Java(자바) BlockingQueue - 설명

 

① 멀티 스레드(Multi-Thread) 환경에서 Queue는 다양하게 활용 될 수 있어요.

② BlockingQueue를 사용함으로써 Thread-safe 하게 Producer, Consumer 패턴을 구현할 수 있어요.

③ 보통 RabbitMQ 등과 같이 메세지 처리 및 Push 처리 기술 분야에 활용 되고 있어요.

 

Java(자바) BlockingQueue - Producer 및 Consumer 소스 코드

 

원본코드

//Message 클래스 선언
 
public class Message {
    private String msg;
    
    public Message(String str){
        this.msg=str;
    }
 
    public String getMsg() {
        return msg;
    }
}
 
//Producer 클래스 선언
 
import java.util.concurrent.BlockingQueue;
 
public class Producer implements Runnable{
private BlockingQueue<Message> queue;
    
    public Producer(BlockingQueue<Message> q){
        this.queue=q;
    }
    
    @Override
    public void run() {
        //기본 메세지 삽입
        for(int i=1; i<31; i++){
            Message msg = new Message(""+i);
            try {
                Thread.sleep(i);
                queue.put(msg);
                System.out.println("Produced "+msg.getMsg());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //종료 문자열 삽입
        Message msg = new Message("exit");
        try {
            queue.put(msg);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
 
//Consumer 클래스 선언
 
import java.util.concurrent.BlockingQueue;
 
public class Consumer implements Runnable{
private BlockingQueue<Message> queue;
    
    public Consumer(BlockingQueue<Message> q){
        this.queue=q;
    }
 
    @Override
    public void run() {
        try{
            Message msg;
            //exit 메세지 확인 후 종료
            while((msg = queue.take()).getMsg() !="exit"){
            Thread.sleep(10);
            System.out.println("Consumed "+msg.getMsg());
            }
        }catch(InterruptedException e) {
            e.printStackTrace();
        }
    }
}
 
//실행 클래스 선언
 
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
 
public class ProducerConsumerTest {
    public static void main(String[] args) {
        //사이즈 기본 30 
        BlockingQueue<Message> queue = new ArrayBlockingQueue<Message>(30);
        Producer producer = new Producer(queue);
        Consumer consumer = new Consumer(queue);
        //Producer(생산자) 큐에 메세지 생산 시작
        new Thread(producer).start();
        //Consumer(소비자) 큐로부터 메세지 소비 시작
        new Thread(consumer).start();
        System.out.println("Producer and Consumer 테스트 시작!");
    }
}

실행화면

- 패키지 구조 확인

Java(자바) BlockingQueue - 소스 다운

blockingqueue-example.zip

  자바 API 문서 참고 :  https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingQueue.html