DEMO_04:线程安全;多线程;volatile使用;线程同步/锁
/**
* 考核点:线程安全;多线程;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);
}
}
DEMO_04:线程安全;多线程;volatile使用;线程同步/锁DEMO_04:线程安全;多线程;volatile使用;线程同步/锁DEMO_04:线程安全;多线程;volatile使用;线程同步/锁DEMO_04:线程安全;多线程;volatile使用;线程同步/锁DEMO_04:线程安全;多线程;volatile使用;线程同步/锁DEMO_04:线程安全;多线程;volatile使用;线程同步/锁DEMO_04:线程安全;多线程;volatile使用;线程同步/锁DEMO_04:线程安全;多线程;volatile使用;线程同步/锁DEMO_04:线程安全;多线程;volatile使用;线程同步/锁