producer-consumer 相关问题

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

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

Monitor.Wait 是否需要同步?

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

回答 3 投票 0

BlockingCollection<T> 抛出意外的 InvalidOperationException

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

回答 2 投票 0

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

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

回答 4 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

使用条件变量的正确方法是什么?

我的作业提供了运行时使用大量 CPU 的代码。目标是通过在生产者消费者问题中实施条件变量来减少该数量。 我

回答 1 投票 0

高性能融合生产者/消费者模式

假设你有以下界面: 接口 IConflateWorkByKey { IAsyncEnumerable> GetValues(); void Publish(TKey 键, TValue 值);...

回答 1 投票 0

JMS消息消费

我不确定以下场景中会发生什么,如果有人解释一下将会有很大帮助。 生产者(P)发送消息M1、M2、M3、M4、M5、M6、M7;假设它是从时间 T1 发送到 ...

回答 1 投票 0

生产者/消费者问题:面临死锁

我恰好使用了几个线程来生成和使用缓冲区内的数据。 只有一个线程用于生成数据,也只有一个线程用于消费。 然而,我仍然面临着致命的...

回答 1 投票 0

如果自动提交的发生频率低于轮询,Kafka Consumer 如何跟踪已处理的消息?

因此,如果 Kafka Consumer 启用了自动提交,提交间隔为 5 秒,并且我们每 1 秒消费一批...... ...消费者会在自动提交之前多次处理消息...

回答 1 投票 0

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