package com.example.thread.sample;


import java.util.ArrayList;

class Customer implements Runnable {
    String[] sushiKind = {"광어초밥", "연어초밥", "새우초밥", "계란초밥", "참치초밥"};

    private ConveyorBeltSushi conveyorBeltSushi;
    private String sushi;

    Customer(ConveyorBeltSushi conveyorBeltSushi) {
        this.conveyorBeltSushi = conveyorBeltSushi;
    }

    public void run() {
        while (true) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
            }
            String name = Thread.currentThread().getName();

            //컨베이트 벨트에 있는 초반 중에 선택
            String sushi = conveyorBeltSushi.getOneSushi();
            conveyorBeltSushi.getSushiDish(sushi);
            System.out.println(name + " ate a " + sushi);
        }
    }
}

class SushiChef implements Runnable {
    private ConveyorBeltSushi conveyorBeltSushi;

    SushiChef(ConveyorBeltSushi conveyorBeltSushi) {
        this.conveyorBeltSushi = conveyorBeltSushi;
    }

    public void run() {
        while (true) {
            int idx = (int)(Math.random()*conveyorBeltSushi.getSushiKindCnt());
            conveyorBeltSushi.putSushiDish(conveyorBeltSushi.sushiKind[idx]);

            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
            }
        }
    }
}

class ConveyorBeltSushi {
    String[] sushiKind = {"광어초밥", "연어초밥", "새우초밥", "계란초밥", "참치초밥"};
    final int MAX_FOOD = 10;
    private ArrayList<String> sushiDishes = new ArrayList<>();


    //초밥을 만들어서 회전벨트에 놓음
    public synchronized void putSushiDish(String sushi) {
        //회전벨트에 초밥갯수가 10개 이상이되면 초밥을 만들지 않고 기다림
        while(sushiDishes.size() >= MAX_FOOD) {
            String name = Thread.currentThread().getName();
            System.out.println(name + " is waiting");

            try {
                //대기 - Lock을 풀고 대기하다, 통지를 받으면 Lock을 재획득(RUNNABLE(실행대기) 상태)
                wait();
                Thread.sleep(500);
            } catch (InterruptedException e) {}
        }
        //초밥 생성함
        sushiDishes.add(sushi);

        notify();//대기 중인 쓰레드를 깨움(RUNNABLE(실행대기) 상태)
        System.out.println("Dishes : " + sushiDishes.toString());
    }

    //초밥을 회전벨트에서 가져감
    public void getSushiDish(String sushi) {
        synchronized (this) {
            String name = Thread.currentThread().getName();

            while(sushiDishes.size() == 0) {
                System.out.println(name + " is waiting");

                try {
                    wait();//Custom 쓰레드를 기다리게 한다.(Waiting Pool로 보냄)
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                }
            }

            while(true) {
                for (int i=0; i<sushiDishes.size(); i++) {
                    if (sushi.equals(sushiDishes.get(i))) {
                        sushiDishes.remove(i);
                        notify();//잠자고 있는 Cook 을 깨우기 위함(RUNNABLE(실행대기) 상태)
                        return;
                    }
                }

                //음식이 없는 경우 Custom 쓰레드를 기다리게 한다.
                try {
                    wait();//COOK 쓰레드를 기다리게 한다.(Waiting Pool로 보냄)
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                }
            }
        }
    }

    public int getSushiKindCnt() {
        return sushiKind.length;
    }

    /**
     * 컨베이트 벨트에 있는 초반 중에 선택
     */
    public String getOneSushi() {
        double random=Math.random();
        int num = (int)Math.round(random * (sushiDishes.size()-1));
        return sushiDishes.get(num);
    }
}

/**
 * wait(), notify()
 * - 동기화의 효율을 높이기 위해 wait(), notify() 사용
 * - wait() : 객체의 lock을 풀고 쓰레드를 해당 객체의 waiting pool에 넣는다.
 * - notify() : waiting pool 에서 대기중인 쓰레드 중의 하나를 꺠운다.
 * - notifyAll() : waiting pool 에서 대기중인 모든 쓰레드를 깨운다.
 */
public class ExWaitNotify {

    public static void main(String... args) throws Exception {
        ConveyorBeltSushi conveyorBeltSushi = new ConveyorBeltSushi();

        new Thread(new SushiChef(conveyorBeltSushi), "To make sushi").start();

        //고객1과 고객2는 "광어초밥", "연어초밥"을 먹는 쓰레드
        new Thread(new Customer(conveyorBeltSushi), "CUSTOMER1").start();
        new Thread(new Customer(conveyorBeltSushi), "CUSTOMER2").start();
        Thread.sleep(5000);
        //System.exit(0);
    }
}