java - Java中使用锁的生产者/消费者线程示例
问题描述
public class ConsumerThreadExample {
public static void main(String[] args) throws InterruptedException {
Consumer c = new Consumer();
Thread a = new Thread(()->{while(true)c.consume();});
Thread b = new Thread(()->{while(true)c.supply();});
a.start();
b.start();
a.join();
b.join();
System.out.println("finish");
}
}
class Consumer{
private List<Integer> buffer = new ArrayList<>();
private Lock lock = new ReentrantLock();
private Condition notEnough = lock.newCondition();
private Condition toomuch = lock.newCondition();
public void consume(){
lock.lock();
try{
while(buffer.isEmpty()){notEnough.await();
System.out.println("consume waiting");}
System.out.println(buffer);
for(int i = 0; i < buffer.size(); i++){
System.out.println("consume "+ buffer.remove(i));
try {
sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("signal supply");
toomuch.signal();
}
catch (Exception e){}
finally {
lock.unlock();
}
}
public void supply(){
lock.lock();
try{
while(!buffer.isEmpty()){toomuch.await();
System.out.println("supply waiting");}
System.out.println("Adding");
buffer.add(1);
buffer.add(3);
buffer.add(5);
System.out.println(buffer);
System.out.println("signal consume");
notEnough.signal();
}
catch (Exception e){}
finally {
lock.unlock();
}
}
}
大家好,考虑上面的代码,我想练习一个经典的线程示例,即消费者/生产者。所以我希望代码用供应()填充缓冲区,然后向消耗()发出信号以消耗缓冲区。每当缓冲区为空,consume() 再次向 supply() 发出信号,依此类推。但输出看起来有点奇怪。输出:
Adding
[1, 3, 5]
signal consume
consume waiting
[1, 3, 5]
consume 1
consume 5
signal supply
[3]
consume 3
signal supply
supply waiting
Adding
[1, 3, 5]
signal consume
consume waiting
[1, 3, 5]
consume 1
consume 5
signal supply
[3]
consume 3
signal supply
supply waiting
Adding
[1, 3, 5]
为什么它消耗 1 和 5 然后信号供应()?3在哪里?为什么它不在 1,3,5 的顺序中?
解决方案
在第一次迭代中
i = 0
buffer = [1, 3, 5]
然后你删除 1。在第二次迭代中
i = 1
buffer = [3, 5]
然后删除 5。然后退出循环,因为 i 现在大于长度。
推荐阅读
- vhdl - VHDL 测试平台/Vivado
- python - 从 seaborn 箱线图中删除空白空间
- botframework - 有没有办法在使用 DirectlineJS 而不是 React 的 Webchat 中清除聊天记录
- c# - 使用过滤器时,MSGraph 分页失败,过滤器子句无效
- google-bigquery - 无法将 Power BI 服务连接到 Google BigQuery - 登录循环
- python - 每次从 csv Elasticsearch 创建新索引时更新索引
- locust - 蝗虫响应时间开始时的高延迟
- windows - 我在 PyCharm 上用 git 下载了一个 repo,几乎每个文件上的许多缩进都关闭了
- javascript - 我有一个非常慢的功能,我正在考虑将数据拆分为 10 和进程的列表,但我不确定用什么来解决这个问题
- javascript - 为什么计数器在控制台中以不同的值出现两次?