我正在做一项关于使用多线程概念在Java中实现生产者-消费者问题的大学作业。在本例中，有两个生产者和一个消费者。生产者A以每5分钟一个的速率生产一个项目(仅是一个例子)，生产者B以每6分钟一个的速率生产一个项目。这些物品被放置在一个有限大小的货架上，只能容纳5件物品。 消费者每隔4分钟就会从货架上取下商品。当货架是空的<
浏览 30提问于2020-03-26得票数 1
3回答
我试图为生产者/消费者编写解决方案，但有限度。public class InternalQueue { private static final int MAX_QUEUE_SIZE= new AtomicInteger(0); publi
浏览 2提问于2021-06-18得票数 0
3回答
假设有1个生产者P和2个消费者C1和C2。并且有2个队列Q1和Q2，它们都具有特定的容量。
P将生成项目，并将其交替放入Q1和Q2中。商品是为特定消费者生产的，不能被其他消费者消费。我在考虑使用BlockingQueue，当消费者的队列为空时，它会阻塞消费者。但问题是，当其中一个队列已满时，生产者将被阻塞。Ja
浏览 3提问于2013-05-31得票数 8
1回答
我面临的问题是，我有一个线程A和n个工作需要完成。线程A必须等待，直到这n个工作完全完成。我的想法是使用一个具有n个计数的CountDownLatch，并使用生产者/消费者模式来控制工人。我使用AtomicInteger作为计数器:生产者检查计数器值是否大于0，然后向BlockingQueue发出信号，如果计数器值小于或等于0，则<em
浏览 1提问于2011-01-21得票数 0
我有以下问题，我不确定如何设计解决方案的各个部分：
我有一个很大的文本文件，我逐行读取它。我需要处理每一行并更新一个HashMap。AFAIK我需要一个生产者线程来从文件中读取行，并将行分派到一个消费者线程池。使用者线程应该更新ConcurrentHashMap，然后获得新的行。我的问题是:使用者线程如何访问ConcurrentHashMap？如
浏览 0提问于2013-05-14得票数 0
6回答
我正在看一个关于Java多线程的视频教程。介绍了用Java实现著名的“生产者-消费者”问题。
它使用wait()和notifyAll()来确保生产者线程和消费者线程之间的正确通信。这位导师故意创建了几个生产者线程，而只有一个消费者线程，但他留下了一个未回答的
浏览 2提问于2013-04-05得票数 5
回答已采纳
1回答
但假设我想保留这两个线程(生产者/消费者)！第一个线程正在写入流中。第二个线程正在从流中读取。我还希望，我能够用这种技术处理更好的显式并行(生产者/使用者)，在流中我可以使用一些隐式并行(例如stream.parallel())。
我使用“generate”访问ja
浏览 2提问于2015-02-12得票数 3
回答已采纳
1回答
正如这篇文章所解释的那样，它不起作用。参见表中的代码示例“(仍然)损坏的多线程版本”双重检查锁定“惯用法”。class Producer { private AtomicIntegerupdateCount = new
浏览 0提问于2014-11-19得票数 0
1回答
我有一系列的生产者和消费者线程。在消费者线程中，如果队列中没有数据，我会使用lock.wait()函数来停止执行。在生产者线程中产生数据时，调用lock.notify()，消费者线程退出等待状态，并移动到线程调度器以获取锁。当通知程序生产者线程释放锁时，线程调度器会随机选择一个线程</
浏览 1提问于2018-10-05得票数 1
2回答
我必须在上面写一个有三个线程的程序。第一个线程生成偶数。第二个线程产生奇数。最后一个是两个线程生成的奇数和偶数的总和。
我是Java并发性的新手。我听说过生产者/消费者模型，在这种模式下，一个生产者生产一些东西，一个消费者使用它。但在上面的场景中，我认为有两个生产者-奇数生成器和偶数生成器和<
浏览 1提问于2014-04-28得票数 0
1回答
JMS中的多线程
、、、、
我需要编写一个多线程JMS生产者和一个多线程JMS消费者；我对使用JMS比较陌生，以前从未使用过多线程。我在API中看到，您可以使用生产者的完成侦听器和消费者的消息侦听器异步发送和接收消息。这是否意味着使用完成侦听器和消息侦听器会导致程序多线程？如果没有，那
浏览 1提问于2015-06-08得票数 1
2回答
只有一个消费者线程和一个生产者线程。生产者线程数据获取速度很慢。它向套接字查询数据，为消费者生成数据所需的时间比消费者处理和发送数据所需的时间要长得多。问题是我正在更新一个显示，所以我希望更新速度变慢，这样它们看起来就像是连续的，而不是突然更新。
我现在使用的是双缓冲区，但是使用者等待缓冲区交
浏览 0提问于2011-03-26得票数 0
回答已采纳
我正在考虑将@ApplicationScoped bean与AtomicInteger结合使用，就像这样class VisitsCounter {
}
return counter.incrementAndGet();}
我的问题是:同时考虑多个请求可以吗或者，我需要使用@ConcurrencyManagement和@Lo
浏览 2提问于2013-01-09得票数 23
回答已采纳
我对生产者-消费者模式的理解是，它可以使用生产者和消费者之间共享的队列来实现。生产者将工作提交到共享队列，消费者检索并处理它。它也可以通过生产者直接提交给消费者(生产者线程直接提交给消费者的执行器服务). 来实现
现在，我研究了Executors类，它提供了一些常见的线程池实
浏览 3提问于2011-08-12得票数 7
回答已采纳
3回答
我正在尝试多个生产者-消费者用例的生产者-消费者问题。我使用BlockingQueue在多个生产者/消费者之间共享公共队列。import java.util.concurrent.BlockingQueue;
System.ou
浏览 2提问于2014-08-19得票数 2
回答已采纳
我有两个线程生产者和消费者。在objective语言中，我使用了信号量来阻止和释放线程使用者。
注：-这是与生产者-消费者问题有关，但不是完全。在这里，生产者不会等待消费者消费。但是消费者会等到生产者生产。在这里，消费者并没有不断地阅读。只有当制片人让他读的时候，他才在读书。
浏览 4提问于2017-06-22得票数 0
1回答
考虑一个有两个线程的应用程序，生产者和消费者。
这两个线程的运行频率大致相同，一秒钟内运行多次。两个线程都访问同一个内存区域，其中生产者写入内存，而使用者读取当前数据块并使用它进行操作，而不使数据无效。解决此问题的一种方法是创建两个缓冲区，一个由消费者访问，一个由生产者写入，并在编写完成后立即交换缓冲区。还是参考文献的<
浏览 1提问于2013-09-13得票数 0
回答已采纳
我正在学习Java的锁和条件，并且已经实现了生产者和消费者的code.Idea是有一个生产者和N消费者。但是，当我运行代码时，总是有一个使用者线程读取。1CONSUMED 5Thread-1CONSUMED 7Thread-1CONSUMED 9
在这里我们可以看到，即使两个线程都很难启动，线程
浏览 7提问于2022-09-02得票数 1
6回答
我正在试着写一个多线程的网络爬虫。只有当队列为空并且当前没有活动的URLCrawler时，它才应该返回null。我的第一个想法是使用一个AtomicInteger来计算当前正在工作的URLCrawlers的数量，并使用一个辅助对象来执行notifyAll()/wait()调用。但是我读到notify()、/notifyAll()和wait()在某种程度上是不推荐使用</e
浏览 0提问于2010-08-04得票数 7
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
