众所周知,多线程的弊端是会使代码受到并发访问的干扰,解决的办法就是同步机制。同步的两种常见形式分别是同步代码块和同步函数,两种形式的锁都是隐式锁,前者持有的锁可以是任意对象,后者持有的锁是默认的this。
从JDK1.5开始,根据面向对象的思想,将锁封装了起来,对外提供Lock接口,并提供了对锁的显式操作。Lock接口的出现比synchronized有更多的操作,是同步的替代。
将锁单独封装的好处就是可以更灵活的使用锁,Lock
接口的实现允许锁在不同的作用范围内获取和释放,并允许以任何顺序获取和释放多个锁,从而支持使用这种技术。
查阅API,在java.util.concurrent.locks包里可以查到Lock接口。主要的方法有
lock()—>获取锁。
unlock()—>释放锁
需要注意的是,synchronized实现同步的时候,当同步代码结束,锁自动释放,但是使用lock接口实现同步就会失去锁的自动释放功能。如果同步的代码块抛出异常,锁不能被释放,会导致其他线程无法执行。因此必须将解锁操作写到finally子句中。
如何使用Lock接口实现同步呢?
Lock接口的已知实现类包括ReentrantLock,ReentrantReadWriteLock,ReentrantReadWriteLock.WriteLock.
Lock lock = new ReentrantLock();
lock.lock();
try{
......;
}
finally{
lock.unlock();
}
如果用Lock接口实现同步,原同步代码块或同步函数中的wait();notify();notifyAll()方法就不能用了。根据面向对象的方法,将原来的同步监视器方法封装到了condition对象中。而Lock接口的灵活之处体现在一个Lock接口可以支持多个condition对象,相对应的方法是await();signal();signalAll().
用法可以查看API的示例
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();
}
}
}