producer-consumer 相关问题

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

如何让生产者知道消费者在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

是否可以仅使用互斥量而不使用条件变量来实现生产者使用者?

我想知道是否有任何方法可以使用c中的phtreads来实现生产者使用者,仅使用pthread_mutex变量来控制对必须具有有限大小N的缓冲区的访问,使用...

回答 1 投票 0

消费只有在阵列已满时才能启动

就像标题说的那样,使用者线程在等待整个数组被填满直到开始使用之前一直遇到问题,然后生产者一直等到它再次为空,然后将它们放入...

回答 2 投票 1

生产者消费者竞争条件

我对比赛条件有疑问。它们在代码示例中概述,我在其中编写了注释//可能的竞赛。这种设计是我自己想出的,但是有种族问题...

回答 2 投票 -1

如何将for循环转换为生产者?

{/ ** *产生下一项。 * * @返回产生的项目...

回答 1 投票 0

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