admin管理员组文章数量:1599529
Condition实现等待/通知模式
Condition
接口提供了类似Object
的监视器方法,与Lock
配合可以实现等待/通知模式,但是这两者在使用方式以及功能特性上还是有差别的。Object
和Condition
接口的一些对比。
Condition主要的几个方法:
- void await():当前线程进入等待状态,如果其他线程调用
condition
的signal
或者signalAll
方法并且当前线程获取Lock
从await
方法返回,如果在等待状态中被中断会抛出被中断异常; - void signal():唤醒一个等待在
condition
上的线程,将该线程从等待队列中转移到同步队列中,如果在同步队列中能够竞争到Lock
则可以从等待方法中返回。 - void signalAll():与1的区别在于能够唤醒所有等待在
condition
上的线程
/**
* 面试题:写一个固定容量同步容器,拥有put和get方法,以及getCount方法,
* 能够支持2个生产者线程以及10个消费者线程的阻塞调用
*
* 使用wait和notify/notifyAll来实现
*
* 使用Lock和Condition来实现(**注意:不要将获取锁的过程放在try块中,因为如果在获取锁时发生了异常,异常抛出的同时,也会导致锁无故释放**)
* 对比两种方式,Condition的方式可以更加精确的指定哪些线程被唤醒
*/
import java.util.LinkedList;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class conditionDemo<T> {
final private LinkedList<T> lists = new LinkedList<>();
final private int MAX = 10; //最多10个元素
private int count = 0;
private Lock lock = new ReentrantLock();
private Condition producer = lock.newCondition();
private Condition consumer = lock.newCondition();
public void put(T t) {
try {
lock.lock();
while(lists.size() == MAX) { //想想为什么用while而不是用if?
producer.await();
}
lists.add(t);
++count;
consumer.signalAll(); //通知消费者线程进行消费
System.out.println("通知消费者线程进行消费");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public T get() {
T t = null;
try {
lock.lock();
while(lists.size() == 0) {
consumer.await();
}
t = lists.removeFirst();
count --;
producer.signalAll(); //通知生产者进行生产
System.out.println("通知生产者进行生产");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
return t;
}
public static void main(String[] args) {
conditionDemo<String> c = new conditionDemo<>();
//启动消费者线程
for(int i=0; i<10; i++) {
new Thread(()->{
for(int j=0; j<5; j++) System.out.println(c.get());
}, "c" + i).start();
}
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
//启动生产者线程
for(int i=0; i<2; i++) {
new Thread(()->{
for(int j=0; j<15; j++) c.put(Thread.currentThread().getName() + " " + j);
}, "p" + i).start();
}
}
}
运行结果:
版权声明:本文标题:Condition实现等待通知模式 内容由热心网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:https://m.elefans.com/dianzi/1728325116a1154335.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论