Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
两个具有共享缓冲区的等待线程(生产者/消费者)
我试图让一堆生产者线程等待 直到缓冲区有空间容纳某个项目 然后将项目放入缓冲区 如果没有更多空间 则返回睡眠状态 同时应该有一堆消费者线程等待 直到缓冲区中有东西 然后尽可能地从缓冲区中获取东西 如果缓冲区为空则返回睡眠状态 在伪代码中 这
c
Multithreading
threadsafety
producerconsumer
如何对 IEnumerable
进行分块,而不会在失败时丢失/丢弃项目?
我有一个生产者 消费者场景 其中生产者是一个可枚举的项目序列 IEnumerable
c
LINQ
Exception
producerconsumer
morelinq
使用 Java RealTime 的生产者-消费者架构
我正在使用 Java Realtime Sun JRTS 2 2 设计交易系统 并且想问一些有关最佳实践的问题 因为我担心发明轮子 并且非常确定我的任务已经解决了 所以我有一个线程不断读取套接字 解析字节并提取消息 二进制协议 之后 我应该
Java
Multithreading
Realtime
producerconsumer
在高性能Java应用程序中异步处理低速消费者(数据库)的最佳方式是什么
One EventHandler 数据库消费者 Disruptor调用数据库中的存储过程 速度太慢 以至于阻塞Disruptor一段时间了 因为我需要Disruptor继续运行而不阻塞 我正在考虑添加一个额外的队列 以便EventHandl
Java
Asynchronous
MessageQueue
producerconsumer
disruptorpattern
boost C++ 无锁队列与共享队列
我对多线程编程很陌生 我只知道最常见的生产者 消费者 队列 我正在使用 boost c 库 我不知道是否更好地使用 boost lockfree queue 或使用 mutex 和 condition variable 的 std queu
c
Multithreading
boost
producerconsumer
lockfree
在 Kafka 中设计生产者和消费者组件
我在用Kafka and Zookeeper作为我的数据管道的主要组件 该管道每秒处理数千个请求 我在用Samza作为我需要对数据进行小型转换的实时数据处理工具 我的问题是我的一位消费者 比方说ConsumerA 消耗了几个主题Kafka并
Java线程生产者消费者算法无法正常工作
我正在尝试学习线程 因此我编写了一个示例生产者消费者问题 其中生产者生成从 1 到 10 的数字 而消费者必须显示它们 但只有消费者显示数字 1 并停止 正如我所说 该程序写得不好 可能很荒谬 但我仍然想弄清楚为什么从 1 到 10 的所有
Java
Multithreading
concurrency
producerconsumer
producer
在 C# 中实现生产者/消费者模式
我该如何实施生产者 消费者C 中的模式使用活动和代表 使用这些设计模式时 在资源方面需要注意什么 有什么我需要注意的边缘情况吗 我知道这个线程有点老了 但由于我有时在搜索中遇到它 我决定为那些想知道如何实现简单的通用生产者 消费者作业队列的
c
NET
Events
DesignPatterns
producerconsumer
消耗 System.Threading.Channels.Channel 中的所有消息
假设我有一个多个生产者 1个消费者 未绑定Channel 与消费者 await foreach var message in channel Reader ReadAllAsync cts Token await consume messa
c
channel
producerconsumer
systemthreadingchannels
多生产者多消费者多线程Java
我正在尝试生产者 消费者问题的多个生产者 多个消费者用例 我使用 BlockingQueue 在多个生产者 消费者之间共享公共队列 下面是我的代码 Producer import java util concurrent BlockingQ
Java
Multithreading
producerconsumer
BlockingQueue
使用队列的生产者/消费者线程
我想创建某种Producer Consumer线程应用程序 但我不确定在两者之间实现队列的最佳方法是什么 所以我有两个想法 这两个想法都可能是完全错误的 我想知道哪个更好 如果它们都很糟糕那么实现队列的最佳方法是什么 我关心的主要是这些示例
Java
Multithreading
Queue
producerconsumer
当生产者也是消费者时,如何在生产者/消费者模式中使用 BlockingCollection - 我该如何结束?
我有一个递归问题 消费者在树的每个级别执行一些工作 然后需要递归树并在下一个级别执行相同的工作 我想用ConcurrentBag BlockingCollection等并行运行它 在这种情况下 队列的消费者也是队列的生产者 我的问题是这样的
c
concurrency
producerconsumer
blockingcollection
SQL Server 序列线程安全吗?
标题太宽泛 但我找不到更具体的标题 请随意更改为更好的标题 我有一个使用序列而不是身份的表 我有三个生产者应用程序 它们同时插入表中 一个消费者应用程序从状态未处理的表中选择 然后处理它们 最后更新已处理的行 消费者应用程序有一个规则 它不
sqlserver
Sequence
producerconsumer
C++ 中具有双缓冲区的单生产者、单消费者数据结构
我在 work 有一个应用程序 我必须在以不同频率调度的两个实时线程之间移动 实际的调度超出了我的控制范围 应用程序是硬实时的 其中一个线程必须驱动硬件接口 因此线程之间的数据传输应该是无锁和无等待的可能的程度 需要注意的是 只需要传输一个
c
concurrency
Realtime
producerconsumer
doublebuffering
具有 pthreads 和锁且无 boost 的单个读取器多个写入器
考虑下一段代码 include
c
Multithreading
pthreads
producerconsumer
生产者消费者 - ExecutorService 和 ArrayBlockingQueue
我想知道我对使用 ExecutorService 和 ArrayBlockingQueue 的生产者消费者设计的理解是否正确 我知道有不同的方法来实现这个设计 但我想 最终 这取决于问题本身 我必须面对的问题是 我有一个制作人 他从一个大文
Java
Multithreading
concurrency
producerconsumer
BlockingQueue
如何聚合来自异步生产者的数据并将其写入文件?
我正在学习 C 中的异步 等待模式 目前我正在尝试解决这样的问题 有一个生产者 硬件设备 每秒生成 1000 个数据包 我需要将这些数据记录到文件中 该设备只有一个ReadAsync 一次报告单个数据包的方法 我需要缓冲数据包并按照它们生成
c
NET
taskparallellibrary
asyncawait
producerconsumer
快速 C++ 单生产者单消费者实现
我正在寻找一个单生产者 单消费者的 FIFO 实现 它的执行速度比普通的锁定 写入 解锁 信号 waitForSignal 锁定 读取 解锁的东西更快 我正在寻找大多数 POSIX 操作系统 x86 特定的很好 支持的用 C 或 C 编写的
c
performance
producerconsumer
内核模块与用户空间程序通信的最佳方式是什么?
这个问题看起来很简单 但我想发送一个事件来通知我的用户空间程序模块缓冲区已准备好读取 例如 我的内核模块中有一个缓冲区 其数据将由用户空间程序消耗 如果所有数据都被消耗 内核模块必须在新数据到达时通知我的程序 这是生产者 消费者的典型问题
c
Linux
Linuxkernel
producerconsumer
RabbitMQ:快速生产者和慢速消费者
我有一个应用程序 它使用 RabbitMQ 作为消息队列在两个组件 发送者和接收者 之间发送 接收消息 发送者以非常快的方式发送消息 接收方收到消息后会做一些非常耗时的工作 主要是数据量非常大的数据库写入 由于接收方需要很长时间才能完成任务
Java
Multithreading
rabbitmq
AMQP
producerconsumer
1
2
»