———————————TicketsSystem.java———————————————————
| //多线程实现火车票的售票系统 .用同步块，或着同步方法 class TicketsSystem { public static void main(String[] args) //运行结果与教程中不同，不完全顺序，每次运行，顺序都不完全一样 { SellThread st=new SellThread();//创建四个线程访问同一变量tickets. // 错 SellThread st1=new SellThread();//若采用创建四个对象的方式，则每个对象中都有100张票 new Thread(st).start(); //b为false，用的同步方法 | //同步方法与同步块共用中，显示的是只调用了同步块，而同步方法未被调用 //b为true,用的同步块， | //原因，启动第一个线程后，CPU时间片没有到期，线程没有立即运行，接着执行b=true, // | //解决办法，启动第一个线程后，执行一个睡眠时间，让CPU时间片到期 try { Thread.sleep(1); } catch(Exception e) { e.printStackTrace(); } st.b=true; new Thread(st).start(); //new Thread(st).start(); //new Thread(st).start(); } } class SellThread implements Runnable //程序有点小问题，当剩下最后一张票时，四个线程都运行，可能会出现票数为0，-1，-2。（系统长时间运行时） //可加上一个静态方法sleep();它会抛出异常 { int tickets=100; //Object obj=new Object();//也可以声明一个Thread对象 Thread th=new Thread(); boolean b=false; public void run() { if(b==false) { while(true) sell(); } else { while(true) { //同步方法利用的是this所代表的对象的锁 synchronized(this) //采用同步后，显示正确。此方法两步，1，声明Thread对象，2，用synchronized把原方法括起来 { //这里换th为this ///* if(tickets>0) { try { Thread.sleep(0); } catch(Exception e) { e.printStackTrace(); } System.out.println("th "+Thread.currentThread().getName()+" sell tickets:"+tickets); tickets--; } //*/ } } } } public synchronized void sell() //每个class也有一个锁，是这个class所对应的class对象的锁（监视器） { if(tickets>0) { try { Thread.sleep(1); } catch(Exception e) { e.printStackTrace(); } System.out.println("sell "+Thread.currentThread().getName()+" sell tickets:"+tickets); tickets--; } } } |
