10#ifdef RDK_BUILD_THREADSAFE_SSS
11#ifndef CONCURRENT_QUEUE
12#define CONCURRENT_QUEUE
13#include <condition_variable>
64void ConcurrentQueue<E>::push(
const E &
element) {
65 std::unique_lock<std::mutex>
lk(
d_lock);
83bool ConcurrentQueue<E>::pop(E &
element) {
84 std::unique_lock<std::mutex>
lk(
d_lock);
106bool ConcurrentQueue<E>::isEmpty()
const {
107 std::unique_lock<std::mutex>
lk(
d_lock);
112bool ConcurrentQueue<E>::getDone()
const {
113 std::unique_lock<std::mutex>
lk(
d_lock);
118void ConcurrentQueue<E>::setDone() {
119 std::unique_lock<std::mutex>
lk(
d_lock);
125void ConcurrentQueue<E>::clear() {
126 std::unique_lock<std::mutex>
lk(
d_lock);
bool rdvalue_is(const RDValue_cast_t)