java 模拟售票，多线程的同步与互斥

模拟售票，一个窗口售票，多个买票者购票，票数设为50 主要是利用线程间的同步于互斥
同步：线程2必须在线程1完成后才能进行
互斥:线程2和线程3访问同一变量，一次只能有一个线程访问

/**
 * 模拟售票，一个窗口售票，多个买票者购票，票数设为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;
	}
	// 取票，票数减一
	public synchronized void getTicket(String name) throws InterruptedException {
		// 售票员正忙，买票者进行等待
		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)
			throws InterruptedException {
		// 只要票数大于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;// 包含剩余票数
	String name;// 购票者姓名
	public getTicket(Ticket d, String name) {
		this.d = d;
		this.name = name;
	}
	public void run() {
		try {
			d.getTicket(name);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}
// 售票员
class setTicket extends Thread {
	Ticket d;
	public setTicket(Ticket d) {
		this.d = d;
	}
	public void run() {
		try {
			d.sellTicket("售票员 1 ");
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}