concurrentqueue

concurrentqueue copied to clipboard

Waiting without dequeuing

1

Is there a way to wait (using the blocking variant) without dequeuing from the container?

cconverse711

Hi dear developer, Have you ever considered replacing the LightweightSemaphore in BlockingConcurrentQueue with a LIFO one to reduce unnecessary thread wake-ups in usage scenarios similar to threadpool?

GHScan

just include "concurrentqueue/concurrentqueue.h" when cmake program errors appears: /opt/vcpkg/installed/x64-linux/include/concurrentqueue/concurrentqueue.h: In static member function ‘static U* moodycamel::ConcurrentQueue::create_array(moodycamel::ConcurrentQueue::size_t)’: /opt/vcpkg/installed/x64-linux/include/concurrentqueue/concurrentqueue.h:3612:40: error: expected type-specifier before ‘;’ token 3612 | new (p + i) U();...

yangqun

Occasionally program can be stuck inside try_dequeue of blockingconcurrentqueue.h

1

Why try_dequeue functions of blocking queue use while instead of if? when inner.try_dequeue(item) return false, it will never get out.

wudandan1221

Every ProducerToken is associated with an inner SPMC queue, while ConsumerToken chooses the best suitable SPMC when the holding thread begins starvation if the originally chosen queue is empty at...

hunt978

Memory Leak

13

Hi Sorry for the previous issue(mistakenly opened with a wrong user) We are using concurrentqueue in our trading application for transfering data between threads, and we are very pleased about...

tolgatanriverdi

Question: Does this build and run on QNX ?

2

Hello all, Anyone with experience on QNX? It fails with the unsupported system when it tries to define the Semaphore wrapper. QNX probably does not have __unix__ defined. I'd be...

kobi-ca

How to force fully remove the remaining data.

4

I did my own statistics when using concurrentqueue, and occasionally there was a problem that the remaining data could not be taken out of the queue. The detail is: After...

runmouse

Zero-copy support

4

I am willing to use the concurrent queue for a low latency network application. Overall, I need to enqueue network packets on one thread, and decode them in another thread...

NewbiZ

How to use token in multi producers and multi consumers situation?

1

I have multi producers and multi consumers, while producers and consumers are in different threads. How to use tokens to maximum the performance? Could u please give me some advices.

mcgrady-forever