producer-consumer 相关问题

生产者 - 消费者问题（也称为有界缓冲问题）是多进程同步问题的经典示例。该问题描述了两个进程，生产者和使用者，他们共享一个用作队列的通用固定大小缓冲区。

生产者和消费者缺少数据

在广播消息系统中，订户/客户端如何知道他们缺少一些丢失的消息？请描述一个解决方案。

producer-consumer producer

回答 1 投票 0

使用多处理程序实现排序的生产者/消费者队列

我有一个非常普通的生产者/消费者场景，但有一个转折点。我需要从数GB的输入流（可以是文件或HTTP流）中读取文本行；用...

python multiprocessing queue producer-consumer

回答 1 投票 1

C ++多线程生产者－消费者问题

我写了一个用条件变量乘以生产者和消费者的代码。即使当我只有一个生产者和一个消费者时，它也不起作用。生产者和消费者都应在while（true）...

c++ multithreading producer-consumer

回答 2 投票 0

如何使用自动线程管理在Java中实现生产者/消费者

我需要实施一个生产者/消费者方案，在该方案中，出于性能原因，消费者尝试批量处理许多工作项（每个工作项都耗尽了工作队列）。此刻我只是...

java executorservice producer-consumer

回答 2 投票 0

根据消费者从Kafka主题中读取过滤器消息

我们如何在Kafka主题中使用来自多个或单个分区的自定义消息？当我在Kafka主题中使用来自多个分区的消息时，如何只读取1条消息？

apache-kafka kafka-consumer-api producer-consumer

回答 1 投票 0

如何解决警告：阵营不承认一个DOM元素的X道具

我使用了一个名为反应，火力-JS处理火力权威性的事情，但我的理解，反应和提供者的消费理念是有限的。我开始与一个在建一个非常大的JSX事情都...

javascript reactjs firebase firebase-authentication producer-consumer

回答 1 投票 1

确实的RabbitMQ持续了消费者一个打开的连接？

我想实现在环境中的RabbitMQ的解决方案，其中所有的连接都必须从安全区域开始不太安全区。该标准的RabbitMQ实现预见...

callback rabbitmq producer-consumer messagebroker consumer

回答 1 投票 0

MPSC队列：竞争条件

我想在此基础上通过一个梅德Vyukov用C语言编写实现无锁多单生产者消费者队列。我写了一个测试，到目前为止几乎工程。但消费者...

multithreading c++17 race-condition producer-consumer task-queue

回答 1 投票 0

的RabbitMQ AMQP - 听ACK从消费信息

我在同一台机器上生产商和经纪商。生产者发送消息如下所示：信道= connection.createChannel（）; //创建一个持久的队列（如果尚未存在）channel.queueDeclare（...

rabbitmq amqp producer-consumer

回答 1 投票 4

生产者消费者问题如何发生饥饿

请举例说明饥饿发生的生产者消费者情景。

java multithreading producer-consumer

回答 1 投票 -4

Java中的信号量。生产者 - 消费者问题

我正在测试信号量的使用与典型的生产者 - 消费者问题，其中我只有一个生产者和一个消费者。生产者一次添加一个产品，消费者可以退出......

java semaphore producer-consumer

回答 2 投票 0

在Kafka / RabbitMQ中的每个消息确认

我们有一个工作的rabbitmq。实现，由于数量，我们计划切换到kafka。我有一点怀疑。在RabbitMQ中，当消费者从Q消息中消息时...

apache-kafka rabbitmq producer-consumer

回答 4 投票 1

Java 8函数式编程 - 需要在类上编写泛型函数

我想创建一个接受类似set的方法（nodeStatus，status，NodeStatus :: setStatus，Status :: valueOf）; set（nodeStatus，errorCode，NodeStatus :: setErrorCode，ErrorCode :: valueOf）; ...

java lambda functional-programming producer-consumer

回答 2 投票 3

消费者/生产者样式记录器中的同步错误

我看到很多这样的问题，但没有人帮助我，所以我发布了我的。我为多线程日志记录做了一个记录器。只有一个线程（在创建第一个记录器时创建。）处理日志...

c++ multithreading logging producer-consumer condition-variable

回答 1 投票 0

扩展分区时的Kafka主题排序

考虑您的生产者为系统用户创建消息，并且它们的顺序在用户级别中很重要。我的制作人，添加消息到主题有两个分区，我...

apache-kafka kafka-consumer-api producer-consumer

回答 1 投票 1

生产者消费者计划在Java中使用wait（）和notify（）

我正在使用低级同步和wait（）和notify（）在Java中执行经典的Producer-Consumer问题。我知道有更好的实现使用java.util.concurrent包中的结构...

java multithreading producer-consumer

回答 4 投票 1

同一组的kafka消费者如何在他们之间共享消息？

比如，有一个消费者群体。（具有相同组ID的消费者）。消费者组正在从经纪人那里消费主题A.主题A有4个分区，该组中有4个消费者。每个......

apache-kafka kafka-consumer-api producer-consumer

回答 1 投票 0

H2O生成器java线程锁，可重入锁

我想通过三线连续产生h2o第一个线程将产生h，第二个产生h，第三个产生o。我怎么能用锁，消费者生产者包com ....

java multithreading locking producer-consumer

回答 2 投票 0

Java如何避免在循环中使用Thread.sleep（）

从我的主要我开始两个线程称为生产者和消费者。两者都包含while（true）循环。生产者循环是UDP服务器，因此它不需要睡眠。我的问题出现在Consumer循环中。 ...

java producer-consumer

回答 3 投票 1

当多个生产者向Broker写入相同的消息时，Broker会做什么？还有一个相关的问题（由于150个字符的限制）

生产者A将消息写入Broker A（分区1），生产者B将相同的消息写入Broker A（分区1）。消息或经纪人会怎么样？我猜是因为有相同的......

apache-kafka producer-consumer kafka-producer-api producer

回答 1 投票 0

最新问题

© www.soinside.com 2019 - 2024. All rights reserved.