thread upload

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/Consumer.java

@@ -0,0 +1,59 @@
+package org.example.thread.assignment01;
+
+import java.util.Random;
+import java.util.concurrent.ThreadLocalRandom;
+
+public class Consumer implements Runnable {
+    private Store store;
+    private String name;
+    private Random random;
+    public static int count = 0;
+
+    public Consumer(String name, Store store) {
+        this.store = store;
+        this.name = name + ++count;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    @Override
+    public void run() {
+        try {
+            store.enter(this);
+            sellRandomTime();
+            store.exit(this);
+        } catch (IllegalArgumentException e) {
+            System.out.println(e.getMessage());
+        }
+    }
+
+    private void sellRandomTime() {
+        try {
+            Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 10000));
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            System.out.println("Thread Interrupted");
+        }
+        pickFoods();
+    }
+
+    public void pickFoods() {
+        int productNum = randomProductNum();
+        int amount = randomAmount();
+        Product product = store.getFoodStand().getFoodsList().get(productNum);
+        store.getFoodStand().sell(product, amount);
+    }
+
+    private int randomAmount() {
+        random = new Random();
+        return random.nextInt(10) + 1;
+    }
+
+    private int randomProductNum() {
+        random = new Random();
+        return random.nextInt(store.getFoodStand().getFoodsList().size());
+    }
+
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/FoodStand.java

@@ -0,0 +1,36 @@
+package org.example.thread.assignment01;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+public class FoodStand {
+    private List<Product> productList;
+
+    public FoodStand() {
+        this.productList = new ArrayList<>();
+    }
+
+
+    public List<Product> getFoodsList() {
+        return this.productList;
+    }
+
+    public void add(Product product, int amount) {
+        if(productList.contains(product)) {
+            product.add(amount);
+        } else {
+            productList.add(product);
+        }
+    }
+
+    public void sell(Product product, int amount) { //상품 판매
+        if(productList.contains(product)) {
+            product.sell(amount);
+        } else {
+            throw new IllegalArgumentException("해당 상품이 존재하지 않습니다.");
+        }
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/Main.java

@@ -0,0 +1,21 @@
+package org.example.thread.assignment01;
+
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+public class Main {
+    public static void main(String[] args) throws InterruptedException {
+        Store store = new Store();
+        Producer producer = new Producer(store);
+        Thread producerThread = new Thread(producer);
+        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
+        Runnable consumerTask = () -> {
+            Consumer consumer = new Consumer("Consumer", store);
+            Thread consumerThread = new Thread(consumer);
+            consumerThread.start();
+        };
+        executorService.scheduleAtFixedRate(consumerTask, 0, 5, TimeUnit.SECONDS);
+        producerThread.start();
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/Producer.java

@@ -0,0 +1,62 @@
+package org.example.thread.assignment01;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Random;
+import java.util.concurrent.ThreadLocalRandom;
+import org.example.thread.assignment01.product.*;
+
+public class Producer implements Runnable {
+    private Store store;
+    private List<Product> itemList;
+    private Random random;
+
+    public Producer(Store store) {
+        this.store = store;
+        this.itemList = new ArrayList<>();
+        initialSetting();
+    }
+
+    private void initialSetting() {
+        itemList.add(new Vegetable("야채", 30));
+        itemList.add(new ProcessedFood("조리 식품", 30));
+        itemList.add(new DriedSeafood("건어물", 30));
+        itemList.add(new CannedFoods("기호 식품", 30));
+        itemList.add(new OtherItems("기타", 30));
+    }
+
+    @Override
+    public void run() {
+        while (!Thread.interrupted()) {
+            try {
+                Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 5000));
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+                System.out.println("Thread Interrupted");
+            }
+
+            randomDelivery();
+        }
+    }
+
+    private void randomDelivery() {
+        int deliveryNum = randomDeliveryNum();
+        int amount = randomAmount();
+        Product product = bringProduct(deliveryNum);
+        store.getFoodStand().add(product, amount);
+
+    }
+    private int randomAmount() {
+        random = new Random();
+        return random.nextInt(10) + 1;
+    }
+
+    private int randomDeliveryNum() {
+        random = new Random();
+        return random.nextInt(itemList.size());
+    }
+
+    private Product bringProduct(int deliveryNum) {
+        return itemList.get(deliveryNum);
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/Product.java

@@ -0,0 +1,60 @@
+package org.example.thread.assignment01;
+
+public class Product {
+
+    private String name;
+    private int amount;
+    public static final int MAX_NUM = 30;
+    public Product(String name, int amount) {
+        this.name = name;
+        this.amount = amount;
+    }
+    public String getName() {
+        return name;
+    }
+
+    public synchronized boolean isAbleBuy(int amount) {
+        if (amount > 30) {
+            System.out.println(this.name + "의 재고는 30개까지만 가능합니다.");
+            return false;
+        }
+        if (this.amount + amount > MAX_NUM) {
+            System.out.println(this.name + "의 재고는 30개까지만 가능합니다.");
+            return false;
+        }
+        return true;
+    }
+
+    public synchronized boolean isAbleSell(int amount) {
+        return (this.amount - amount >= 0);
+    }
+
+    public synchronized void add(int amount) {
+        while (!isAbleBuy(amount)) {
+            try {
+                wait();
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+        }
+        this.amount += amount;
+        System.out.printf("%s %d개가 가판대에 추가 되었습니다.\n", this.name, amount);
+        notifyAll();
+    }
+
+    public synchronized void sell(int amount) { //상품 판매
+        while (!isAbleSell(amount)) {
+            try {
+                wait();
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+        }
+        if(isAbleSell(amount)) {
+            this.amount -= amount;
+            System.out.printf("%s %d개 구매 완료.\n", this.name, amount);
+            System.out.printf("남은 %s의 수량: %d\n", this.name, this.amount);
+            notifyAll();
+        }
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/Store.java

@@ -0,0 +1,51 @@
+package org.example.thread.assignment01;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class Store {
+    private List<Consumer> people;
+
+    private FoodStand foodStand;
+
+    public static final int PEOPLE_NUM_LIMIT = 5;
+
+    public Store() {
+        people = new ArrayList<>();
+        foodStand = new FoodStand();
+    }
+
+    public FoodStand getFoodStand() {
+        return foodStand;
+    }
+
+    public synchronized boolean isAbleEnter() {
+        return people.size() < PEOPLE_NUM_LIMIT;
+    }
+
+    public synchronized void enter(Consumer consumer) {
+        if (consumer == null) {
+            throw new IllegalArgumentException("consumer is null");
+        }
+        while (!isAbleEnter()) {
+            try {
+                System.out.println("대기중입니다 ...");
+                wait();
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+        }
+        people.add(consumer);
+        System.out.println(consumer.getName() + " enter");
+    }
+
+    public synchronized void exit(Consumer consumer) {
+        if (people.contains(consumer)) {
+            people.remove(consumer);
+            System.out.println(consumer.getName() + " exit");
+            notifyAll();
+        }
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/product/CannedFoods.java

@@ -0,0 +1,9 @@
+package org.example.thread.assignment01.product;
+
+import org.example.thread.assignment01.Product;
+
+public class CannedFoods extends Product {
+    public CannedFoods(String name, int amount) {
+        super(name, amount);
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/product/DriedSeafood.java

@@ -0,0 +1,9 @@
+package org.example.thread.assignment01.product;
+
+import org.example.thread.assignment01.Product;
+
+public class DriedSeafood extends Product {
+    public DriedSeafood(String name, int amount) {
+        super(name, amount);
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/product/OtherItems.java

@@ -0,0 +1,9 @@
+package org.example.thread.assignment01.product;
+
+import org.example.thread.assignment01.Product;
+
+public class OtherItems extends Product {
+    public OtherItems(String name, int amount) {
+        super(name, amount);
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/product/ProcessedFood.java

@@ -0,0 +1,9 @@
+package org.example.thread.assignment01.product;
+
+import org.example.thread.assignment01.Product;
+
+public class ProcessedFood extends Product {
+    public ProcessedFood(String name, int amount) {
+        super(name, amount);
+    }
+}

Thread/src/main/java/com/nhnacademy/gaeun/assignment01/product/Vegetable.java

@@ -0,0 +1,9 @@
+package org.example.thread.assignment01.product;
+
+import org.example.thread.assignment01.Product;
+
+public class Vegetable extends Product {
+    public Vegetable(String name, int amount) {
+        super(name, amount);
+    }
+}