码迷,mamicode.com
首页 > 编程语言 > 详细

java多线程实现卖票程序

时间:2015-03-14 21:41:07      阅读:339      评论:0      收藏:0      [点我收藏+]

标签:

本文采用java多线程实现了模拟车站多个车票卖票的功能。

关键词:java多线程 共享变量 实现runnable接口 volatile  线程同步。

代码如下

Ticket类

package ex7_TicketSaler;

/*同一对象的多个线程thread0/1/2,对共享变量count的操作,需要将count的值声明为volatile
 * 并且因为多个线程操作的是同一个对象ticket,因此count是资源共享的
 * 
 */

public class Ticket implements Runnable{
    volatile int count = 1000;   //总共的票数量
    Boolean flag = true;
    Object locObj = new Object();
    @Override
    public void run() {
        // TODO Auto-generated method stub
        //加入同步块后,count的值不会出现错误
            
            while(count>0)
            {
//                synchronized(locObj)
//                {
//                    
//                    
//                    
//                }
                getTicket();
                
                                
            }    
            
            //线程结束后的处理程序
            System.out.println(Thread.currentThread().getName()+"执行结束\n");
        

    }
    
    //定义了一个同步方法  此方法同时只能被一个线程执行完毕后,另一个线程才能够执行
    
    public synchronized void getTicket()
    {
        
        if(count>0)
        {
            count--;
            System.out.println(Thread.currentThread().getName()+"卖出一张票,"+"剩余票数:"+count +"\n");
            Thread.yield();    
            
        }
        else
        {
            flag = false;
        }
    }
    
}

TicketSaler类

package ex7_TicketSaler;

public class TicketSaler {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        System.out.println("开始售票\n");
        int n = 10;
        Thread [] threads= new Thread[n];
        Ticket ticket = new Ticket();
        for (int i=0;i<n;i++)
        {
            threads[i] = new Thread(ticket);
            threads[i].setName("售票窗口"+i);
            threads[i].start();
        }
//        for(int i=0;i<n;i++)
//        {
//            System.out.println("线程名"+threads[i].getName()+"\n");
//        }
        
        //让新开的新城先执行,控制线程结束
        //thread[0]在thread[1]前执行完毕,thread[1]在thread[2]前执行完毕,thread[2]在主线程之前执行完毕
        for(int i=n-1;i>0;i--)
        {
            try {
                threads[i].join();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
        System.out.println("结束售票\n");
        
    }

}

 

java多线程实现卖票程序

标签:

原文地址:http://www.cnblogs.com/wll-zju/p/4338184.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!