读书人

Java线程(2)

发布时间: 2012-12-19 14:13:14 作者: rapoo

Java线程(二)

今天重新整理关于concurrent包的使用。

Lock 接口, 提供了synchronized的功能, 同时额外增加复杂性,处理复杂问题的能力,因为在synchronized的时候,可以顺序的获取多个锁,同时也需要倒序的释放这些锁,碰到一些情况这个就不能满足了,这时候Lock就可以,

它实现了锁在不同作用范围的获取和释放,同时不同顺序的获取和释放。

通常这样使用

Lock l = ...

l.lock();

try{

?

?

}finally{

?l.unlock();

}

没有了synchronized的自动释放锁的能力,手动做

Lock 的一些功能

一个非块结构的获取锁, tryLock()

获取可中断锁的尝试, tryInterruptibly()

获取超时失效锁的尝试, tryLock(Long, timeUnit);

重这3个方法中,看出来有三种获取锁的方式,可中断,不可中断,定时

?

?

ReadWriteLock 接口, 提供了多个线程同时访问共享资源的能力,它由一对读-写锁组成,读锁可以被多个线程共享,写只能独占,并且保证了数据的内存同步,写的结果在读中,即时可得。

它适用于,需要经常被读,但是写的较少的情况,简单说,就是读的时间长的

?

ReentrantLock 实现了Lock 的 可重入互斥锁, 具有synchronized语句访问隐式锁的相同的基本语义和行为,但更强大。它提供了很多的方法来检查当前锁的情况,包括当前线程是否拥有锁,isHeldByCurrentThread(), 等待的线程, getWaitingThreads(Condition), getQueuedThreads(), getHoldCount(), getOwner(), hasXXX, 等方法来查看是否有等待线程,等待的数量等。

它还提供了一个fair参数,来实现公平策略,即当多个线程竞争的时候,倾向于等待时间最长的线程,当然是不保证的,并且可能很慢。同时使用tryLock()方法是不管公平的,只要锁空闲,就可获取。

?

Condition 接口,与每个Lock相关,newCondition()创建, 在我看来Condition就是Object中wait,notify的升级版,Object中使用的隐式锁机制的wait,notify需要保持一个锁, Condition不需要, 同时Condition 可以提供唤醒的通知顺序控制,可以对一个锁有多个Condition。

?

 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();     }   }  } 

?

?

?

读书人网 >编程

热点推荐