Searched refs:shareQueue (Results 1 – 7 of 7) sorted by relevance
49 static SafeBlockQueue<int> shareQueue; member in OHOS::__anona475a01d0110::DemoThreadData53 shareQueue.Push(j); in Put()59 shareQueue.Pop(); in Get()269 DemoThreadData::shareQueue.Push(t); in QueuePushInfull()277 DemoThreadData::shareQueue.Push(t); in QueuePushInnotfull()315 DemoThreadData::shareQueue.Pop();365 DemoThreadData::shareQueue.Push(value);396 DemoThreadData::shareQueue.Push(t);470 DemoThreadData::shareQueue.Push(t);519 DemoThreadData::shareQueue.Pop();[all …]
45 static SafeBlockQueueTracking<int> shareQueue; member in OHOS::__anonfd60cb500110::DemoThreadData50 shareQueue.Pop(); in Get()56 shareQueue.Push(j); in Put()62 shareQueue.Join(); in Join()68 shareQueue.Pop(); in GetAndOneTaskDone()70 shareQueue.OneTaskDone(); in GetAndOneTaskDone()290 DemoThreadData::shareQueue.Push(t); in QueuePushInfull()298 DemoThreadData::shareQueue.Push(t); in QueuePushInnotfull()340 DemoThreadData::shareQueue.Pop();546 DemoThreadData::shareQueue.Push(t);[all …]
43 static SafeQueue<int> shareQueue; member in OHOS::__anon25c7b2b30110::DemoThreadData49 shareQueue.Push(i); in Put()55 shareQueue.Pop(i); in Get()60 SafeQueue<int> DemoThreadData::shareQueue; member in OHOS::__anon25c7b2b30110::DemoThreadData145 DemoThreadData::shareQueue.Clear(); in ResetStatus()173 ASSERT_TRUE(DemoThreadData::shareQueue.Size() > 0);191 ASSERT_TRUE(DemoThreadData::shareQueue.Size() == 0);255 ASSERT_TRUE(DemoThreadData::shareQueue.Size() == 0);259 DemoThreadData::shareQueue.Push(t);262 ASSERT_TRUE(DemoThreadData::shareQueue.Size() == THREAD_NUM);[all …]
218 static AudioSafeBlockQueue<int> shareQueue; member in OHOS::AudioStandard::DemoThreadData222 shareQueue.Push(j); in Put()228 shareQueue.Pop(); in Get()436 DemoThreadData::shareQueue.Push(t); in QueuePushInfull()444 DemoThreadData::shareQueue.Push(t); in QueuePushInnotfull()482 DemoThreadData::shareQueue.Pop();532 DemoThreadData::shareQueue.Push(value);563 DemoThreadData::shareQueue.Push(t);637 DemoThreadData::shareQueue.Push(t);686 DemoThreadData::shareQueue.Pop();[all …]
67 static SafeBlockQueue<int> shareQueue; member in OHOS::__anondc08bdaf0110::DemoThreadData72 shareQueue.Pop(); in Get()78 shareQueue.Push(i); in Put()143 DemoThreadData::shareQueue.Push(equivalent); in QueuePushFullEquivalent()152 DemoThreadData::shareQueue.Push(t); in QueuePushInnotfullNotEquivalent()228 while (!DemoThreadData::shareQueue.IsEmpty()) { in QueueFullHandler()295 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()313 DemoThreadData::shareQueue.Pop(); in BENCHMARK_F()362 DemoThreadData::shareQueue.Push(value); in BENCHMARK_F()461 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()[all …]
68 static SafeBlockQueueTracking<int> shareQueue; member in OHOS::__anonefe9c4f30110::DemoThreadData75 shareQueue.Push(i); in Put()81 shareQueue.Pop(); in Get()87 shareQueue.Pop(); in GetAndOneTaskDone()89 shareQueue.OneTaskDone(); in GetAndOneTaskDone()94 shareQueue.Join(); in Join()348 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()365 DemoThreadData::shareQueue.Pop(); in BENCHMARK_F()442 DemoThreadData::shareQueue.Push(t); in QueuePushFullNotEquivalent()529 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()[all …]
70 static SafeQueue<int> shareQueue; member in OHOS::__anon08a86d1b0110::DemoThreadData78 shareQueue.Push(i); in Put()84 shareQueue.Pop(i); in Get()90 shareQueue.Erase(i); in Erase()96 shareQueue.Empty(); in Empty()101 SafeQueue<int> DemoThreadData::shareQueue; member in OHOS::__anon08a86d1b0110::DemoThreadData241 DemoThreadData::shareQueue.Clear(); in ResetStatus()268 AssertTrue((DemoThreadData::shareQueue.Size() > 0), in BENCHMARK_F()285 AssertTrue((DemoThreadData::shareQueue.Size() == 0), in BENCHMARK_F()355 AssertTrue((DemoThreadData::shareQueue.Size() == 0), in BENCHMARK_F()[all …]