producer-consumer 相关问题

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

以输入为中心的方法与以输出为中心的方法来解决算法?

我正在努力理解这两种解决问题的方法之间的区别。 从我读到的: “以输入为中心的策略:在这种方法中,你处理一个输入...

回答 0 投票 0

ESP32:任务之间的共享变量

我想在 ESP32 上实现生产者/消费者任务。为此,有两个任务:第一个任务通过 I2C 读取输入并将其存储在队列中;第二个任务取值...

回答 0 投票 0

消费 System.Threading.Channels.Channel 中的所有消息

假设我有很多生产者,1个消费者未绑定频道,有一个消费者: await foreach (var message in channel.Reader.ReadAllAsync(cts.Token)) { 等待消费(消息); } 问题是...

回答 2 投票 0

RabbitMQ 消费者从未附加到队列,响应到达并且队列从未被删除

我的 rpc 请求场景中有一个奇怪的案例。由于 autodelete 的属性设置为 true,我发现了它。 此属性表示当...时删除至少有一个消费者的队列

回答 0 投票 0

如何让生产者知道消费者在python中完成工作

嗨我想瘫痪阅读和分析多个文本文件的过程。所以我有一个生产者 Producer 和两个消费者 TextAnalyzer A 和 TextAnalyzer B。 生产者有一个 RequstQueue

回答 1 投票 0

持久队列生产者消费者聚合

我正在用 JAVA 设计一个简单的生产者消费者对,它将大规模运行,生产者将数据转储到文件系统中,消费者将定期获取数据,

回答 0 投票 0

如何使用 aiohttp 和 aiofiles 实现生产者-消费者模型

问题: 我想使用 aiohttp 生产者下载大量文件,而 aiofiles 消费者从池中提取文件。 我见过这样的实现 参考https://gist.github.com/showa-...

回答 0 投票 0

生产者-消费者模式

我正在尝试模拟关于多线程的生产者-消费者模型。我们假设有三个规则需要遵守。生产者不能在桶里添加产品 当桶里已经装满了产品的时候 ...

回答 1 投票 1

如何解决消费者的问题?

我想用ReentrantLock实现一个有仓库、消费者和制造商的程序。我有一个基于数组的循环队列作为货物的存储。生产者可以生产产品 ...

回答 1 投票 0

龙卷风上的皮卡消费者跑不动了

我想使用RabbitMQ和Tornado建立监控系统。我可以运行生产者,我的消费者可以消费队列中的数据,但数据不能显示在网站上。这只是我之前的实验...

回答 1 投票 0

共享物品生产者和消费者问题

我有一味生产者消费者问题(我找不到类似的问题,搜索关键词也用完了),消费者本身就是生产者。生产的物品可以共享。...

回答 1 投票 0

C ++双端队列使用者总是从生产者那里得到空队列

在一个非常简单的消费者/生产者测试中,我的消费者总是得到一个空队列。而且我不知道哪里错了。这是一个非常简单的测试程序,所以我希望一个敏锐的眼睛可以给...

回答 1 投票 0

永久终止程序并与RabbitMQ使用者一起进入频道

我正在用Go编写程序,并使用go频道编写RMQ使用者,来到了这些场景。 “永远进入通道”阻塞主线程,直到它从其他go例程获取停止信号为止。但下面...

回答 1 投票 0

这是TPL Dataflow的工作吗?

我在不同的任务上运行了非常典型的生产者/消费者模型。任务1:从二进制文件中读取一批byte [],并为每个字节数组集合启动一个新任务。 (操作是...

回答 2 投票 11

使用信号量的生产者-消费者模式实现

家伙!我知道可以使用信号量同步原语来实现生产者-消费者模式。但是要执行多少个信号灯以及需要哪些事件?

回答 1 投票 0

C ++中的多线程生产者/消费者

我正在研究多线程并编写了基本的生产者/消费者。我在下面写的生产者/消费者有两个问题。 1)即使将消费者的睡眠时间设置为低于生产者的睡眠时间...

回答 2 投票 0

异步队列实现。Wait()比等待更快

为了提供可以逐个排队和执行异步方法的生产者-消费者功能,我正在尝试实现一个异步队列。我注意到在大型...

回答 1 投票 0

Java多线程生产者-消费者

遵循此代码,如何在发送记录和获取记录之间实现多线程。公共类Test_ProducerConsumer {//主要方法public static void main(String [] args){...

回答 1 投票 0

Kakfa重试概念-卡夫卡将停止哪些基础重试?

作为Kafka的新手,试图了解Kafka中的重试概念。什么基础的重试过程将完成?示例Retries参数我们设置为7。现在问题在这里,卡夫卡将是...

回答 1 投票 0

批量使用Amazon sqs,高山sqs春季靴中的消息

我已经配置了SQS侦听器以使用消息列表中的消息,但是一次只能接收一条消息,并且由于无法将model.StudentData转换为Java实例而出错。...]

回答 1 投票 0

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