/**
* 模拟售票，一个窗口售票，多个买票者购票，票数设为50 主要是利用线程间的同步于互斥
*
* 同步：线程2必须在线程1完成后才能进行
* 互斥:线程2和线程3访问同一变量，一次只能有一个线程访问
*
* @author
*
*/
public class SaleTicket {
public static void main
(String[] args
) { Ticket t = new Ticket(50);
setTicket set = new setTicket(t);// 售票线程
set.start();
// 买票线程
for (int i = 1; i <= 52; i++) {
getTicket get = new getTicket(t, "买票者 " + i + " ");
get.start();
}
}
}
//票对象
class Ticket {
private int ticketNum;// 票数
boolean write = false;// 售票与买票间的同步信号量，同一时间只有一张票卖出
boolean read = true;// 买票者 买票间的信号量，一张票只能卖给一个人
public Ticket(int ticketNum) {
this.ticketNum = ticketNum;
}
// 取票，票数减一
// 售票员正忙，买票者进行等待
while (!write && read) {
System.
out.
println("*****************************" + name
+ " 买票等待。。。");
this.wait();
}
write = false;// 某个买票者要买票，售票员办理即进行等待
if (ticketNum > 0) {
read = false;// 让其他买票者等待
System.
out.
println("*****************************" + name
+ " 买票成功，号码=" + ticketNum);
this.subTicketNum();// 销售一张票
read = true;// 让其他买票者进行买票
this.notifyAll();
} else {// 票数为0
read = false;
System.
out.
println("*****************************票已经售完， " + name
+ " 没有买到票");
}
}
// 售票
public synchronized void sellTicket
(String name
) // 只要票数大于0，售票员就一直进行售票
while (ticketNum > 0) {
while (write) {
// 进行售票
System.
out.
println(name
+ " 处理业务，售票等待。。。"); this.wait();
}
if (ticketNum > 0) {
System.
out.
println(name
+ " 开始售票，号码=" + ticketNum
); }
write = true;
this.notifyAll();
}
System.
out.
println(name
+ " 对不起，售票已经售完！"); }
public void subTicketNum() {
if (this.ticketNum > 0)
this.ticketNum = this.ticketNum - 1;
}
public int getTicketNum() {
return ticketNum;
}
}
// 购票者
class getTicket
extends Thread { Ticket d;// 包含剩余票数
public getTicket
(Ticket d,
String name
) { this.d = d;
this.name = name;
}
public void run() {
try {
d.getTicket(name);
e.printStackTrace();
}
}
}
// 售票员
class setTicket
extends Thread { Ticket d;
public setTicket(Ticket d) {
this.d = d;
}
public void run() {
try {
d.sellTicket("售票员 1 ");
e.printStackTrace();
}
}
}
//java/5703