@@ -0,0 +1,69 @@
+package thread.bounded;
+
+import util.MyLogger;
+import util.ThreadUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class BoundedMain {
+    public static void main(String[] args) {
+
+        // 1. BoundedQueue 선택
+        BoundedQueue queue = new BoundedQueueV1(2);
+
+        // 2. 생산자, 소비자 실행 순서 선택, 반드 하나만 선탹!
+//        producerFirst(queue);
+        consumerFirst(queue);
+    }
+
+    private static void producerFirst(BoundedQueue queue){
+        MyLogger.log("== [생산자 먼저 실행] 시작, " + queue.getClass().getSimpleName() + "  == ");
+        List<Thread> threads = new ArrayList<>();
+        startProducer(queue, threads);
+        printAllState(queue, threads);
+        startConsumer(queue, threads);
+        printAllState(queue, threads);
+        MyLogger.log("== [생산자 먼저 실행] 종료, " + queue.getClass().getSimpleName() + "  == ");
+    }
+
+    private static void consumerFirst(BoundedQueue queue){
+        MyLogger.log("== [소비자 먼저 실행] 시작, " + queue.getClass().getSimpleName() + "  == ");
+        List<Thread> threads = new ArrayList<>();
+        startConsumer(queue, threads);
+        printAllState(queue, threads);
+        startProducer(queue, threads);
+        printAllState(queue, threads);
+        MyLogger.log("== [소비자 먼저 실행] 종료, " + queue.getClass().getSimpleName() + "  == ");
+    }
+
+    private static void startConsumer(BoundedQueue queue, List<Thread> threads) {
+        System.out.println();
+        MyLogger.log("소비자 시작");
+        for (int i = 1; i <= 3; i++) {
+            Thread consumer = new Thread(new ConsumerTask(queue), "consumer" + i);
+            threads.add(consumer);
+            consumer.start();
+            ThreadUtils.sleep(100);
+        }
+    }
+
+    private static void startProducer(BoundedQueue queue, List<Thread> threads){
+        System.out.println();
+        MyLogger.log("생성자 시작");
+        for (int i = 1; i <= 3; i++) {
+            Thread producer = new Thread(new ProducerTask(queue, "data" + i), "proudcer" + i);
+            threads.add(producer);
+            producer.start();
+            ThreadUtils.sleep(100);
+        }
+    }
+    private static void printAllState(BoundedQueue queue, List<Thread> threads) {
+        System.out.println();
+        MyLogger.log("현제 상태 출력, 큐 데이터 : " + queue);
+        for(Thread thread : threads) {
+            MyLogger.log(thread.getName() + ": " + thread.getState());
+        }
+
+    }
+}
@@ -0,0 +1,8 @@
+package thread.bounded;
+
+public interface BoundedQueue {
+
+    void put(String data);
+
+    String take();
+}
@@ -0,0 +1,36 @@
+package thread.bounded;
+
+import util.MyLogger;
+
+import java.util.ArrayDeque;
+import java.util.Queue;
+
+public class BoundedQueueV1 implements BoundedQueue{
+    private final Queue<String> queue = new ArrayDeque<>();
+    private final int max;
+
+    public BoundedQueueV1(int max) {
+        this.max = max;
+    }
+
+    @Override
+    public synchronized void put(String data) {
+        if(queue.size() == max){
+            MyLogger.log("[put] 큐가 가득 참, 버림 : " + data);
+            return;
+        }
+        queue.offer(data);
+    }
+
+    @Override
+    public synchronized String take() {
+        if(queue.isEmpty()) return null;
+        return queue.poll();
+    }
+
+    @Override
+    public String toString() {
+        // toString도 sychronized 를 원래는 붙혀줘야 된다.
+        return queue.toString();
+    }
+}
@@ -0,0 +1,19 @@
+package thread.bounded;
+
+import util.MyLogger;
+
+public class ConsumerTask implements Runnable {
+
+    private BoundedQueue queue;
+
+    public ConsumerTask(BoundedQueue queue) {
+        this.queue = queue;
+    }
+
+    @Override
+    public void run() {
+        MyLogger.log("[소비 시도]     ? <- " + queue);
+        String data = queue.take();
+        MyLogger.log("[소비 완료] " + data + " <- " + queue);
+    }
+}
@@ -0,0 +1,23 @@
+package thread.bounded;
+
+import util.MyLogger;
+
+public class ProducerTask implements Runnable{
+
+    private BoundedQueue queue;
+    private String request;
+
+    public ProducerTask(BoundedQueue queue, String request) {
+        this.queue = queue;
+        this.request = request;
+    }
+
+    @Override
+    public void run() {
+        MyLogger.log("[생산 시도] " + request + " -> " + queue);
+        queue.put(request);
+        MyLogger.log("[생산 완료] " + request + " -> " + queue);
+
+
+    }
+}