MCPcopy Create free account
hub / github.com/cameron314/concurrentqueue / wait_dequeue

Method wait_dequeue

blockingconcurrentqueue.h:365–373  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

363 // Never allocates. Thread-safe.
364 template<typename U>
365 inline void wait_dequeue(U& item)
366 {
367 while (!sema->wait()) {
368 continue;
369 }
370 while (!inner.try_dequeue(item)) {
371 continue;
372 }
373 }
374
375 // Blocks the current thread until either there's something to dequeue
376 // or the timeout (specified in microseconds) expires. Returns false

Callers 2

blocking_wrappersMethod · 0.80

Calls 2

waitMethod · 0.45
try_dequeueMethod · 0.45

Tested by 1

blocking_wrappersMethod · 0.64