producer-consumer 相关问题

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

消费者生产者队列 .get() 永远加载

我在 article_urls: list[str] 中有一个 URL 列表，我正在尝试创建几个工作人员，它们转到 URL 并从网页获取不同的 URL，然后将该 URL 放入另一个队列。我要

python asynchronous python-asyncio producer-consumer

回答 1 投票 0

为什么这段代码偶尔会挂在 std::condition_variable::wait() 上？

我已经在 C++ 中实现了一个非常标准的单消费者-多生产者模式，此外还限制了队列中的任务数量。一个 Worker 在一个

c++ multithreading producer-consumer condition-variable stdthread

回答 2 投票 0

Go 函数单独运行良好，但在 goroutines 中调用时卡住

这是一个将字节写入 io.Writer 的函数代码，当它单独运行时，它可以很好地处理输入。 func WriteFrame(w io.Writer, frame Frame) (int, error) { 日志.Printf...

go channel goroutine ethernet producer-consumer

回答 0 投票 0

多线程单生产者多消费者问题[关闭]

我的生产者和消费者实施使用互斥锁和条件变量时遇到问题。生产者读取数字很好，所以问题不在那里。我在...中使用互斥锁

c++ multithreading parallel-processing thread-safety producer-consumer

回答 0 投票 0

无法在 Apache Kafka 中与远程生产者写入主题

所以我试着在我的集群中写一个主题，生产者在一个独立的设备上，而不是代理和动物园管理员服务器。我使用 SSL_SASL 身份验证，我相信有一个我...

apache-kafka apache-zookeeper producer-consumer apache-kafka-security

回答 1 投票 0

Apache activemq artemis v.2.28.0：如何按需设置消息是否有过期时间？

我正在学习如何使用 Artemis 消息传递代理。在我的示例应用程序中，我正在应用生产者-消费者方案。我希望发送到队列的某些消息具有过期时间。我的

producer-consumer activemq-artemis

回答 0 投票 0

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

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

algorithm producer-consumer

回答 0 投票 0

ESP32：任务之间的共享变量

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

multithreading esp32 producer-consumer

回答 0 投票 0

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

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

c# channel producer-consumer system.threading.channels

回答 2 投票 0

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

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

rabbitmq rpc producer-consumer

回答 0 投票 0

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

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

python multithreading python-multithreading producer-consumer condition-variable

回答 1 投票 0

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

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

java queue scale producer-consumer persistent

回答 0 投票 0

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

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

python python-asyncio aiohttp producer-consumer python-aiofiles

回答 0 投票 0

生产者-消费者模式

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

c++ multithreading deadlock producer-consumer

回答 1 投票 1

如何解决消费者的问题？

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

multithreading producer-consumer reentrantlock

回答 1 投票 0

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

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

python-2.7 rabbitmq tornado producer-consumer pika

回答 1 投票 0

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

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

java multithreading concurrency synchronization producer-consumer

回答 1 投票 0

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

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

c++ multithreading producer-consumer deque

回答 1 投票 0

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

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

go rabbitmq deadlock channel producer-consumer

回答 1 投票 0

这是TPL Dataflow的工作吗？

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

c# concurrency task-parallel-library producer-consumer tpl-dataflow

回答 2 投票 11

producer-consumer 相关问题

最新问题