concurrentqueue

concurrentqueue copied to clipboard

- **Update concurrentqueue.h** - **Update lightweightsemaphore.h** - **Update lightweightsemaphore.h** - **Update lightweightsemaphore.h** - **Replace BLOCK_SIZE with CQ_BLOCK_SIZE to avoid conflicts with ** - **Improve compatibility with c++ modules** - **Disable...

jcelerier

How to drain a multi-producer queue properly?

1

I struggle to figure out how to drain a queue properly. **tl;dr** Sentinel-based approach fails because sending the sentinel last doesn't guarantee it's read last. I have a multi-producer queue....

mooskagh

In some cases, the order of values retrieved by calling try_dequeue does not match the order in which the values were placed by enqueue.

6

Call Sequence: 1 call to enqueue, inserting value 4. 2.After a 50ms interval, second call to enqueue, inserting value 0. 3.Within less than 1ms, first call to try_dequeue, retrieving value...

wangxm7237

Pre-allocation of producers

3

As far as I understood, the constructor: ``` ConcurrentQueue(size_t minCapacity, size_t maxExplicitProducers, size_t maxImplicitProducers) ``` uses the `maxExplicitProducers` and `maxImplicitProducers` to set the initial number of blocks. However, it does...

frankist

When there is lot of enqueue , it fails

10

I have been using queue like this parallelQueue::ConcurrentQueue *pMPSC_consume; pMPSC_consume = new ConcurrentQueue(PARALLEL_QUEUE_MAX_NODES, 0, enteredNoOfThreads); and when i call pMPSC_consume->try_enqueue() , its failing at times .... I have given PARALLEL_QUEUE_MAX_NODES...

abhit011

Segmentation fault during fuzztests "unaligned tcache chunk" / "double free or corruption (out)"

2

GCC version: ``` $ g++ --version g++ (Ubuntu 11.4.0-1ubuntu1~22.04) 11.4.0 ``` OS: ``` $ uname -a Linux iafanasyev-pc 6.8.0-52-generic #53~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Wed Jan 15 19:18:46 UTC 2 x86_64 x86_64...

ivafanas

concurrent queue on a GPU

1

Out of curiosity i would like to ask if anyone has thought about implementing such concurrent queue on a GPU side? With the results for task scheduling on CPU it...

natalia342N

Hang when shutting down blocking concurrent queue via interrupt

1

When attempting to interrupt a blocking concurrent queue that is waiting on a time out, I'm experiencing a hang (until the timeout) in this line ``` do { #ifdef MOODYCAMEL_LIGHTWEIGHTSEMAPHORE_MONOTONIC...

diehard2

try_enqueue fails

3

Hello, may I ask if there is a limit on the number of entries for this queue? When I try to enqueue more than about 1024 in a for loop,...

ZWF12345678

Prepare enqueue API

4

As for today we have bulk operations which reduce synchronization costs in average but it has high latency as we should move many elements at once. And I think API...

Hattonuri