Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
缓冲后台输入流实现
我已经写了背景InputStream and OutputStream 包装其他流并在后台线程上预读的实现 主要允许在处理解压缩流的不同线程中进行解压缩 压缩 这是一个相当标准的生产者 消费者模型 这似乎是一种利用多核 CPU 的简单方法
Java
Multithreading
Compression
inputStream
producerconsumer
线程安全的异步字节队列
我有一个回调方法 只要有新数据可用 就会调用该方法 public delegate void DataCallback byte buffer int offset int count 我想将其包装在一个实现与此类似的接口的类中 publi
c
Multithreading
net35
Queue
producerconsumer
经典的生产者消费者线程
In the 经典生产者消费者问题 http en wikipedia org wiki Producer consumer problem 制片人什么时候睡觉itemCount BUFFER SIZEamd 宕机时会再次醒来 但有一次it
c
Multithreading
producerconsumer
C++11 非阻塞生产者/消费者
我有一个 C 11 应用程序 其中有一个生成数据的高优先级线程和一个消耗数据的低优先级线程 在我的例子中 将其写入磁盘 我想确保高优先级生产者线程永远不会被阻塞 即它仅使用无锁算法 使用无锁队列 我可以从生产者线程将数据推送到队列 并从消费
Multithreading
C11
producerconsumer
Java如何避免在循环中使用Thread.sleep()
从我的主线程开始 我启动了两个线程 称为生产者和消费者 两者都包含while true 环形 生产者循环是 UDP 服务器 因此不需要睡眠 我的问题出在消费者循环中 消费者循环从链接队 列中删除对象并将其传递给函数以进行进一步处理 根据研究
Java
producerconsumer
两个具有共享缓冲区的等待线程(生产者/消费者)
我试图让一堆生产者线程等待 直到缓冲区有空间容纳某个项目 然后将项目放入缓冲区 如果没有更多空间 则返回睡眠状态 同时应该有一堆消费者线程等待 直到缓冲区中有东西 然后尽可能地从缓冲区中获取东西 如果缓冲区为空则返回睡眠状态 在伪代码中 这
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
1
2
»