Home
last modified time | relevance | path

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

/commonlibrary/c_utils/base/test/unittest/common/
Dutils_safe_block_queue_test.cpp38 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; variable
71 void GetThreadDatePushedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, in GetThreadDatePushedStatus()
86 void GetThreadDateGetedStatus(std::array<DemoThreadData, THREAD_NUM>& demoDatas, in GetThreadDateGetedStatus()
152 std::thread threads[THREAD_NUM];
154 std::array<DemoThreadData, THREAD_NUM> demoDatas;
157 for (unsigned int i = 0; i < THREAD_NUM; i++) {
172 ASSERT_EQ(unpushedIn, THREAD_NUM - QUEUE_SLOTS);
175 for (unsigned int i = 0; i < THREAD_NUM - QUEUE_SLOTS; i++) {
184 ASSERT_EQ(pushedIn, THREAD_NUM);
185 ASSERT_EQ(getedOut, THREAD_NUM - QUEUE_SLOTS);
[all …]
Dutils_safe_block_queue_tracking.cpp32 const unsigned int THREAD_NUM = QUEUE_SLOTS + 1; variable
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];
161 std::array<DemoThreadData, THREAD_NUM> demoDatas;
171 for (unsigned int i = 0; i < THREAD_NUM; i++) {
181 for (unsigned int i = 0; i < THREAD_NUM; i++) {
211 std::thread threads[THREAD_NUM];
212 std::array<DemoThreadData, THREAD_NUM> demoDatas;
222 for (unsigned int i = 0; i < THREAD_NUM; i++) {
[all …]
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];
149 std::array<DemoThreadData, THREAD_NUM> demoDatas;
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++)
[all …]
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];
348 for (int i = 0; i < THREAD_NUM; ++i) {
368 for (int i = 0; i < THREAD_NUM; ++i) {
382 std::thread threads[THREAD_NUM];
[all …]
/commonlibrary/c_utils/docs/zh-cn/
Dc-utils-guide-safeMap.md43 constexpr int THREAD_NUM = 5;
44 thread threads[THREAD_NUM * 2];
70 for (int i = 0; i < THREAD_NUM; i++) {
75 for (int i = 0; i < THREAD_NUM; i++) {
77 threads[i + THREAD_NUM] = thread(&FindHandler, i, ref(out));
82 for (int i = 0; i < 2 * THREAD_NUM; i++) {
87 if (sm.Size() == THREAD_NUM) {
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++) {
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dsingleton_runtime.rs19 const THREAD_NUM: usize = 10; constant
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()