ReentrantLock使用Condition实现通知部分线程
2016-05-02 11:50
519 查看
关键字synchronized与wait()和notify()/notifyAll()方法想结合可以实现等待/通知模式,类ReentrantLock也可以实现同样的功能,但需要借助于Condition对象。Condition类在JDK5中出现,使用它有更好的灵活性,比如可以实现多路通知的功能,也就是在一个Lock对象中可以创建多个Condition对象(对象监视器),线程对象可以注册在指定的Condition中,从而可以有选择地进行线程通知,在调度线程上更加灵活。
编程举例:
Service类,包含等待和通知的同步方法。
线程A类,A类线程使用conditionA进行等待。
B类线程,B类线程使用conditionB进行等待。
测试类,调用Service类的signalAll_A方法,只通知在conditionA上等待的线程:
程序输出如下:
由此可见线程B没有被唤醒。
在使用Condition实现等待通知时:
Object类中的wait()方法相当于Condition类的await()方法。
Object类中的wait(long timeout)方法相当于Condition类中的await(long time,TimeUnit unit)方法。
Object类中的notify()方法相当于Condition类中的signal()方法。
Object类中的notifyAll()方法相当于Condition类中的signalAll()方法。
参考《Java多线程编程核心技术》
编程举例:
Service类,包含等待和通知的同步方法。
package lock; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class MyService { private Lock lock = new ReentrantLock(); public Condition conditionA = lock.newCondition(); public Condition conditionB = lock.newCondition(); public void awaitA(){ try{ lock.lock(); System.out.println("thread "+Thread.currentThread().getName()+" wait begin,in awaitA method"); conditionA.await(); //使用conditionA进行等待 System.out.println("thread "+Thread.currentThread().getName()+" end wait,in awaitA method"); }catch (InterruptedException e){ e.printStackTrace(); }finally { lock.unlock(); } } public void awaitB(){ try{ lock.lock(); System.out.println("thread "+Thread.currentThread().getName()+" wait begin,in awaitB method"); conditionB.await(); //使用conditionB进行等待 System.out.println("thread "+Thread.currentThread().getName()+" end wait,in awaitB method"); }catch (InterruptedException e){ e.printStackTrace(); }finally { lock.unlock(); } } public void signalAll_A(){ try{ lock.lock(); System.out.println("现在要通知所在在conditionA上等待的线程 "+Thread.currentThread().getName()); conditionA.signalAll(); //通知所有在conditionA上等待的线程 }finally { lock.unlock(); } } public void signalAll_B(){ try{ lock.lock(); System.out.println("现在要通知所在在conditionB上等待的线程 "+Thread.currentThread().getName()); conditionB.signalAll(); }finally { lock.unlock(); } } }
线程A类,A类线程使用conditionA进行等待。
package lock; public class ThreadA extends Thread{ private MyService service; public ThreadA(MyService service){ super(); this.service = service; } @Override public void run(){ service.awaitA(); } }
B类线程,B类线程使用conditionB进行等待。
package lock; public class ThreadB extends Thread{ private MyService service; public ThreadB(MyService service){ super(); this.service = service; } @Override public void run(){ service.awaitB(); } }
测试类,调用Service类的signalAll_A方法,只通知在conditionA上等待的线程:
package lock; public class Run { public static void main(String[] args) throws InterruptedException { MyService service = new MyService(); ThreadA a = new ThreadA(service); a.setName("A"); a.start(); ThreadB b = new ThreadB(service); b.setName("B"); b.start(); Thread.sleep(3000); service.signalAll_A(); //只通知在conditionA上等待的线程。 } }
程序输出如下:
thread A wait begin,in awaitA method thread B wait begin,in awaitB method 现在要通知所在在conditionA上等待的线程 main thread A end wait,in awaitA method
由此可见线程B没有被唤醒。
在使用Condition实现等待通知时:
Object类中的wait()方法相当于Condition类的await()方法。
Object类中的wait(long timeout)方法相当于Condition类中的await(long time,TimeUnit unit)方法。
Object类中的notify()方法相当于Condition类中的signal()方法。
Object类中的notifyAll()方法相当于Condition类中的signalAll()方法。
参考《Java多线程编程核心技术》
相关文章推荐
- LightOJ - 1328 A Gift from the Setter (数学)
- 使用CMD 命令 ping 某段IP并保存到文件中
- HDU-ACM2085
- 《剑指offer》 02 单例模式
- 解析xml
- 开源C++库:ACE及其安装使用
- UItableview 添加 uisearchController
- Hibernate运行报错Unknown entity: domain.UserBean
- 聊聊计算机中的编码(Unicode,GBK,ASCII,utf8,utf16,ISO8859-1等)以及乱码问题的解决办法
- 二叉索引树(树状数组)
- PHP变量的定义与相应的数据类型
- PHP变量的定义与相应的数据类型
- PHP变量的定义与相应的数据类型
- C经典 指针数组与二维数组指针变量的区别
- HDU-ACM2083
- HDU-ACM2081
- http协议学习笔记(四)
- 任务和特权级保护(一)——《x86汇编语言:从实模式到保护模式》读书笔记27
- 4 C 语言 数值存储方式 数组
- [leetcode] 347. Top K Frequent Elements 解题报告