32 lines
1.2 KiB
Java
32 lines
1.2 KiB
Java
package com.inmind.thread_safe_sychronized05;
|
|
|
|
//卖票任务:就是卖100张票
|
|
public class TicketTask implements Runnable{
|
|
int ticketCount = 100;//100张票
|
|
Object lock = new Object();//锁对象
|
|
|
|
@Override
|
|
public void run() {
|
|
//有票就卖
|
|
while (true) {
|
|
//这里是3个线程共享的同一个锁对象
|
|
synchronized (lock){//同步代码块：只有拥有锁对象的线程才能进入同步代码块去执行
|
|
//synchronized (new Object()){//执行到这就创建锁对象，那就没有同一个锁对象，解决线程安全的效果（错误）
|
|
//如果有票就卖
|
|
if (ticketCount > 0) {
|
|
//模拟卖票时间
|
|
try {
|
|
Thread.sleep(50);
|
|
} catch (InterruptedException e) {
|
|
e.printStackTrace();
|
|
}
|
|
System.out.println(Thread.currentThread().getName() + "正在卖第" + ticketCount + "张票");
|
|
ticketCount--;
|
|
} else {
|
|
break;//结束循环
|
|
}
|
|
}//当线程执行完毕该同步代码块之后，锁对象就会释放
|
|
}
|
|
}
|
|
}
|