java 模拟售票，多线程的同步与互斥，java互斥,/** * 模拟售票，一

java 模拟售票，多线程的同步与互斥，java互斥,/** * 模拟售票，一

/** * 模拟售票，一个窗口售票，多个买票者购票，票数设为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();        }    }}