package com.himi.test;

 import java.util.concurrent.locks.Lock;

 import java.util.concurrent.locks.ReentrantLock;

 public class SellTicket implements Runnable {

     // 定义票

     private int tickets = 40;

     // 定义锁对象

     private Lock lock = new ReentrantLock();

     @Override()

     public void run() {

         while (true) {//这里利用try{}finally{},是因为担心程序加锁之后出问题，不能跳出解锁

             try {

                 // 加锁

                 lock.lock();

                 if (tickets > 0) {

                     try {

                         Thread.sleep(100);

                     } catch (InterruptedException e) {

                         e.printStackTrace();

                     }

                     System.out.println(Thread.currentThread().getName()

                             + "正在出售第" + (tickets--) + "张票");

                 }

             } finally {

                 // 释放锁

                 lock.unlock();

             }

         }

     }

 }

 package com.himi.test;

 public class SellTicketDemo {

     public static void main(String[] args) {

         // 创建资源对象

         SellTicket st = new SellTicket();

         // 创建三个窗口

         Thread t1 = new Thread(st, "窗口1");

         Thread t2 = new Thread(st, "窗口2");

         Thread t3 = new Thread(st, "窗口3");

         // 启动线程

         t1.start();

         t2.start();

         t3.start();

     }

 }