[ JAVA开发技术 ] 【守望者 j2se】并发包-ReentrantLock

ReentrantLock:java.util.concurrent.lock 中的 Lock 框架是锁定的一个抽象，它允许把锁定的实现作为 Java 类，而不是作为语言的特性来实现。这就为 Lock 的多种实现留下了空间，各种实现可能有不同的调度算法、性能特性或者锁定语义。 ReentrantLock 类实现了 Lock ，它拥有与 synchronized 相同的并发性和内存语义，但是添加了类似锁投票、定时锁等候和可中断锁等候的一些特性。此外，它还提供了在激烈争用情况下更佳的性能。（换句话说，当许多线程都想访问共享资源时，JVM 可以花更少的时候来调度线程，把更多时间用在执行线程上。）

Reentrant 锁意味着什么呢？简单来说，它有一个与锁相关的获取计数器，如果拥有锁的某个线程再次得到锁，那么获取计数器就加1，然后锁需要被释放两次才能获得真正释放。这模仿了 synchronized 的语义；如果线程进入由线程已经拥有的监控器保护的 synchronized 块，就允许线程继续进行，当线程退出第二个（或者后续） synchronized 块的时候，不释放锁，只有线程退出它进入的监控器保护的第一个 synchronized 块时，才释放锁。对于 Lock 和 synchronized 有一点明显的区别 —— lock 必须在 finally 块中释放。否则，如果受保护的代码将抛出异常，锁就有可能永远得不到释放！这一点区别看起来可能没什么，但是实际上，它极为重要。忘记在 finally 块中释放锁，可能会在程序中留下一个定时炸弹，当有一天炸弹爆炸时，您要花费很大力气才有找到源头在哪。而使用同步，JVM 将确保锁会获得自动释放。

//仓库

public class CangKu {

private boolean isFull=false;

private ReentrantLock  lock=new  ReentrantLock();

//放入数据

public  void   put()

{

    if(!this.isFull)

    {       

      try { 

        //申请锁

        lock.lock();

        System.out.println("放满了,可以来取");

        isFull=!isFull;

    } catch(Exception e) {

     e.printStackTrace();

    }finally

    {  //释放锁

       lock.unlock();

    } 

    }

}

   //取得数据

public  void   get()

{

    if(this.isFull)

    {       

     try { 

        //申请锁

        lock.lock();

        System.out.println("取完了,来放");

        isFull=!isFull;

    } catch(Exception e) {

     e.printStackTrace();

    }finally

    {  //释放锁

       lock.unlock();

    }

    } 

}

}

//get

public class GetThread  implements  Runnable {

private  CangKu   ck;

public GetThread(CangKu cu) { 

  this.ck = cu;

  new Thread(this).start();

}

public void run() {

    while(true) 

    {

      this.ck.get();

    }

}

}

//put

public class PutThread extends Thread {

private CangKu ck;

public PutThread(CangKu cu) {

  this.ck = cu;

  this.start();

}

    public  void  run()

    {

     while(true)

     {

      this.ck.put();

     }

    }

}

public class ReentCangKUMain {

/**

  * ReentrantLock仓库实例测试

  */

public static void main(String[] args) {

  

  CangKu   cu=new CangKu();

     PutThread  pth=new PutThread(cu);

        GetThread  gth=new GetThread(cu);

}

}