今天写了个售票 - 黑马程序员技术交流社区

/**
* 三个类ticket，sealWindow,ticketSealCenter,代表票信息，售票窗口，售票中心，售票中心分配一定数量的票（多个窗口实现多线程售票）
* @author Administrator
*思路：对象票（临界资源，共享）、售票窗口（买票、退票）、售票中心（管理票：添加，减少）
*三者关系：临界资源票作为资源供售票中心管理，售票窗口的操作作为售票中中心的代理进行(这里图简便直接继承)
*/
public class TicketThread {
public static void main(String[] args) {
final SealWindow sealWindow = new SealWindow();
ExecutorService threadPool = Executors.newFixedThreadPool(10);
for(int i=0;i<10;i++){
Runnable runnable = new Runnable(){
@Override
public void run(){
try {
Thread.sleep(1000);
Ticket ticket =sealWindow.getTicket();
System.out.println(ticket);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
threadPool.execute(runnable);
}
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
sealWindow.addTickets();
}
}
//售票窗口
class SealWindow extends TicketSealCenter{
}
//售票中心：管理票（目前只考虑同样的票）--1.票池 2.数量 3.添加、清除、修改、查找功能
class TicketSealCenter{
private Ticket[] ticketPool = new Ticket[5];
//票数总量
private int count;
//存数索引
private int putptr;
//取数索引
private int takeptr;
//对象锁
private Lock lock = new ReentrantLock();
//无票线程控制信号
private Condition ticketNotEmpty = lock.newCondition();
//添加线程控制信号
private Condition ticketAdd = lock.newCondition();
/**
* 添加票
*/
public void add(Ticket ticket){
//上锁
lock.lock();
//判断票池大小是否足够（足够，添加；否则，扩容再添加）
try {
if(ticketPool.length<=count){
ticketAdd.await();
Ticket[] newTicketPool = new Ticket[ticketPool.length+10];
System.arraycopy(ticketPool, 0, newTicketPool, 0, ticketPool.length);
ticketPool = newTicketPool;
}
ticketPool[putptr++]=ticket;
count++;
if(putptr==ticketPool.length){
putptr=0;
}
ticketNotEmpty.signal();
} catch (InterruptedException e) {
e.printStackTrace();
}
lock.unlock();
}
/**
* 添加多张票
*/
public void addTickets(){
for(int i=1;i<100;i++){
this.add(new Ticket("第"+i+"","张火车票"));
}
}
/**
* 查看是否有票
* @return
*/
public boolean hasTicket(){
return count>0;
}
/**
* 取票
*/
public Ticket getTicket(){
//上锁
lock.lock();
Ticket ticket = null;
//判断是否有票，若有票，则取票。否则，阻塞等待(使用while 防止伪唤醒)
try {
while(!this.hasTicket()){
ticketNotEmpty.await();
}
ticket = ticketPool[takeptr];
takeptr++;
if(takeptr==ticketPool.length){
takeptr = 0;
}
count--;
ticketAdd.signal();
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
lock.unlock();
}
return ticket;
}
}
//临界类资源：票--名称、具体信息
class Ticket{
@Override
public String toString() {
return "Ticket [name=" + name + ", info=" + info + "]";
}
private String name;
private String info;
public Ticket() {
}
public Ticket(String name, String info) {
this.name = name;
this.info = info;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getInfo() {
return info;
}
public void setInfo(String info) {
this.info = info;
}
}

复制代码