producer-consumer 相关问题

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

如何创建Consumer Producer队列

我有一个Producer，它生成一个带有属性类型的POJO。只能有两种类型，“A”和“B”。我有一个消费者的线程池。每当我从制片人那里收到“B”型的消息时，......

java producer-consumer queuing

回答 2 投票 1

生产者和消费者在发送视频文件时通常如何工作？

根据我的理解，当我想向Kafka经纪人发送电影（4GB）时，一个制作人将发送一个4GB字节的视频文件（序列化它）并将其发送给kafka经纪人和许多想要...的消费者。

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

回答 2 投票 4

如何编写Java多线程代码用于替代生产者和消费者方法。它应该有3个生产者（P1，P2，P3）和1个消费者（C1）

我能否获得实现这一目标的明确方法。我使用了join并等待替代生产者和消费者执行。在一次采访中询问了这个问题。他不喜欢我的解决方案。一世 ...

java multithreading synchronized synchronous producer-consumer

回答 1 投票 0

Amazon SQS如何处理不向同一服务的不同实例发送相同的消息？

我有一个队列（在这种情况下是Amazon SQS）并且有N个运行相同服务的节点正在消耗来自SQS的消息。我怎样才能确保在任何时间点，不超过一个......

message-queue distributed-computing amazon-sqs producer-consumer

回答 1 投票 1

动物园管理员是卡夫卡必须的吗？

在Kafka中，我想只使用单个代理，单个主题和一个具有一个生产者和多个消费者的分区（每个消费者从代理获得自己的数据副本）。鉴于......

partitioning apache-zookeeper producer-consumer apache-kafka broker

回答 6 投票 80

卡夫卡制片人表现不佳

我和kafka制作人有问题。其实我正在使用spring kafka，并通过KafkaTemplate发送消息：默认KafkaProducerFactory defaultKafkaProducerFactory = new ...

apache-kafka messaging producer-consumer kafka-producer-api spring-kafka

回答 2 投票 0

没有获得kafka consumer jmx metrics的records-lag-max值

我正在运行启用了JMX的java kafka流应用程序。我试图获取消费者滞后，但为应用程序拥有的所有消费者获得无限。我正在寻找下面的jmx ......

apache-kafka monitoring jmx metrics producer-consumer

回答 1 投票 0

生产者消费者与消费者陷入僵局

我正在尝试使用条件变量实现生产者使用者，这样我就可以了解同步。我正在使用github来指导我并解决了一些seg故障，但现在看来我的......

c pthreads deadlock race-condition producer-consumer

回答 1 投票 0

Java：实现多线程供应商/消费者管道，每种任务都有并行限制

我们需要异步处理不同类型的对象。使用API 密钥处理每种类型的对象。每个API密钥都有自己的并发使用限制（例如不超过5个并行...

java threadpool producer-consumer

回答 2 投票 2

C中的生产者 - 消费者w / pthreads +信号量（同时访问的缓冲区槽）

我用C编写了一个多线程生产者 - 消费者程序。我的初始程序不是Minimal / Complete / Verifiable，所以我从头开始重写它，而且bug仍在发生。我发现......

c pthreads buffer semaphore producer-consumer

回答 1 投票 1

wait（） - 在java中以奇怪的方式发生故障的notify（）机制[重复]

我已经尝试在这里阅读类似问题的一些答案（我总是这样做），但没有找到（或者不理解？）这个特定问题的答案。我正在实施一个相当简单的消费者-...

java multithreading synchronization producer-consumer

回答 2 投票 2

C＃并行添加队列并侦听队列传播

我是多线程编程的新手。我有一个程序需要查询数据库，然后对返回的数据执行一些数据操作。由于我的组织结构，我必须做...

c# .net queue task-parallel-library producer-consumer

回答 2 投票 0

NServiceBus命令处理程序中的生产者/使用者

因为NServiceBus似乎不支持向消息队列添加优先级机制，所以我想自己实现它。命令处理程序（Producer）：public void Handle（DoAnAction message）{...

c# .net nservicebus producer-consumer

回答 2 投票 5

为什么消费者会降低生产者的表现

我目前正试图通过实现生产者 - 消费者模式来提高我的软件性能。在我的特定情况下，我有一个生产者，顺序创建行和多个......

java multithreading performance executorservice producer-consumer

回答 1 投票 1

如何在python脚本中调试KCL（python）？

我为python使用者使用KCL库，但我不知道如何在python脚本中获取数据等？它通过MultiLangDaemon并基于java工作。我有一个python脚本在java之上工作（我...

python amazon-web-services stream producer-consumer amazon-kinesis

回答 1 投票 0

每次在C中工作最后的消费者（生产者消费者问题）

我有10个消费者和1个生产者线程。生产者线程生成一个随机整数并将其插入缓冲区。消费者线程从该缓冲区中获取和删除项目并进行打印。一切都是......

c multithreading pthreads producer-consumer

回答 2 投票 1

读者 - 写作者对pthreads的问题导致只有1个读者

我的任务是使用posix pthreads创建一个读者 - 作者问题的解决方案。我产生了3位读者和1位作家。任务规范要求一次向队列2添加值（写入者）。 ......

c pthreads producer-consumer

回答 2 投票 1

生产者 - 消费者问题中的无限循环

我试图更好地理解c编程中的fork（）和并发性。我是新手，我无法理解逻辑。我试图制作一个简单的生产者 - 消费者计划......

c fork producer-consumer

回答 1 投票 0

生产者消费者集合，具有读取和写入批量数据的能力

我正在寻找像BufferBlock这样的集合，但使用的方法如下：SendAsync （T []）T [] ReceiveAsync （）有人可以帮忙吗？

c# multithreading task-parallel-library producer-consumer

回答 2 投票 0

为什么生产者 - 消费者不会停止？

我找到了一个代表具有两个线程的producer-consumer的示例。但是，当我向进程发送信号停止时，它不会。它期望第二信号，例如SIGKILL完全停止。我想 ...

python python-3.x multithreading queue producer-consumer

回答 1 投票 1

producer-consumer 相关问题

最新问题