| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_safe_block_queue_test.cpp | 38 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; member
71 void GetThreadDatePushedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, unsigned int& pushedIn, in GetThreadDatePushedStatus()
86 void GetThreadDateGetedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, in GetThreadDateGetedStatus()
146 static void ThreadsJoin(std::thread (&threads)[THREAD_NUM])
153 static void CheckFullQueueStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, unsigned int& pushedIn, in CheckFullQueueStatus()
159 ASSERT_EQ(pushedIn, THREAD_NUM); in CheckFullQueueStatus()
160 ASSERT_EQ(getedOut, THREAD_NUM - QUEUE_SLOTS); in CheckFullQueueStatus()
169 std::thread threads[THREAD_NUM]; in HWTEST_F()
171 std::array<DemoThreadData, THREAD_NUM> demoDatas; in HWTEST_F()
174 for (unsigned int i = 0; i < THREAD_NUM; in HWTEST_F()
[all...] |
| H A D | utils_safe_block_queue_tracking.cpp | 32 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; member
82 void GetThreadDatePushedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, in GetThreadDatePushedStatus()
96 void GetThreadDateGetedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, in GetThreadDateGetedStatus()
159 std::thread threads[THREAD_NUM]; in HWTEST_F()
161 std::array<DemoThreadData, THREAD_NUM> demoDatas; in HWTEST_F()
171 for (unsigned int i = 0; i < THREAD_NUM; i++) { in HWTEST_F()
181 for (unsigned int i = 0; i < THREAD_NUM; i++) { in HWTEST_F()
203 static void CheckFullQueueStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, unsigned int& pushedIn, in CheckFullQueueStatus()
209 ASSERT_EQ(pushedIn, THREAD_NUM); in CheckFullQueueStatus()
210 ASSERT_EQ(getedOut, THREAD_NUM in CheckFullQueueStatus()
[all...] |
| H A D | utils_safe_queue_test.cpp | 33 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; member
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];
149 std::array<DemoThreadData, THREAD_NUM> demoDatas;
180 ASSERT_EQ(pushedIn, THREAD_NUM); in HWTEST_F()
183 for (unsigned int i = 0; i < THREAD_NUM; i++) in HWTEST_F()
231 ASSERT_EQ(pushedIn, THREAD_NUM); in HWTEST_F()
232 ASSERT_EQ(getedOut, THREAD_NUM); in HWTEST_F()
257 for (unsigned int i = 0; i < THREAD_NUM; in HWTEST_F()
[all...] |
| H A D | utils_safe_map_test.cpp | 229 const int THREAD_NUM = 100; member
237 std::thread threads[THREAD_NUM]; in HWTEST_F()
254 for (int i = 0; i < THREAD_NUM; ++i) { in HWTEST_F()
276 std::thread threads[THREAD_NUM]; in HWTEST_F()
277 std::thread checkThread[THREAD_NUM]; in HWTEST_F()
298 for (int i = 0; i < THREAD_NUM; ++i) { in HWTEST_F()
322 std::thread threads[THREAD_NUM]; in HWTEST_F()
348 for (int i = 0; i < THREAD_NUM; ++i) { in HWTEST_F()
368 for (int i = 0; i < THREAD_NUM; ++i) { in HWTEST_F()
383 for (int i = 0; i < THREAD_NUM; in ResultCompare()
[all...] |
| /commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_benchmark_test/ |
| H A D | safe_block_queue_benchmark_test.cpp | 56 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; member
90 void GetThreadDateGetedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, unsigned int& getedOut, in GetThreadDateGetedStatus()
104 void GetThreadDatePushedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, unsigned int& pushedIn, in GetThreadDatePushedStatus()
197 void QueueFullHandler(std::thread (&threads)[THREAD_NUM], std::array<DemoThreadData, THREAD_NUM>& demoDatas,
210 AssertEqual(unpushedIn, THREAD_NUM - QUEUE_SLOTS,
211 "unpushedIn did not equal THREAD_NUM - QUEUE_SLOTS as expected.", state);
213 for (unsigned int i = 0; i < THREAD_NUM - QUEUE_SLOTS; i++) {
222 AssertEqual(pushedIn, THREAD_NUM, "pushedIn did not equal THREAD_NUM a
[all...] |
| /commonlibrary/c_utils/base/test/benchmarktest/safe_queue_benchmark_test/ |
| H A D | safe_queue_benchmark_test.cpp | 31 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; member
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;
275 AssertEqual(pushedIn, THREAD_NUM, "pushedIn did not equal THREAD_NUM as expected.", state); in BENCHMARK_F()
278 for (unsigned int i = 0; i < THREAD_NUM; in BENCHMARK_F()
[all...] |
| /commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_tracking_benchmark_test/ |
| H A D | safe_block_queue_tracking_benchmark_test.cpp | 55 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; member
107 void GetThreadDateGetedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, unsigned int& getedOut, in GetThreadDateGetedStatus()
121 void GetThreadDatePushedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, unsigned int& pushedIn, in GetThreadDatePushedStatus()
149 void StartThreads(std::thread (&threads)[THREAD_NUM],
151 std::array<DemoThreadData, THREAD_NUM>& demoDatas,
154 for (unsigned int i = 0; i < THREAD_NUM; i++) {
236 std::thread threads[THREAD_NUM]; in BENCHMARK_F()
237 std::array<DemoThreadData, THREAD_NUM> demoDatas; in BENCHMARK_F()
248 for (unsigned int i = 0; i < THREAD_NUM; i++) { in BENCHMARK_F()
259 for (unsigned int i = 0; i < THREAD_NUM; in BENCHMARK_F()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_file.rs | 20 pub const THREAD_NUM: usize = 16; consts
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};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | singleton_runtime.rs | 19 const THREAD_NUM: usize = 10; consts
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()
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_map_benchmark_test/ |
| H A D | safe_map_benchmark_test.cpp | 411 const int THREAD_NUM = 10; member
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...] |