84669 人が学習中
152542 人が学習中
20005 人が学習中
5487 人が学習中
7821 人が学習中
359900 人が学習中
3350 人が学習中
180660 人が学習中
48569 人が学習中
18603 人が学習中
40936 人が学習中
1549 人が学習中
1183 人が学習中
32909 人が学習中
我尝试用ArrayList做生产者-消费者问题,有多个生产者,多个消费者,用wait、noitify、notifyAll做并发控制。
当生产者生产完毕后,如何只notify消费者呢?
拥有18年软件开发和IT教学经验。曾任多家上市公司技术总监、架构师、项目经理、高级软件工程师等职务。 网络人气名人讲师,...
你确保只有消费者在wait,这样notify就只会通知消费者了。 话说你为什么要让生产者去wait呢?
给队列加一个锁lock,然后创建两个Condition,一个是full,处理队列满的情况;另一个是empty,处理队列空的情况。 操作流程是这样的: 生产者: 1、获得锁 2、检查队列是否满,如果满则等待full condition,直到被消费者唤醒 3、将元素加入队列 4、notify empty condition,唤醒一个消费者 5、释放锁
消费者: 1、获得锁 2、检查队列是否空,如果空则等待empty condition,直到被生产者唤醒 3、从队列中取出一个元素 4、notify full condition,唤醒一个生产者 5、释放锁。
牢记一点,Condition不是锁,不存在“锁定”Condition的情况。
notify被唤醒的线程是随机的,所以通常是没办法指定是谁被唤醒。 根据我的知识水平,我认为能做的办法有两点: 1.设置消费者线程的优先级,使用notifyAll,这样增大消费者线程获取资源的概率; 2.就是保证生产者执行完后,正在wait的只有消费者;
class BoundedBuffer { final Lock lock = new ReentrantLock(); final Condition notFull = lock.newCondition(); final Condition notEmpty = lock.newCondition(); final Object[] items = new Object[100]; int putptr, takeptr, count; public void put(Object x) throws InterruptedException { lock.lock(); try { while (count == items.length) notFull.await(); items[putptr] = x; if (++putptr == items.length) putptr = 0; ++count; notEmpty.signal(); } finally { lock.unlock(); } } public Object take() throws InterruptedException { lock.lock(); try { while (count == 0) notEmpty.await(); Object x = items[takeptr]; if (++takeptr == items.length) takeptr = 0; --count; notFull.signal(); return x; } finally { lock.unlock(); } } }
无法指定线程,notify会唤醒等待该对象的一个线程。
你确保只有消费者在wait,这样notify就只会通知消费者了。
话说你为什么要让生产者去wait呢?
给队列加一个锁lock,然后创建两个Condition,一个是full,处理队列满的情况;另一个是empty,处理队列空的情况。
操作流程是这样的:
生产者:
1、获得锁
2、检查队列是否满,如果满则等待full condition,直到被消费者唤醒
3、将元素加入队列
4、notify empty condition,唤醒一个消费者
5、释放锁
消费者:
1、获得锁
2、检查队列是否空,如果空则等待empty condition,直到被生产者唤醒
3、从队列中取出一个元素
4、notify full condition,唤醒一个生产者
5、释放锁。
牢记一点,Condition不是锁,不存在“锁定”Condition的情况。
notify被唤醒的线程是随机的,所以通常是没办法指定是谁被唤醒。
根据我的知识水平,我认为能做的办法有两点:
1.设置消费者线程的优先级,使用notifyAll,这样增大消费者线程获取资源的概率;
2.就是保证生产者执行完后,正在wait的只有消费者;
无法指定线程,notify会唤醒等待该对象的一个线程。
无法指定线程,notify会唤醒等待该对象的一个线程。