34 lines
1.1 KiB
Java
34 lines
1.1 KiB
Java
package com.inmind.thread_safe_lock07;
|
|
|
|
import java.util.concurrent.locks.Lock;
|
|
import java.util.concurrent.locks.ReentrantLock;
|
|
|
|
//卖票任务:就是卖100张票
|
|
public class TicketTask implements Runnable{
|
|
int ticketCount = 100;//100张票
|
|
Lock lock = new ReentrantLock();//Lock对象
|
|
|
|
@Override
|
|
public void run() {
|
|
//有票就卖
|
|
while (true) {
|
|
// synchronized (lock){//同步代码块：只有拥有锁对象的线程才能进入同步代码块去执行
|
|
lock.lock();//加锁
|
|
//如果有票就卖
|
|
if (ticketCount > 0) {
|
|
try {
|
|
Thread.sleep(50);
|
|
} catch (InterruptedException e) {
|
|
e.printStackTrace();
|
|
}
|
|
System.out.println(Thread.currentThread().getName() + "正在卖第" + ticketCount + "张票");
|
|
ticketCount--;
|
|
} else {
|
|
break;
|
|
}
|
|
lock.unlock();//释放锁
|
|
// }//当线程执行完毕该同步代码块之后，锁对象就会释放
|
|
}
|
|
}
|
|
}
|