1、引入Condiion
Condition的作用与Object.wait()和Object.notify()的作用大致是相同的。但是wait()和notify()方法是与synchronized关键字合作使用的,而Condition是与重入锁相关联的。通过Lock接口(重入锁实现了这一接口)的new Condition()方法可以生成一个与当前重入锁绑定的Condition实例。利用Condition对象,可以让线程在合适的时间等待,或者在某一个特定的时间得到通知。
2、Condition接口提供的基本方法
void await() throws InterruptedException;
void awaitUninterrruptibly();
long awaitNanos(long nanosTimeout) throws InterruptedException;
boolean await(long time, TmeUnit unit) throws InterruptedException;
boolean await(Date deadline) throws InterruptedException;
void signal();
void signalAll();
以上方法的含义如下:
- await()方法会使当前线程等待,同时释放当前锁,当其他线程中使用signal()或signalAll()方法时,线程会重新获得锁并继续执行。或者当其他线程被中断时,也能跳出等待。这和Object.wait()很相似。
- awaitUninterruptibly()与await()方法基本相同,但他并不会在中断过程中响应中断。
- signal()方法用于唤醒一个在等待中的线程。相对的signalAll()方法会唤醒所有在等待中的线程。这和Object.notifyAll()很类似。
3、简单演示一下Condition的功能
演示代码如下:
public class ReentrantLockCondition implements Runnable
{
public static ReentrantLock lock = new ReentrantLock();
//通过ReentrantLock创建Condition实例,并与之关联
public static Condition condition = lock.newCondition();
@Override
public void run()
{
try
{
lock.lock();
condition.await();
System.out.println("Thread is going on");
}
catch (InterruptedException e)
{
e.printStackTrace();
}
finally
{
lock.unlock();
}
}
public static void main(String[] args) throws InterruptedException
{
ReentrantLockCondition tl = new ReentrantLockCondition();
Thread t1 = new Thread(tl);
t1.start();
Thread.sleep(2000);
//通知t1继续执行
lock.lock();
condition.signal();
lock.unlock();
}
}
与Object.wait()和Object.notify()方法类似,当前线程使用Condition.await()时,要求线程持有相关的重入锁,在Condition.await()调用后,这个线程会释放这把锁。同理,在Condition.signal()方法调用时,也要求线程先获得相关的锁。在signal()方法调用后,系统会从当前Condtion对象的等待队列中,唤醒一个线程。一旦线程被唤醒,它会重新尝试获得与之绑定的重入锁,一旦成功获取,就可以继续执行了。因此,在signal()方法调用之后,一般需要释放相关的锁,谦让给被唤醒的线程,让它可以继续执行。