Java培訓之java難點解析(十五)-Lock接口

Lock接口：多線程在JDK1.5版本升級時，推出一個接口Lock接口。
解決線程安全問題使用同步的形式，(同步代碼塊，要么同步函數(shù))其實最終使用的都是鎖機制。
 
到了后期版本，直接將鎖封裝成了對象。線程進入同步就是具備了鎖，執(zhí)行完，離開同步，就是釋放了鎖。
在后期對鎖的分析過程中，發(fā)現(xiàn)，獲取鎖，或者釋放鎖的動作應(yīng)該是鎖這個事物更清楚。所以將這些動作定義在了鎖當中，并把鎖定義成對象。
 
所以同步是隱示的鎖操作，而Lock對象是顯示的鎖操作，它的出現(xiàn)就替代了同步。
 
在之前的版本中使用Object類中wait、notify、notifyAll的方式來完成的。那是因為同步中的鎖是任意對象，所以操作鎖的等待喚醒的方法都定義在Object類中。
 
而現(xiàn)在鎖是指定對象Lock。所以查找等待喚醒機制方式需要通過Lock接口來完成。而Lock接口中并沒有直接操作等待喚醒的方法，而是將這些方式又單獨封裝到了一個對象中。這個對象就是Condition，將Object中的三個方法進行單獨的封裝。并提供了功能一致的方法 await()、signal()、signalAll()體現(xiàn)新版本對象的好處。
< java.util.concurrent.locks > Condition接口：await()、signal()、signalAll()；
--------------------------------------------------------
class BoundedBuffer {
   final Lock lock = new ReentrantLock();
   final Condition notFull  = lock.newCondition(); 
   final Condition notEmpty = lock.newCondition(); 
   final Object[] items = new Object[100];
   int putptr, takeptr, count;
   public void put(Object x) throws InterruptedException {
     lock.lock();
     try {
       while (count == items.length) 
         notFull.await();
       items[putptr] = x; 
       if (++putptr == items.length) putptr = 0;
       ++count;
       notEmpty.signal();
     } 
finally {
       lock.unlock();
     }
   }
   public Object take() throws InterruptedException {
     lock.lock();
     try {
       while (count == 0) 
         notEmpty.await();
       Object x = items[takeptr]; 
       if (++takeptr == items.length) takeptr = 0;
       --count;
       notFull.signal();
       return x;
     } 
finally {
       lock.unlock();
     }
   } 
 }


本文版權(quán)歸傳智播客Java培訓學院所有，歡迎轉(zhuǎn)載，轉(zhuǎn)載請注明作者出處。謝謝！
作者：傳智播客Java培訓學院
首發(fā)：http://xamj520.com/javaee