Home
last modified time | relevance | path

Searched refs:THREAD_NUM (Results 1 – 25 of 26) sorted by relevance

12

/ohos5.0/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_safe_block_queue_test.cpp159 ASSERT_EQ(pushedIn, THREAD_NUM); in CheckFullQueueStatus()
169 std::thread threads[THREAD_NUM];
223 std::thread threads[THREAD_NUM];
289 std::thread threads[THREAD_NUM];
337 std::thread threads[THREAD_NUM];
386 std::thread threads[THREAD_NUM];
425 ASSERT_EQ(getedOut, THREAD_NUM);
442 std::thread threads[THREAD_NUM];
475 ASSERT_EQ(getedOut, THREAD_NUM);
492 std::thread threads[THREAD_NUM];
[all …]
H A Dutils_safe_block_queue_tracking.cpp159 std::thread threads[THREAD_NUM];
209 ASSERT_EQ(pushedIn, THREAD_NUM); in CheckFullQueueStatus()
230 std::thread threads[THREAD_NUM];
310 std::thread threads[THREAD_NUM];
369 std::thread threads[THREAD_NUM];
437 std::thread threads[THREAD_NUM];
488 ASSERT_EQ(getedOut, THREAD_NUM);
512 std::thread threads[THREAD_NUM];
554 ASSERT_EQ(getedOut, THREAD_NUM);
576 std::thread threads[THREAD_NUM];
[all …]
H A Dutils_safe_queue_test.cpp33 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; variable
92 for (unsigned int i = 0; i < THREAD_NUM; i++) in AllThreadPut()
101 for (unsigned int i = 0; i < THREAD_NUM; i++) in AllThreadGet()
148 std::thread threads[THREAD_NUM];
180 ASSERT_EQ(pushedIn, THREAD_NUM);
183 for (unsigned int i = 0; i < THREAD_NUM; i++)
231 ASSERT_EQ(pushedIn, THREAD_NUM);
232 ASSERT_EQ(getedOut, THREAD_NUM);
257 for (unsigned int i = 0; i < THREAD_NUM; i++)
282 ASSERT_EQ(pushedIn, THREAD_NUM);
[all …]
H A Dutils_safe_map_test.cpp229 const int THREAD_NUM = 100; variable
237 std::thread threads[THREAD_NUM];
254 for (int i = 0; i < THREAD_NUM; ++i) {
276 std::thread threads[THREAD_NUM];
277 std::thread checkThread[THREAD_NUM];
298 for (int i = 0; i < THREAD_NUM; ++i) {
322 std::thread threads[THREAD_NUM];
383 for (int i = 0; i < THREAD_NUM; ++i) { in ResultCompare()
389 for (int i = 0; i < THREAD_NUM; ++i) { in ResultCompare()
397 for (int i = 0; i < THREAD_NUM; ++i) { in ResultCompare()
[all …]
/ohos5.0/commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_benchmark_test/
H A Dsafe_block_queue_benchmark_test.cpp197 void QueueFullHandler(std::thread (&threads)[THREAD_NUM], std::array<DemoThreadData, THREAD_NUM>& d… in QueueFullHandler() argument
240 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
261 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
286 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
339 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
390 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
439 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
486 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
531 std::thread threadsout[THREAD_NUM]; in BENCHMARK_F()
535 std::thread threadsin[THREAD_NUM]; in BENCHMARK_F()
[all …]
/ohos5.0/foundation/multimedia/audio_framework/frameworks/native/audioutils/test/unittest/
H A Daudio_utils_unit_test.cpp326 ASSERT_EQ(pushedIn, THREAD_NUM); in CheckFullQueueStatus()
336 std::thread threads[THREAD_NUM];
390 std::thread threads[THREAD_NUM];
456 std::thread threads[THREAD_NUM];
504 std::thread threads[THREAD_NUM];
553 std::thread threads[THREAD_NUM];
592 ASSERT_EQ(getedOut, THREAD_NUM);
609 std::thread threads[THREAD_NUM];
642 ASSERT_EQ(getedOut, THREAD_NUM);
659 std::thread threads[THREAD_NUM];
[all …]
/ohos5.0/commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_tracking_benchmark_test/
H A Dsafe_block_queue_tracking_benchmark_test.cpp55 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; variable
154 for (unsigned int i = 0; i < THREAD_NUM; i++) { in StartThreads()
236 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
287 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
339 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
390 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
454 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
505 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
556 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
607 std::thread threadsout[THREAD_NUM]; in BENCHMARK_F()
[all …]
/ohos5.0/commonlibrary/c_utils/base/test/benchmarktest/safe_queue_benchmark_test/
H A Dsafe_queue_benchmark_test.cpp31 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; variable
145 for (unsigned int i = 0; i < THREAD_NUM; i++) { in AllThreadPut()
153 for (unsigned int i = 0; i < THREAD_NUM; i++) { in AllThreadGet()
162 for (unsigned int i = 0; i < THREAD_NUM; i++) { in AllThreadErase()
171 for (unsigned int i = 0; i < THREAD_NUM; i++) { in AllThreadEmpty()
244 std::thread threads[THREAD_NUM];
245 std::array<DemoThreadData, THREAD_NUM> demoDatas;
278 for (unsigned int i = 0; i < THREAD_NUM; i++) { in BENCHMARK_F()
359 for (unsigned int i = 0; i < THREAD_NUM; i++) { in BENCHMARK_F()
363 AssertTrue((DemoThreadData::shareQueue.Size() == THREAD_NUM), in BENCHMARK_F()
[all …]
/ohos5.0/commonlibrary/c_utils/docs/zh-cn/
H A Dc-utils-guide-safeMap.md44 constexpr int THREAD_NUM = 5;
45 thread threads[THREAD_NUM * 2];
71 for (int i = 0; i < THREAD_NUM; i++) {
76 for (int i = 0; i < THREAD_NUM; i++) {
78 threads[i + THREAD_NUM] = thread(&FindHandler, i, ref(out));
83 for (int i = 0; i < 2 * THREAD_NUM; i++) {
88 if (sm.Size() == THREAD_NUM) {
H A Dc-utils-guide-semaphore.md56 constexpr int THREAD_NUM = 2 * COUNT_MAX;
124 thread threads[THREAD_NUM];
125 for (int i = 0; i < THREAD_NUM; i++) {
129 for (int i = 0; i < THREAD_NUM; i++) {
/ohos5.0/docs/zh-cn/device-dev/kernel/
H A Dkernel-small-apx-library.md23 在本示例中，主线程创建了THREAD_NUM个子线程，每个子线程启动后等待被主线程唤醒，主线程成功唤醒所有子线程后，子线程继续执行直至生命周期结束，同时主线程通过pthread_join方法等待所有…
36 #define THREAD_NUM 3
92 pthread_t thread[THREAD_NUM];
108 /* 批量创建THREAD_NUM个子线程 */
109 for (i = 0; i < THREAD_NUM; i++) {
119 while (g_startNum < THREAD_NUM) {
137 for (int j = 0; j < THREAD_NUM; j++) {
149 if (g_wakenNum != THREAD_NUM) {
156 for (i = 0; i < THREAD_NUM; i++) {
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_file.rs20 pub const THREAD_NUM: usize = 16; const
109 .max_blocking_pool_size(THREAD_NUM as u8)
137 .max_blocking_pool_size(THREAD_NUM as u8)
159 .max_blocking_threads(THREAD_NUM) in tokio_runtime()
174 use crate::{tokio_runtime, TASK_NUM, THREAD_NUM};
210 use crate::{tokio_runtime, TASK_NUM, THREAD_NUM};
/ohos5.0/commonlibrary/c_utils/base/test/benchmarktest/safe_map_benchmark_test/
H A Dsafe_map_benchmark_test.cpp411 const int THREAD_NUM = 10; variable
421 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
435 for (int i = 0; i < THREAD_NUM; ++i) { in BENCHMARK_F()
466 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
467 std::thread checkThread[THREAD_NUM]; in BENCHMARK_F()
486 for (int i = 0; i < THREAD_NUM; ++i) { in BENCHMARK_F()
518 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
538 for (int i = 0; i < THREAD_NUM; ++i) { in BENCHMARK_F()
551 for (int i = 0; i < THREAD_NUM; ++i) { in BENCHMARK_F()
567 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_rtg.cpp157 constexpr int THREAD_NUM = 8; variable
184 for (int i = 0; i < THREAD_NUM; ++i) {
190 if (tids.size() >= THREAD_NUM) {
225 constexpr int THREAD_NUM = 8; variable
252 for (int i = 0; i < THREAD_NUM; ++i) {
258 if (tids.size() >= THREAD_NUM) {
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dsingleton_runtime.rs19 const THREAD_NUM: usize = 10; const
46 for _ in 0..THREAD_NUM { in sdv_concurrently_runtime_spawn_async_in_async_task()
74 for _ in 0..THREAD_NUM { in sdv_concurrently_spawn_async_in_async_task()
102 for _ in 0..THREAD_NUM { in sdv_concurrently_task_builder_spawn_async_in_async_task()
/ohos5.0/base/startup/init/test/unittest/param/
H A Datomic_unittest.cpp25 const int THREAD_NUM = 5; variable
108 pthread_t readThread[THREAD_NUM] = { 0 };
110 for (size_t i = 0; i < THREAD_NUM; i++) {
/ohos5.0/docs/en/device-dev/kernel/
H A Dkernel-small-apx-library.md23 In this example, the main thread creates THREAD_NUM child threads. Once a child thread is started, …
36 #define THREAD_NUM 3
92 pthread_t thread[THREAD_NUM];
109 for (i = 0; i < THREAD_NUM; i++) {
119 while (g_startNum < THREAD_NUM) {
137 for (int j = 0; j < THREAD_NUM; j++) {
149 if (g_wakenNum != THREAD_NUM) {
156 for (i = 0; i < THREAD_NUM; i++) {
/ohos5.0/base/startup/init/test/moduletest/
H A Dsyspara_moduleTest.cpp32 const int THREAD_NUM = 5; variable
147 for (int i = 0; i < THREAD_NUM; ++i) {
156 for (int i = 0; i < THREAD_NUM; ++i) {
315 for (int i = 0; i < THREAD_NUM; ++i) {
318 for (int j = 0; j < THREAD_NUM; ++j) {
354 for (int i = 0; i < THREAD_NUM; ++i) {
/ohos5.0/foundation/multimedia/media_library/frameworks/services/media_async_worker/src/
H A Dmedialibrary_async_worker.cpp30 static const int32_t THREAD_NUM = 3; variable
65 for (auto i = 0; i < THREAD_NUM; i++) { in Init()
/ohos5.0/base/security/access_token/interfaces/innerkits/accesstoken/test/unittest/src/
H A Daccesstoken_kit_test.h43 static const int THREAD_NUM = 3; variable
/ohos5.0/foundation/multimedia/media_library/interfaces/kits/js/include/
H A Dthumbnail_manager.h169 constexpr int THREAD_NUM = 5; variable
/ohos5.0/foundation/multimedia/media_library/frameworks/js/src/
H A Dthumbnail_manager.cpp191 for (auto i = 0; i < THREAD_NUM; i++) { in Init()
/ohos5.0/docs/zh-cn/device-dev/device-test/
H A Ddeveloper_test.md404 // HWMTEST_F(TEST_SUITE, TEST_TC, TEST_LEVEL, THREAD_NUM)
405 // THREAD_NUM可设置用例执行的线程数量。
/ohos5.0/base/hiviewdfx/hiview/
H A Dhisysevent.yaml165 THREAD_NUM: {type: INT64, desc: thread num}
/ohos5.0/docs/en/device-dev/device-test/
H A Ddeveloper_test.md409 // HWMTEST_F(TEST_SUITE, TEST_TC, TEST_LEVEL, THREAD_NUM)
410 // THREAD_NUM can be used to set the number of threads for executing a test case.

12