producer-consumer 相关问题

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

Go：用于通用数据处理的接口{}的chan

我目前正在尝试用golang编写一些生产者和消费者代码，试图保持它的通用性。它看起来像这样。函数生产者 () { 共享数据通道 <- getData() //retu...

go interface channel producer-consumer data-processing

回答 1 投票 0

双重异常/大师冥想错误：esp32cam 的生产者消费者问题运行书籍示例内存损坏

我的第一个问题。请耐心等待。我正在使用 PlatformIO Windows10 VM 运行 VS-Code，尝试运行书中的第一个项目：使用 ESP32 开发 IOT 项目，Vedat Ozan Oner...h...

iot esp32 producer-consumer freertos platformio

回答 1 投票 0

我的生产者-消费者实现超出了最大大小

我已经实现了一个 Runnable Producer 和一个 Runnable Consumer 以及一个 Store 类。商店分配了最大尺寸的货架。每个生产者添加一个项目，每个消费者将删除一个...

java concurrency producer-consumer

回答 1 投票 0

如何使用.NET Framework和异步I/O高效处理数百万本地文件？

我需要处理一个大存储库（源存储库）并在另一个存储库（元数据存储库）中创建/更新（或保持完整）大约 2M 个文件。虽然文件有~2M，但大部分都只是...

c# multithreading asynchronous producer-consumer .net-4.7.2

回答 1 投票 0

如何将.NET Framework中的Parallel.ForEach移植到异步IO？

我需要处理一个大存储库（源存储库）并在另一个存储库（元数据存储库）中创建/更新（或保持完整）大约 2M 个文件。我当前的实现不使用异步 I/O，甚至

c# multithreading asynchronous producer-consumer .net-4.7.2

回答 1 投票 0

Windows 服务 .Net 8 上的 FileSystemWatcher [IHostedService]

我正在尝试使用 .Net 8 创建一个 Windows 服务应用程序作为托管服务，我的应用程序的想法是监视文件夹列表。问题是我正在丢失由...触发的事件 Created

windows-services .net-8.0 producer-consumer filesystemwatcher concurrent-queue

回答 1 投票 0

当我的队列有东西要处理时如何触发后台线程

我正在使用 ConcurrentQueue 来存储来自多个线程的消息。如何创建一些后台线程，当我的队列中有东西时会自动触发？

c# multithreading producer-consumer concurrent-queue

回答 2 投票 0

LabVIEW 正在覆盖队列中捕获的图像

我正在使用视觉例程从 300fps GigE 相机捕获帧（“抓取”）。相机传输帧的速度比高清写入帧的速度要快一些，所以我在一个循环中捕捉并坚持......

parallel-processing video-processing producer-consumer labview

回答 1 投票 0

向消费者发出生产者已停止生产的信号

我正在开发一个控制台 .NET Core 应用程序，它收集电子邮件数据，然后使用通道异步发送这些电子邮件。我目前正在将消费者添加为托管服务...

c# .net asynchronous channel producer-consumer

回答 1 投票 0

无法从我的 Spring 应用程序连接在 docker 容器中运行的 kafka 代理

我在kafka中进行了实践，编写了一个简单的Spring生产者-消费者应用程序。我创建了一个 docker-compose 文件来启动容器内的 Zookeeper 和 kafka 代理实例。我是...

docker-compose spring-kafka producer-consumer

回答 1 投票 0

无法使用java从rabbitmq中的传递回调块分配消息

我正在尝试使用 Java-Maven 使用来自 RabbitMQ 的消息。我能够获取并打印传递回调块内的消息，但无法将该值分配给任何全局变量。拜...

java rabbitmq message-queue producer-consumer

回答 2 投票 0

为什么我的使用 pthread_cond_signal 的生产者-消费者程序会卡住？

我正在用 C 语言编写一个使用 pthread 的生产者-消费者程序。该程序应该生产和消费最多达到限制 n 的项目。然而，当 n = 1 和 n = 2 时，我的程序通常很快就会卡住。成为...

c producer-consumer condition-variable

回答 1 投票 0

Asyncio 任务已销毁但处于挂起状态

我正在向外部 API 发出请求，获取响应并将其写入文件。一切正常/运行良好，但是我收到“任务已被破坏，但正在等待！”警告...

python python-asyncio producer-consumer python-aiofiles

回答 1 投票 0

一个或多个消费者从单个生产者接收最新数据的数据结构是否有通用名称？

行为非常简单：需要 N 个槽位，其中 N 是消费者数量加 2。生产者锁定一个用于写入的槽，该槽未被消费者锁定，并且不是最后写入的索姆...

data-structures producer-consumer

回答 1 投票 0

使用 Dart Futures 的生产者-消费者：有没有办法让 Dart“任务”在等待数据结构上的活动时挂起？

我试图了解 Dart 的 async/await 如何工作的一些想法/直觉。这是一个简单的 Dart 程序，其中包含：将字符串添加到管道（List）的生产者函数。消费者

dart async-await producer-consumer

回答 1 投票 0

从同一线程高效读取两个不同的System.Threading.Channels

假设以下情况：我有两个不同的事件流流 1 是基于拉动的快速移动事件流（想想金融工具价格）流 2 的移动速度要慢得多 (

c# concurrency producer-consumer

回答 1 投票 0

C# 中的内存数据结构或集合，表现出像 AWS SQS 或 Azure 服务总线队列这样的查看和锁定行为

我需要将消息从云队列中出队，然后处理它们。然而，对于每个工作实例，我们希望让工作人员定义它可以轻松处理多少消息

c# .net publish-subscribe producer-consumer system.threading.channels

回答 1 投票 0

Kafka 消费者在暂停和恢复后不消费消息

我正在使用这个node-rdkafka库来实现具有消费者暂停和恢复方法的节点kafka来处理背压。我创建了一个小演示，我可以在其中暂停消费者并......

node.js apache-kafka producer-consumer

回答 2 投票 0

消费后台线程生产者生成的项目时如何保持 UI 响应？

我已将长时间运行的同步操作卸载到后台线程。这需要一段时间才能开始，但最终它开始很好地生产物品。那么问题来了如何食用

windows multithreading producer-consumer

回答 1 投票 0

Spring Boot 消费者类也应该是生产者/rabbitmq

我正在使用rabbitmq和springBoot。我有一个消费者当前正在侦听一个队列，并且应该根据收到的消息向另一个队列发送一条新消息。这就是我的问题。我...

java spring-boot rabbitmq producer-consumer

回答 1 投票 0

producer-consumer 相关问题

最新问题