| /commonlibrary/c_utils/base/test/unittest/common/ |
| D | utils_safe_block_queue_tracking.cpp | 87 for (auto& t : demoDatas) { in GetThreadDatePushedStatus() local 101 for (auto& t : demoDatas) { in GetThreadDateGetedStatus() local 148 int t = qi.Pop(); variable 192 for (auto& t : threads) { variable 272 for (auto& t : threads) { variable 289 int t = i; in QueuePushInfull() local 297 int t = i; in QueuePushInnotfull() local 350 for (auto& t : threads) { variable 408 for (auto& t : threads) { variable 445 int t = 1; variable [all …]
|
| D | utils_safe_queue_test.cpp | 76 int t = 0; in GetHandleThreadDataTime() local 112 for (auto &t : demoDatas) in GetThreadDatePushedStatus() local 127 for (auto &t : demoDatas) in GetThreadDateGetedStatus() local 140 for (auto &t : threads) in ResetStatus() local 185 int t = 0; variable 256 int t = 1; variable 302 int t = 1; variable
|
| D | utils_safe_block_queue_test.cpp | 76 for (auto& t : demoDatas) { in GetThreadDatePushedStatus() local 91 for (auto& t : demoDatas) { in GetThreadDateGetedStatus() local 142 int t = qi.Pop(); variable 148 for (auto& t : threads) { in ThreadsJoin() local 268 int t = i; in QueuePushInfull() local 276 int t = i; in QueuePushInnotfull() local 394 int t = 1; variable 469 int t = i; variable 609 int t = 1; variable
|
| D | utils_safe_map_test.cpp | 377 for (auto& t : vcfi) { in ResultCompare() local 387 int t = 0; in ResultCompare() local
|
| D | utils_sorted_vector_test.cpp | 346 for (int t = 0; t < arraySize; ++t) { variable
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_benchmark_test/ |
| D | safe_block_queue_benchmark_test.cpp | 95 for (auto& t : demoDatas) { in GetThreadDateGetedStatus() local 109 for (auto& t : demoDatas) { in GetThreadDatePushedStatus() local 151 int t = i; in QueuePushInnotfullNotEquivalent() local 191 int t = qi.Pop(); in BENCHMARK_F() local 225 for (auto& t : threads) { in QueueFullHandler() local 294 int t = i; in BENCHMARK_F() local 321 for (auto& t : threads) { in BENCHMARK_F() local 371 for (auto& t : threads) { in BENCHMARK_F() local 397 int t = 1; in BENCHMARK_F() local 460 int t = i; in BENCHMARK_F() local [all …]
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_queue_benchmark_test/ |
| D | safe_queue_benchmark_test.cpp | 115 int t = 0; in GetHandleThreadDataTime() local 181 for (auto &t : demoDatas) { in GetThreadDatePushedStatus() local 196 for (auto &t : demoDatas) { in GetThreadDateGetedStatus() local 210 for (auto &t : demoDatas) { in GetThreadDateEraseStatus() local 224 for (auto &t : demoDatas) { in GetThreadDateEmptyStatus() local 237 for (auto &t : threads) { in ResetStatus() local 279 int t = 0; in BENCHMARK_F() local 358 int t = 1; in BENCHMARK_F() local
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_tracking_benchmark_test/ |
| D | safe_block_queue_tracking_benchmark_test.cpp | 112 for (auto& t : demoDatas) { in GetThreadDateGetedStatus() local 126 for (auto& t : demoDatas) { in GetThreadDatePushedStatus() local 162 for (auto& t : threads) { in JoinAllThreads() local 220 int t = qi.Pop(); in BENCHMARK_F() local 347 int t = i; in BENCHMARK_F() local 441 int t = i; in QueuePushFullNotEquivalent() local 460 int t = 1; in BENCHMARK_F() local 528 int t = i; in BENCHMARK_F() local 614 int t = 1; in BENCHMARK_F() local
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_map_benchmark_test/ |
| D | safe_map_benchmark_test.cpp | 439 for (auto& t : threads) { in BENCHMARK_F() local 491 for (auto& t : threads) { in BENCHMARK_F() local 495 for (auto& t : checkThread) { in BENCHMARK_F() local 543 for (auto& t : threads) { in BENCHMARK_F() local 547 for (auto& t : vcfi) { in BENCHMARK_F() local 593 for (auto& t : threads) in BENCHMARK_F() local 596 for (auto& t : vcfi) in BENCHMARK_F() local 604 int t = -1; in BENCHMARK_F() local
|
| /commonlibrary/c_utils/base/test/benchmarktest/ |
| D | benchmark_assert.h | 38 void AssertFalse(const T &t, const char* printInfo, benchmark::State& state) in AssertFalse() 46 void AssertTrue(const T &t, const char* printInfo, benchmark::State& state) in AssertTrue()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| D | test_worker.cpp | 354 std::thread t([&env, &worker] { in RemoveGlobalCallObject() local 760 std::thread t([&env, &worker] { in TestWorkerOnMessageInner() local 814 std::thread t([&env, &worker] { in HandleHostException() local 893 std::thread t([&env, &worker] { in RemoveListenerInner() local 1023 std::thread t([&env, &worker] { in DebuggerOnPostTask() local 1670 std::thread t([&env, &worker] { in __anonb03d6e582402() variable 1706 std::thread t([&env, &worker] { in __anonb03d6e582502() variable 1750 std::thread t([&env, &worker] { in __anonb03d6e582602() variable 1792 std::thread t([&env, &worker] { in __anonb03d6e582802() variable 1876 std::thread t([&env, &worker] { in __anonb03d6e582902() variable [all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ffrt/ |
| D | spawner.rs | 52 let t: Box<Task> = Box::new(t); in ffrt_submit() localVariable
|
| /commonlibrary/c_utils/base/src/ |
| D | thread_pool.cpp | 47 std::thread t([this] { this->WorkInThread(); }); in Start() local
|
| D | thread_ex.cpp | 66 auto t = new ThreadParam; // t would be delete in ThreadParam::Proxy in CreatePThread() local
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/test/ |
| D | test_locks.cpp | 225 std::thread t([lockPtr, &callbackData] () { in TEST_F() local 317 std::thread t([lockPtr, &callbackData, &barrier] () { in TEST_F() local 369 std::thread t([lockPtr, &data] () { in TEST_F() local 446 std::thread t([&callbackData]() { in TEST_F() local 520 std::thread t([&callbackData]() { in TEST_F() local 590 std::thread t([&callbackData]() { in TEST_F() local
|
| D | test_condition.cpp | 324 std::thread t([&thisVar]() { in TEST_F() local 368 std::thread t([&thisVar]() { in TEST_F() local
|
| /commonlibrary/c_utils/base/test/fuzztest/thread_fuzzer/ |
| D | thread_fuzzer.cpp | 87 auto t = std::make_unique<TestThread>(0, readyToWork, priority, TestRun); in ThreadTestFunc() local
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| D | mod.rs | 280 t: Option<bool>, field
|
| /commonlibrary/rust/ylong_json/src/ |
| D | deserializer.rs | 110 let t = T::deserialize(&mut deserializer)?; in from_reader() localVariable 143 let t = T::deserialize(&mut deserializer)?; in from_slice() localVariable 1141 let t = r#"{"Tuple":[1,2]}"#.as_bytes(); in ut_deserialize_enum() localVariable
|
| D | serializer_compact.rs | 658 let t = E::Tuple(100, 200); in ut_serialize_enum() localVariable
|
| /commonlibrary/c_utils/base/test/benchmarktest/sorted_vector_benchmark_test/ |
| D | sorted_vector_benchmark_test.cpp | 407 for (int t = 0; t < arraySize; ++t) { in BENCHMARK_F() local
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task.cpp | 1452 for (auto t: delayedTimers_) { in ClearDelayedTimers() local
|