Lock接口:多线程在JDK1.5版本升级时,推出一个接口Lock接口。java
解决线程安全问题使用同步的形式,(同步代码块,要么同步函数)其实最终使用的都是锁机制。安全
到了后期版本,直接将锁封装成了对象。线程进入同步就是具有了锁,执行完,离开同步,就是释放了锁。多线程
在后期对锁的分析过程当中,发现,获取锁,或者释放锁的动做应该是锁这个事物更清楚。因此将这些动做定义在了锁当中,并把锁定义成对象。函数
因此同步是隐示的锁操做,而Lock对象是显示的锁操做,它的出现就替代了同步。线程
在以前的版本中使用Object类中wait、notify、notifyAll的方式来完成的。那是由于同步中的锁是任意对象,因此操做锁的等待唤醒的方法都定义在Object类中。对象
而如今锁是指定对象Lock。因此查找等待唤醒机制方式须要经过Lock接口来完成。而Lock接口中并无直接操做等待唤醒的方法,而是将这些方式又单独封装到了一个对象中。这个对象就是Condition,将Object中的三个方法进行单独的封装。并提供了功能一致的方法 await()、signal()、signalAll()体现新版本对象的好处。接口
< java.util.concurrent.locks > Condition接口:await()、signal()、signalAll();同步
--------------------------------------------------------it
class BoundedBuffer {io
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();
}
}
}