JDK5以后提供了一个新的锁对象Lock，Lock是一个接口，ReentrantLock是Lock的实现类

1. package com.kxg_11;
   
2. 
   
3. import java.util.concurrent.locks.Lock;
   
4. import java.util.concurrent.locks.ReentrantLock;
   
5. /*
   
6. * Lock:
   
7. *                 lock():添加锁
   
8. *                 unlock():释放锁
   
9. */
   
10. public class SellTicekt implements Runnable {
    
11.         private int ticket = 100;
    
12. //        创建Lock接口的实现类ReentrantLock
    
13.         private Lock lock = new ReentrantLock();
    
14.         @Override
    
15.         public void run() {
    
16.                 while (true) {
    
17.                         try {
    
18.                                 lock.lock();
    
19.                                 try {
    
20.                                         Thread.sleep(100);
    
21.                                 } catch (InterruptedException e) {
    
22.                                         e.printStackTrace();
    
23.                                 }
    
24.                                 if (ticket > 0) {
    
25.                                         System.out.println(Thread.currentThread().getName()
    
26.                                                         + "正在出售第" + (ticket--) + "张票");
    
27.                                 }
    
28.                         } finally {
    
29.                                 lock.unlock();
    
30.                         }
    
31.                 }
    
32.         }
    
33. }

复制代码

JDK5以后提供了一个新的锁对象Lock，Lock是一个接口，ReentrantLock是Lock的实现类

1. package com.kxg_11;
   
2. 
   
3. import java.util.concurrent.locks.Lock;
   
4. import java.util.concurrent.locks.ReentrantLock;
   
5. /*
   
6. * Lock:
   
7. *                 lock():添加锁
   
8. *                 unlock():释放锁
   
9. */
   
10. public class SellTicekt implements Runnable {
    
11.         private int ticket = 100;
    
12. //        创建Lock接口的实现类ReentrantLock
    
13.         private Lock lock = new ReentrantLock();
    
14.         @Override
    
15.         public void run() {
    
16.                 while (true) {
    
17.                         try {
    
18.                                 lock.lock();
    
19.                                 try {
    
20.                                         Thread.sleep(100);
    
21.                                 } catch (InterruptedException e) {
    
22.                                         e.printStackTrace();
    
23.                                 }
    
24.                                 if (ticket > 0) {
    
25.                                         System.out.println(Thread.currentThread().getName()
    
26.                                                         + "正在出售第" + (ticket--) + "张票");
    
27.                                 }
    
28.                         } finally {
    
29.                                 lock.unlock();
    
30.                         }
    
31.                 }
    
32.         }
    
33. }

复制代码