producer-consumer 相关问题

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

Spring Boot 消费者类也应该是生产者/rabbitmq

我正在使用rabbitmq和springBoot。我有一个消费者当前正在侦听一个队列，并且应该根据收到的消息向另一个队列发送一条新消息。这就是我的问题。我...

java spring-boot rabbitmq producer-consumer

回答 1 投票 0

针对高流量 kafka 主题扩展 karafka 消费者实例

我正在使用 Rails 和 Karafka gem。在其中一个主题中，流量会很大，因此我向该主题添加了 10 个分区，还将 Karafka::App.config.concurrency 设置为 10。但这并没有给我一个

ruby-on-rails parallel-processing producer-consumer karafka

回答 1 投票 0

如何使用 .NET Core 7 控制台向 MassTransit 消费者发送数据

我的解决方案中有两个项目，一个是控制台，另一个是API。在 API 项目中，我按如下方式设置 MassTransit：使用大众运输；使用通知； var builder = WebApplication.

asp.net-core rabbitmq masstransit producer-consumer

回答 1 投票 0

Python 中使用 multiprocessing.Queue 的生产者消费者模式

我是 Python 及其并发方法的新手。我正在尝试使用 multiprocessing.Queue 类来实现生产者消费者模式。通过使用 Queue 类，我可以编写以下内容...

python multiprocessing producer-consumer

回答 1 投票 0

使用Python，如何生成大于1MB的kafka消息？

我试图通过kafka传输一些巨大的json数据，但它没有发生。 python 生产者没有错误，消费者端也没有任何消息。生产者 = KafkaProducer(bootstrap_se...

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

回答 2 投票 0

生产者/消费者 - Queue.通过列表获取

我正在尝试从数据库获取数据以便输入到机器学习模型。但我的Producer只是将数据一行一行地放入DB中的队列，Consumer也只能一行一行地获取。我的机器学习M...

python django-views queue buffer producer-consumer

回答 1 投票 0

消费者组中的消费者如何在 Azure eventhub 中工作？

假设我的 Azure eventhub 中有 32 个分区。我有一个消费者尝试读取 32 个分区并进行检查点设置。但有时，事件中心的传入消息可能会扩大。为了

azure event-handling azure-eventhub producer-consumer

回答 1 投票 0

更改clientId是否会让Kafka将其视为新消费者并执行重新平衡？

我是 Kafka 新手，正在探索 Kafkajs 文档。我有一个关于 clientId 配置的问题。在文档中，提到 clientId 是 cli 的逻辑分组...

node.js apache-kafka producer-consumer kafkajs clientid

回答 1 投票 0

Monitor.Wait 是否需要同步？

我开发了一个通用的生产者-消费者队列，它通过监视器以以下方式发出脉冲：排队：公共无效EnqueueTask（T任务） { _workerQueue.Enqueue(任务);

c# synchronization monitor producer-consumer

回答 3 投票 0

BlockingCollection<T> 抛出意外的 InvalidOperationException

我在.NET8中尝试BlockingCollection（作为队列），有时我最终会遇到异常： “System.InvalidOperationException：集合参数为空并且已...

c# .net producer-consumer .net-8.0 blockingcollection

回答 2 投票 0

使用命名互斥锁来锁定文件

我正在使用命名互斥体来锁定对文件（路径为“strFilePath”）的访问，如下所示：私有无效DoSomethingsWithAFile（字符串strFilePath） { 互斥体互斥体 = 新互斥体(false,

c# .net producer-consumer

回答 4 投票 0

在 C# 中使用 BlockingCollection 进行并发消息反序列化的线程安全问题

我有以下设置内部课程计划 { 公共 BlockingCollection> MessageQueue { 获取；放; } = []; 静态无效主（字符串[]参数） { ...

c# producer-consumer system.text.json blockingcollection

回答 1 投票 0

ActiveMQ Artemis 发送消息而不创建生产者连接

有没有什么解决方案可以在不创建生产者的情况下将消息发送到ActiveMQ Artemis队列？我想通过消费者连接发送字节消息。有一个 QueueControlImpl 类，但用于发送字节 m...

producer-consumer activemq-artemis

回答 1 投票 0

我有一个kafka主题的两个消费者组我想设置一种没有重复的方法

一个kafka主题有两个消费者组我想设置这样一种方法，如果一个消费者组宕机，那么第二个消费者组开始从第一个消费者组留下的偏移量开始消费，以避免

apache-kafka kafka-consumer-api producer-consumer

回答 1 投票 0

对于这种情况，我应该如何使用线程在java中实现并行性？

所以我的场景是我收到一条执行作业的消息。该作业有一个 sourceId。现在，一次应运行具有一种类型的 sourceId 的一项作业，其他作业应排队。当一项工作开始时，它...

java multithreading concurrency quarkus producer-consumer

回答 1 投票 0

使用 PThreads 的 C 生产者-消费者

我正在解决一个问题，我正在实现一个模仿生产者-消费者范式的程序。当我只有一个生产者和一个消费者时，我使用的代码可以工作，但它不会......

c multithreading pthreads semaphore producer-consumer

回答 1 投票 0

条件变量解决多生产者多消费者问题

我目前正在学习操作系统，我遇到了“使用条件变量解决并发问题”。任务是模拟具有 si 队列的多线程 Web 服务器...

multithreading concurrency producer-consumer condition-variable critical-section

回答 1 投票 0

如何使用 C#/C++/librdkafka 与 OIDC 和 Azure AD 作为 apache kafka 中 OAUTHBEARER 的令牌提供程序？

我尝试使用 C# 向 Apache Kafka 生成消息。但我注意到有一个名为 sasl.login.callback.handler.class 的配置，应该在 kafka 生产者客户端中配置。但我找不到

apache-kafka oauth-2.0 oauth azure-active-directory producer-consumer

回答 1 投票 0

如何批量处理 ChannelReader<T>，在消费和处理任何单个项目之间强制执行最大间隔策略？

我在生产者-消费者场景中使用Channel，并且我需要以每批10个项目的方式消耗该通道，并且不让任何消耗的项目在

c# memory-leaks producer-consumer iasyncenumerable system.threading.channels

回答 1 投票 0

通道<Task> - 编写器在下一步逻辑之前等待任务结果

我有一个 Worker 类，用于处理作业消息。我希望它串行处理消息，这样我就不需要在多线程调用者之间同步（锁定）其内部数据更改。对于

c# asynchronous async-await channel producer-consumer

回答 1 投票 0

producer-consumer 相关问题

最新问题