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()方法调用之后，一般需要释放相关的锁，谦让给被唤醒的线程，让它可以继续执行。
网友评论