/**
 * 考核点：线程安全;多线程；volatile使用;线程同步/锁
 * <p>
 * tip:难度稍难，注意卖出重复（剩余有两个相同数量），超卖（库存为0仍然在卖）
 * <p>
 * 题目:
 * 淘宝某商品有库存400
 * 有无数网民抢购但同一瞬间不能超过5个人同时抢购（不断创建线程但线程数不能超过5），超过5个时打印：当前瞬间抢购线程超过5个.等待缺口...
 * 抢购成功打印：抢购成功，剩余xxx
 * 库存为0后结束抢购，结束方法，打印：卖完了。（不再创建线程结束方法）
 */
public class Main04 {

    volatile static int num = 400; // 商品库存
    volatile static int threadNum = 0; // 当前线程数

    public static void main(String[] args) {
        while (true) {
            if (threadNum <= 5) { // 判断线程数
                if (num > 0) {
                    new Thread(() -> {
                        threadNum++; // 线程数+1
                        if (num > 0) {
                            process();  // 执行抢购操作
                        } else {
                            System.out.println("卖完了!");
                            return;
                        }
                        threadNum--; // 线程结束，数-1
                    }).start();
                } else {
                    // 数量清空结束方法
                    System.out.println("卖完了噢！");
                    return;
                }
            } else {
                System.out.println("当前瞬间抢购线程超过5个.等待缺口...");
            }
        }
    }

    /**
     * 执行抢购业务处理
     */
    private static synchronized void process() {
        num--;
        System.out.println("抢购成功，剩余: " + num);
    }


}