Jaehyeon's Thread Code Review

Thread/src/main/java/com/nhnacademy/jaehyeon/practice/Consumer.java

@@ -0,0 +1,29 @@
+package com.nhnacademy.jaehyeon.practice;
+
+import java.util.concurrent.ThreadLocalRandom;
+
+public class Consumer implements Runnable {
+
+    Mart mart;
+    String name;
+    int item;
+
+    public Consumer(String name, Mart mart, int item) {
+        this.name = name;
+        this.mart = mart;
+        this.item = item;
+    }
+
+    @Override
+    public void run() {
+        this.mart.getStore(this.item).enter();
+        try {
+            Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 10000));
+            this.mart.getStore(this.item).buy();
+
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        this.mart.getStore(this.item).exit();
+    }
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/practice/Main.java

@@ -0,0 +1,33 @@
+package com.nhnacademy.jaehyeon.practice;
+
+import java.util.concurrent.ThreadLocalRandom;
+
+public class Main {
+    public static void main(String[] args) {
+
+        int storeNumber = 5;
+        Mart mart = new Mart(storeNumber);
+
+        for (int i = 0; i < storeNumber; i++) {
+            Thread producerThread = new Thread(new Producer(mart, i));
+            producerThread.start();
+        }
+
+        int count = 0;
+        while (true) {
+            try {
+                Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 1500));
+            } catch (InterruptedException e) {
+
+            }
+
+            for (int i = 0; i < storeNumber; i++) {
+                count++;
+                Thread consumerThread = new Thread(new Consumer("Consumer " + count, mart, i));
+                consumerThread.start();
+            }
+
+
+        }
+    }
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/practice/Mart.java

@@ -0,0 +1,26 @@
+package com.nhnacademy.jaehyeon.practice;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class Mart {
+    List<Store> storeList;
+    int storeNumber;
+
+    public Mart(int storeNumber) {
+        this.storeList = new ArrayList<>();
+        this.storeNumber = storeNumber;
+
+        for (int i = 0; i < storeNumber; i++) {
+            this.storeList.add(new Store());
+        }
+    }
+
+    public Store getStore(int item) {
+        if (item >= 0 && item < storeNumber) {
+            return this.storeList.get(item);
+        } else {
+            return null;
+        }
+    }
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/practice/Producer.java

@@ -0,0 +1,25 @@
+package com.nhnacademy.jaehyeon.practice;
+
+import java.util.concurrent.ThreadLocalRandom;
+
+public class Producer implements Runnable {
+    Mart mart;
+    int item;
+
+    public Producer(Mart mart, int item) {
+        this.mart = mart;
+        this.item = item;
+    }
+
+    @Override
+    public void run() {
+        while (true) {
+            this.mart.getStore(item).sell();
+            try {
+                Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 1500));
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/practice/Store.java

@@ -0,0 +1,66 @@
+package com.nhnacademy.jaehyeon.practice;
+
+import java.util.concurrent.Semaphore;
+import java.util.concurrent.atomic.AtomicInteger;
+
+public class Store {
+
+    private static final int MAX_PRODUCT_COUNT = 10;
+    private static final int MAX_PERSON_COUNT = 5;
+
+    AtomicInteger consumerCount;
+    AtomicInteger productCount;
+
+    Semaphore semaphore;
+
+    public Store() {
+        this.consumerCount = new AtomicInteger(0);
+        this.productCount = new AtomicInteger(0);
+        semaphore = new Semaphore(MAX_PERSON_COUNT);
+    }
+
+    public void enter() {
+        try {
+            semaphore.acquire();
+        } catch (InterruptedException e) {
+            //TODO
+        }
+
+        this.consumerCount.addAndGet(1);
+        System.out.println("손님 입장");
+
+    }
+
+    public void exit() {
+        this.consumerCount.addAndGet(-1);
+        System.out.println("손님 퇴장");
+
+        semaphore.release();
+    }
+
+    public synchronized void buy() {
+        while (productCount.get() == 0) {
+            try {
+                wait();
+            } catch (InterruptedException e) {
+                //TODO
+            }
+        }
+        System.out.println("손님이 물건을 샀습니다.");
+        productCount.addAndGet(-1);
+        notifyAll();
+    }
+
+    public synchronized void sell() {
+        while (productCount.get() >= MAX_PRODUCT_COUNT) {
+            try {
+                wait();
+            } catch (InterruptedException e) {
+                //TODO
+            }
+        }
+        System.out.println("물건을 납품했습니다.");
+        productCount.addAndGet(1);
+        notifyAll();
+    }
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/store/Consumer.java

@@ -0,0 +1,36 @@
+package com.nhnacademy.jaehyeon.store;
+
+import java.util.concurrent.ThreadLocalRandom;
+
+public class Consumer implements Runnable {
+    Store store;
+    String name;
+    static int count = 0;
+
+    public Consumer(Store store) {
+        this.store = store;
+        this.name = "Consumer" + count++;
+    }
+
+
+
+
+    @Override
+    public void run() {
+        try {
+            store.enter(this);
+            Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 5000));
+            store.sell();
+            store.exit(this);
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        }
+
+
+    }
+
+    @Override
+    public String toString() {
+        return name;
+    }
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/store/Main.java

@@ -0,0 +1,27 @@
+package com.nhnacademy.jaehyeon.store;
+
+import java.util.concurrent.ThreadLocalRandom;
+
+public class Main {
+    public static void main(String[] args) {
+        Store store = new Store();
+        Thread consumer = new Thread(new Consumer(store));
+        Thread producer = new Thread(new Producer(store));
+
+        consumer.start();
+        producer.start();
+        while (true) {
+            try {
+                Thread thread = new Thread(new Consumer(store));
+                Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 5000));
+                thread.start();
+            } catch (InterruptedException e) {
+
+            }
+
+        }
+
+    }
+
+
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/store/Producer.java

@@ -0,0 +1,31 @@
+package com.nhnacademy.jaehyeon.store;
+
+import java.util.concurrent.ThreadLocalRandom;
+
+public class Producer implements Runnable {
+    int count;
+    Store store;
+
+    public Producer(Store store) {
+        this.store = store;
+        count = 0;
+    }
+
+    public Product makeProduct() {
+        count++;
+        return new Product(count);
+    }
+
+    @Override
+    public void run() {
+        while(true){
+            try {
+                Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 2000));
+                store.buy(makeProduct());
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+        }
+
+    }
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/store/Product.java

@@ -0,0 +1,9 @@
+package com.nhnacademy.jaehyeon.store;
+
+public class Product {
+    int number;
+
+    public Product(int number) {
+        this.number = number;
+    }
+}

Thread/src/main/java/com/nhnacademy/jaehyeon/store/Store.java

@@ -0,0 +1,61 @@
+package com.nhnacademy.jaehyeon.store;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class Store {
+    volatile List<Product> productList;
+    List<Consumer> consumerList;
+
+    private static final int MAX_PRODUCT_COUNT = 10;
+    private static final int MAX_CONSUMER_COUNT = 5;
+
+    public Store() {
+        this.productList = new ArrayList<>();
+        this.consumerList = new ArrayList<>();
+    }
+
+    public synchronized void enter(Consumer consumer) {
+        while (this.consumerList.size() >= MAX_CONSUMER_COUNT) {
+
+                System.out.println("꽉찼습니다 기다려주세요");
+
+        }
+        this.consumerList.add(consumer);
+        System.out.println(consumer + "이 들어왔습니다.");
+    }
+
+    public synchronized void exit(Consumer consumer) {
+        System.out.println(consumer + "이 나갑니다");
+        this.consumerList.remove(consumer);
+        notifyAll();
+
+    }
+
+    public synchronized void buy(Product product) {
+        while (this.productList.size() >= MAX_PRODUCT_COUNT) {
+            try {
+                wait();
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+        }
+        System.out.println("물건 샀습니다.");
+        this.productList.add(product);
+        notifyAll();
+    }
+
+    public synchronized void sell() {
+        while (this.productList.isEmpty()) {
+            try {
+                wait();
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+        }
+        System.out.println("물건 팔았습니다");
+        this.consumerList.remove(0);
+        notifyAll();
+
+    }
+}