1. /**
   
2. * 三个类ticket，sealWindow,ticketSealCenter,代表票信息，售票窗口，售票中心，售票中心分配一定数量的票（多个窗口实现多线程售票）
   
3. * @author Administrator
   
4. *思路：对象票（临界资源，共享）、售票窗口（买票、退票）、售票中心（管理票：添加，减少）
   
5. *三者关系：临界资源票作为资源供售票中心管理，售票窗口的操作作为售票中中心的代理进行(这里图简便直接继承)
   
6. */
   
7. public class TicketThread {
   
8. 
   
9.         public static void main(String[] args) {
   
10.                 final SealWindow sealWindow  = new SealWindow();
    
11.                 ExecutorService threadPool = Executors.newFixedThreadPool(10);
    
12.                 for(int i=0;i<10;i++){
    
13.                         Runnable runnable = new Runnable(){
    
14.                                 @Override
    
15.                                 public void run(){
    
16.                                         try {
    
17.                                                 Thread.sleep(1000);
    
18.                                                 Ticket ticket =sealWindow.getTicket();
    
19.                                                 System.out.println(ticket);
    
20.                                         } catch (InterruptedException e) {
    
21.                                                 e.printStackTrace();
    
22.                                         }
    
23.                                 }
    
24.                         };
    
25.                         threadPool.execute(runnable);
    
26.                 }
    
27.                 try {
    
28.                         Thread.sleep(3000);
    
29.                 } catch (InterruptedException e) {
    
30.                         // TODO Auto-generated catch block
    
31.                         e.printStackTrace();
    
32.                 }
    
33.                 sealWindow.addTickets();
    
34.                
    
35.         }
    
36. 
    
37. }
    
38. //售票窗口
    
39. class SealWindow extends TicketSealCenter{
    
40.        
    
41. }
    
42. //售票中心：管理票（目前只考虑同样的票）--1.票池 2.数量 3.添加、清除、修改、查找功能
    
43. class TicketSealCenter{
    
44.         private Ticket[] ticketPool = new Ticket[5];
    
45.         //票数总量
    
46.         private int count;
    
47.         //存数索引
    
48.         private int putptr;
    
49.         //取数索引
    
50.         private int takeptr;
    
51.         //对象锁
    
52.         private Lock lock = new ReentrantLock();
    
53.         //无票线程控制信号
    
54.         private Condition ticketNotEmpty = lock.newCondition();
    
55.         //添加线程控制信号
    
56.         private Condition ticketAdd = lock.newCondition();
    
57.        
    
58.         /**
    
59.          * 添加票
    
60.          */
    
61.         public void add(Ticket ticket){
    
62.                 //上锁
    
63.                 lock.lock();
    
64.                 //判断票池大小是否足够（足够，添加；否则，扩容再添加）
    
65.                 try {
    
66.                         if(ticketPool.length<=count){
    
67.                                 ticketAdd.await();
    
68.                                 Ticket[] newTicketPool = new Ticket[ticketPool.length+10];
    
69.                                 System.arraycopy(ticketPool, 0, newTicketPool, 0, ticketPool.length);
    
70.                                 ticketPool = newTicketPool;
    
71.                         }
    
72.                         ticketPool[putptr++]=ticket;
    
73.                         count++;
    
74.                         if(putptr==ticketPool.length){
    
75.                                 putptr=0;
    
76.                         }
    
77.                         ticketNotEmpty.signal();
    
78.                 } catch (InterruptedException e) {
    
79.                         e.printStackTrace();
    
80.                 }
    
81.                 lock.unlock();
    
82.         }
    
83.         /**
    
84.          * 添加多张票
    
85.          */
    
86.         public void addTickets(){
    
87.                 for(int i=1;i<100;i++){
    
88.                         this.add(new Ticket("第"+i+"","张火车票"));
    
89.                 }
    
90.         }
    
91.         /**
    
92.          * 查看是否有票
    
93.          * @return
    
94.          */
    
95.         public boolean hasTicket(){
    
96.                 return count>0;
    
97.         }
    
98.         /**
    
99.          * 取票
    
100.          */
     
101.         public Ticket getTicket(){
     
102.                 //上锁
     
103.                 lock.lock();
     
104.                 Ticket ticket = null;
     
105.                 //判断是否有票，若有票，则取票。否则，阻塞等待(使用while 防止伪唤醒)
     
106.                 try {
     
107.                         while(!this.hasTicket()){
     
108.                                 ticketNotEmpty.await();
     
109.                         }
     
110.                         ticket = ticketPool[takeptr];
     
111.                         takeptr++;
     
112.                         if(takeptr==ticketPool.length){
     
113.                                 takeptr = 0;
     
114.                         }
     
115.                         count--;
     
116.                         ticketAdd.signal();
     
117.                 } catch (InterruptedException e) {
     
118.                         e.printStackTrace();
     
119.                 }finally{
     
120.                         lock.unlock();
     
121.                 }
     
122.                
     
123.                 return ticket;
     
124.         }
     
125.        
     
126.        
     
127. }
     
128. //临界类资源：票--名称、具体信息
     
129. class Ticket{
     
130.         @Override
     
131.         public String toString() {
     
132.                 return "Ticket [name=" + name + ", info=" + info + "]";
     
133.         }
     
134.         private String name;
     
135.         private String info;
     
136.        
     
137.         public Ticket() {
     
138.         }
     
139.         public Ticket(String name, String info) {
     
140.                 this.name = name;
     
141.                 this.info = info;
     
142.         }
     
143.         public String getName() {
     
144.                 return name;
     
145.         }
     
146.         public void setName(String name) {
     
147.                 this.name = name;
     
148.         }
     
149.         public String getInfo() {
     
150.                 return info;
     
151.         }
     
152.         public void setInfo(String info) {
     
153.                 this.info = info;
     
154.         }
     
155.        
     
156. }

复制代码

厉害，哥们以前是有基础吗？报的是那一期？

真是醉了，怪不得分那么高， 见过的这题属你写的最严谨了。大神大神:victory:

SpiderManZZH 发表于 2015-1-6 00:58
厉害，哥们以前是有基础吗？报的是那一期？

没，在上班，还被报呢

雪落纷飞 发表于 2015-1-6 01:22
真是醉了，怪不得分那么高， 见过的这题属你写的最严谨了。大神大神 ...

其实都差不多，只是当初看到这题的时候感觉用面向对象的思路写很清晰，也好实现，若是东改西改的实现功能效果没那么好

好多技术分，我要努力

学习中。。。

好流弊！！！