producer-consumer 相关问题

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

如何在Python中迭代Queue.Queue项目?

有谁知道迭代 Queue.Queue 元素而不将它们从队列中删除的 Pythonic 方法。我有一个生产者/消费者类型的程序,其中要处理的项目由

回答 5 投票 0

Python 中 SharedMemoryManager 管理的可变数量的 SharedMemory 对象

我希望有可变数量的 SharedMemory 对象(取决于我的生产者-消费者应用程序架构中的消费者进程的数量)由 SharedMemoryManager 管理,所以我正在创建

回答 1 投票 0

EasyNetQ 消费行为和模块化整体

我是 EasyNetQ 的新手。考虑将这个库采用到我的项目中。 我有一个关于消费消息的问题。维基百科指出: “当消息从通过

回答 1 投票 0

如果 Channel 有 Complete 方法,为什么还需要 CancellationToken?

我正在使用System.Threading.Channel。 Channel.Reader.WaitToReadAsync 接受 CancelationToken。但是,还有 Channel.Writer.TryComplete() 或 Channel.Writer.Complete() 方法。那么,为什么会...

回答 1 投票 0

如何向Kafka中每一个空闲的消费者发送消息?

我在 Kafka 中有 3 个消费者和 1 个生产者。 当生产者发送所有消息时(我的简单代码中有 100 条消息),这些消息被分配给三个消费者,而我的 main

回答 1 投票 0

MassTransit 不消耗非 MassTransit 消息

我必须使用Python发布消息并使用MassTransit(.Net core应用程序)使用它。 为了进行测试,我创建了一个控制台应用程序来使用 Azure.ServiceBuss 库生成消息。

回答 1 投票 0

尝试在 ConcurrentQueue 中出队

如果队列中没有项目,ConcurrentQueue中的TryDequeue将返回false。 如果队列为空,我需要我的队列将等待,直到新项目添加到队列中,并将该新项目出列...

回答 3 投票 0

ConcurrentQueue<> 中的 TryDequeue 和 TryTake 有什么区别?

在ConcurrentQeueue<>类中,定义了额外的方法TryDequeue()。但是,由于它实现了 IProducerConsumerCollection<>,因此它还有一个 TryTake() 方法。根据文档,他们

回答 1 投票 0

使用 Java 对象监视器实现阻塞有界队列 [关闭]

我正在通过在Java中实现自己的有界阻塞队列的实践来学习更多关于Java中的并发和锁。我有以下使用 ReentrantLock 的实现

回答 0 投票 0

在生产者-消费者问题中应该使用多少个条件变量?

我目前正在学习C++中的多线程。我对条件变量有疑问。 如果我有这样的代码: std::condition_variable cvS; std::condition_variable CVR; std::condition_varia...

回答 2 投票 0

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

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

回答 1 投票 0

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

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

回答 2 投票 0

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

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

回答 0 投票 0

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

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

回答 0 投票 0

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

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

回答 1 投票 0

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

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

回答 0 投票 0

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

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

回答 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

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