Searched refs:SafeBlockQueue (Results 1 – 8 of 8) sorted by relevance
42 class SafeBlockQueue {44 explicit SafeBlockQueue(int capacity) : maxSize_(capacity) in SafeBlockQueue() function159 virtual ~SafeBlockQueue() {} in ~SafeBlockQueue()175 class SafeBlockQueueTracking : public SafeBlockQueue<T> {177 explicit SafeBlockQueueTracking(int capacity) : SafeBlockQueue<T>(capacity) in SafeBlockQueueTracking()275 using SafeBlockQueue<T>::maxSize_;276 using SafeBlockQueue<T>::mutexLock_;277 using SafeBlockQueue<T>::cvNotEmpty_;278 using SafeBlockQueue<T>::cvNotFull_;279 using SafeBlockQueue<T>::queueT_;
7 线程安全阻塞队列SafeBlockQueue类，提供阻塞和非阻塞版的入队入队和出队接口，并提供可最追踪任务完成状态的的SafeBlockQueueTracking类。14 ### OHOS::SafeBlockQueue18 | | **SafeBlockQueue**(int capacity)<br/>构造函数 |19 | | virtual **~SafeBlockQueue**()<br/>析构函数 |30 #### class SafeBlockQueueTracking : public SafeBlockQueue47 - SafeBlockQueue的示例代码87 SafeBlockQueue<int> que;
67 static SafeBlockQueue<int> shareQueue;83 SafeBlockQueue<int> DemoThreadData::shareQueue(QUEUE_SLOTS);164 SafeBlockQueue<int> qi(QUEUE_CAPACITY); in BENCHMARK_F()185 SafeBlockQueue<int> qi(QUEUE_CAPACITY); in BENCHMARK_F()630 SafeBlockQueue<int> qi(QUEUE_CAPACITY); in BENCHMARK_F()647 SafeBlockQueue<int> qi(QUEUE_CAPACITY); in BENCHMARK_F()
49 static SafeBlockQueue<int> shareQueue;64 SafeBlockQueue<int> DemoThreadData::shareQueue(QUEUE_SLOTS);125 SafeBlockQueue<int> qi(10);137 SafeBlockQueue<int> qi(10);
87 std::shared_ptr<SafeBlockQueue<uint64_t>> queue_;
65 using TaskQueue = std::shared_ptr<SafeBlockQueue<Backup>>;
244 …auto backup = [executors = executors_, queue = std::make_shared<SafeBlockQueue<Backup>>(MAX_TASK_C… in GetMetaKvStore()
133 queue_ = std::make_shared<SafeBlockQueue<uint64_t>>(1); in PreferencesImpl()487 std::weak_ptr<SafeBlockQueue<uint64_t>> queue = queue_; in Flush()