本文采用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"); } }
原文:http://www.cnblogs.com/wll-zju/p/4338184.html