卖票问题，用三个类的咋做不出来了呢？ - 黑马程序员技术交流社区

public class Test13 {
/**
* 编写三各类Ticket、SealWindow、TicketSealCenter分别代表票信息、售票窗口、售票中心。售票中心分配一定数量的票，
* 由若干个售票窗口进行出售，利用你所学的线程知识来模拟此售票过程。
*
* 多个售票窗口一起工作，这是一个多线程考题
*/
public static void main(String[] args) {
// 新建一个售票中心
TicketSealCenter center = new TicketSealCenter();
// 设置好车票出发和目的地，这时候票信息中还没有座位号
center.setTicket("广州", "南宁");
// 分配票的数量
center.setAmount(1000);
// 创建一个售票中心实现Runnable 在run方法中会给加上座位号然后打印
SealWindow seal = new SealWindow(center.getTicket(), center.getAmount());
// 创建线程并执行
Thread t1 = new Thread(seal, "一号窗");
Thread t2 = new Thread(seal, "二号窗");
Thread t3 = new Thread(seal, "三号窗");
t1.start();
t2.start();
t3.start();
}
}
class Ticket {
// 票的属性有座位号跟出发目的地
private int num;
private String off;
private String des;
// 有参构造（参数中不含座位号）以便让售票中心初始化
public Ticket(String off, String des) {
this.off = off;
this.des = des;
}
// 设置座位号让售票窗口打印设置好的票
public void setNum(int num) {
this.num = num;
}
// 票信息
public String toString() {
return off + "------>" + des + "\r\n" + "座位号" + num;
}
}
class SealWindow implements Runnable {
private int amount;
private Ticket ticket;
// 有参构造传入的是要卖的票的信息还有一共可以卖多少张票
public SealWindow(Ticket ticket, int amount) {
this.ticket = ticket;
this.amount = amount;
}
public void run() {
while (true) {
synchronized (this) {
if (amount > 0) {
try {
Thread.sleep(2);
} catch (InterruptedException e) {
}
// 这里就是设置票的座位号设置好打印
ticket.setNum(amount--);
System.out
.println(Thread.currentThread().getName() + "售出：");
System.out.println(ticket.toString());
System.out.println();
} else {
System.out.println("无票可售");
break;
}
}
}
}
}
// 售票中心
class TicketSealCenter {
private int amount;
private Ticket ticke;
//设置总票数
public void setAmount(int amount) {
this.amount = amount;
}
// 分配可以售出的总票数
public int getAmount() {
return amount;
}
//设置票信息的出发地和目的地（不含座位号）
public void setTicket(String off, String des) {
ticke = new Ticket(off, des);
}
//返回票信息（还不含座位号）
public Ticket getTicket() {
return ticke;
}
}

复制代码

public class Test4 {
public static void main(String[] args) {
Ticket ticket = new Ticket("芜湖", 0);
TicketSealCenter tsc1 = new TicketSealCenter(ticket);
SealWindow sw1 = new SealWindow(ticket);
SealWindow sw2 = new SealWindow(ticket);
SealWindow sw3 = new SealWindow(ticket);
// SealWindow sw4 = new SealWindow(ticket);
Thread th1 = new Thread(tsc1);
th1.setName("售票中心");
Thread th2 = new Thread(sw2);
th2.setName("售票窗口1");
Thread th3 = new Thread(sw1);
th3.setName("售票窗口2");
Thread th4 = new Thread(sw3);
th4.setName("售票窗口3");
th1.start();
th2.start();
th3.start();
th4.start();
}
}
class SealWindow implements Runnable {
private Ticket ticket;
public SealWindow(Ticket ticket) {
this.ticket = ticket;
}
@Override
public void run() {
while (true) {
ticket.seal();
try {
Thread.sleep(500);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
class TicketSealCenter implements Runnable {
private Ticket t;
public TicketSealCenter(Ticket t) {
this.t = t;
}
@Override
public void run() {
while (true) {
// 生产芜湖车次的车票
t.pro("芜湖");
}
}
}
class Ticket {
static LinkedList<Ticket> pool = new LinkedList<Ticket>();
private String destination;
private int site = 0;
public Ticket(String destination, int site) {
this.destination = destination;
this.site = site;
}
private boolean flag = false;
private Lock lock = new ReentrantLock();
private Condition con_pro = lock.newCondition();
private Condition con_seal = lock.newCondition();
public void pro(String des) {
lock.lock();
try {
while (flag) {
con_pro.await();
}
//每次生产若干票
int num = (int) (Math.random() * 10)+1;
for (int i = 0; i < num; i++) {
Ticket t = new Ticket(des, site++);
pool.addFirst(t);
System.out.println(Thread.currentThread().getName() + "生产了"
+ t.toString());
}
flag = true;
con_seal.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
/**
* 这个方法被若干线程操作
*/
public void seal() {
lock.lock();
try {
while (!flag) {
con_seal.await();
}
if (pool.size() > 0) {
// 如果有票，售票窗口就开始卖票并打印信息
System.out.println(Thread.currentThread().getName() + "售出了"
+ pool.removeLast().toString());
} else {
// 如果没有有票，唤醒售票中心线程生产票
flag = false;
con_pro.signal();
}
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
lock.unlock();
}
}
@Override
public String toString() {
// destination车次第site座
return destination + "车次第" + site + "座";
}
}

复制代码