【简述】
wait()和notify()方法是和synchronized关键字合作使用的。
Condition是和重入锁相关联的,通过ReentrantLock.newCondition()生成一个与当前重入锁绑定的Condition实例。
利用Condition对象,可以让线程在合适的时间等待,或者在某一个特定的时间得到通知,继续执行。
【Condition提供的基本方法】
await():会使当前线程等待,同时释放锁。当其他线程使用signal()或signalAll()方法时,线程会重新获得锁屏继续执行。或者当线程被中断时,也能跳出等待。
awaitUninterruptibly():与await()方法基本相同,但是它不会在等待的过程中响应中断。
signal():用于唤醒一个在等待中的线程。
signalAll():唤醒所有在等待中的线程。
【Condition实例】
package com.higgin.reentrantLock; import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock; /**
* Created by HigginCui on 2017/5/17.
*/
public class ConditionThread implements Runnable{ public static ReentrantLock lock = new ReentrantLock(); public static Condition condition = lock.newCondition(); //生成一个与当前重入锁lock绑定的condition实例 @Override
public void run() {
try {
lock.lock();
System.out.println(Thread.currentThread().getName()+" 开始运行");
condition.await(); //线程等待(会响应中断),会让当前线程释放占用的锁lock,必须在lock()和unlock()之间
System.out.println(Thread.currentThread().getName()+" 继续运行");
} catch (InterruptedException e) {
e.printStackTrace();
System.out.println(Thread.currentThread().getName()+" 进入响应中断!");
} finally {
lock.unlock(); //释放锁
System.out.println(Thread.currentThread().getName()+" 释放锁!");
}
} public static void main(String[] args) throws InterruptedException{
ConditionThread ct = new ConditionThread();
Thread t = new Thread(ct,"conditionThread");
t.start();
System.out.println(Thread.currentThread().getName()+"线程 开始运行!");
Thread.sleep(); lock.lock(); //调用singnal()方法前,main线程先获得相关的锁
condition.signal(); //从当前Condition对象的等待队列中,唤醒一个线程,此时main线程依然占用着锁
Thread.sleep();
System.out.println(Thread.currentThread().getName()+"线程 已经在2秒前唤醒一个等待线程了,单依然占用着锁,,现在准备释放锁");
lock.unlock(); //释放锁,给被唤醒的线程,此时conditionThread线程才可以获得锁继续运行
}
}
【运行结果】
【分析】
Condition.await()方法调用后,当前线程会释放锁。
Condition.signal()方法调用后,系统会从当前Condition对象的等待队列中,唤醒一个线程。
一旦线程被唤醒,它会重新尝试获得与之绑定的重入锁,一旦成功获取,就可以继续执行了。
因此,在signal()方法调用之后,一般需要释放相关的锁,谦让给被唤醒的线程,让被唤醒的线程获得锁继续执行。