producer-consumer

1热度

2回答

所有C＃[1] [2]似乎有隐约类似于接口： private Queue<T> items; public void Produce(T item) public T Consume() 在任何实现方式中有像下面？ private Queue<T> items; public void Produce(T[] item) public T[] Consume(int count)

0热度

1回答

单个生产者到多个消费者（相同的消费者群体）

我已经尝试将消息从单个生产者发送到2个不同的消费者，其中不同消费者组ID。结果是消费者能够阅读完整的消息（两个消费者都得到相同的消息）。但我想问一下，这两位消费者是否可以在设置消费者群组名称时将其设置为SAME？

0热度

2回答

多线程生产者/消费者同步问题

我遇到了两个线程似乎没有正确同步的问题。我基本上有一个布尔值名称“占用”。当没有线程启动时，它被设置为false。但是当一个开始，线程集占用是真的我有一个类有线程（运行），他们调用下面的函数。这是一个模拟银行示例，它接收一定金额（初始余额），然后随机执行提款和存款。我的教授提到了一些有关从存款线索中提取信号的信号？这是如何运作的？退出线程，它应该运行，直到余额为两个低，并等待存款线程。我应该怎么

2热度

2回答

Java线程生产者和消费者

我正在编写一个使用ReentrantLock而不是生产者和消费者问题的小程序。但程序卡住了，因为一旦生产的物品被消耗，消费者线程将停止并且不再恢复消耗。代码片段： import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.

0热度

1回答

如何使用New Kafka Consumer API编写样本kafka喷嘴？

喜欢风暴卡夫卡客户端，我曾用风暴卡夫卡客户端，但不能很好地工作，并写一个新的喷口不工作了。谁可以帮我写一个样品卡夫卡壶嘴。

1热度

1回答

等待多个不同的脉冲事件

我得到了一个归结为生产者 - 消费者模式的应用程序。有几个线程正在做一些工作并更新单个数据集，以便多个线程可以使用这些数据并自行完成工作。目前，这并不是非常复杂，所有消费线程都会等待数据集，直到其中一个生产者调用一个pulseall。现在有一个愿望是在任何一个集合发生变化时，让其中一个消费者线程从两个不同的数据集中消费。团队希望将重构保持在最低限度，并且我对线程的有限经验给我一些问题找到了一个干

2热度

1回答

如何从ConcurrentQueue消耗chuncks正确

我需要实现可以从多个线程填充请求的队列。当这个队列变得大于1000个完成的请求时，这个请求应该被存储到数据库中。这是我的实现： public class RequestQueue { private static BlockingCollection<VerificationRequest> _queue = new BlockingCollection<VerificationReq

0热度

2回答

生产者 - 消费者c - 对于较大值的分段错误

我正在做一个生产者一个消费者问题，其中有两个线程。我使用共享链接列表来完成，在这个链接列表中，生产者放置了一些东西，消费者从同一个列表中获取。我必须用2个值N和B来运行我的代码（N是要传输的数据大小，B是共享链表的最大大小）。（./thread-a1 N B）此代码对小值运行良好。但是，对于N = 20,000和B = 16，它给出了分段错误：11 我无法弄清楚为什么会发生这种情况。请帮助

0热度

1回答

如何在Java上正确编写RabbitMQ Publisher？

我们是否需要为每个线程创建单独的通道或为所有线程使用相同的通道？还有关于连接的相同问题。我们是否需要为每个线程或单个连接使用不同的连接？当我们在每个线程的所有线程和单个通道中使用一个通道时，有什么区别？

0热度

1回答

根本没有输出数据生产者/消费者线程

编辑：我有一个生产者类，发送一些数据到SharedBuffer类。这个数据被添加到一个ArrayList中，其限制被设置为100.向所述列表添加数据没有问题，但是使用者类没有设法从列表中获取任何数据。根本没有输出（没有空或错误）。编辑2：添加了将数据放入数组的方法。 SharedBuffer类： static final int RESOURCE_LIMIT = 100; pri