Home
last modified time | relevance | path

Searched refs:threads (Results 1 – 25 of 277) sorted by relevance

12345678910>>...12

/ohos5.0/base/hiviewdfx/faultloggerd/tools/crasher_cpp/faults/
H A Dmulti_thread_container_access.cpp37 std::vector<std::thread> threads; in MultiThreadVectorAccess() local
46 threads.push_back(std::move(th)); in MultiThreadVectorAccess()
49 for (auto& th : threads) { in MultiThreadVectorAccess()
59 std::vector<std::thread> threads; in MultiThreadMapAccess() local
68 threads.push_back(std::move(th)); in MultiThreadMapAccess()
71 for (auto& th : threads) { in MultiThreadMapAccess()
81 std::vector<std::thread> threads; in MultiThreadListAccess() local
91 threads.push_back(std::move(th)); in MultiThreadListAccess()
94 for (auto& th : threads) { in MultiThreadListAccess()
/ohos5.0/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_safe_block_queue_test.cpp148 for (auto& t : threads) { in ThreadsJoin()
169 std::thread threads[THREAD_NUM]; variable
196 ThreadsJoin(threads);
223 std::thread threads[THREAD_NUM]; variable
257 ThreadsJoin(threads);
289 std::thread threads[THREAD_NUM]; variable
323 ThreadsJoin(threads);
373 ThreadsJoin(threads);
428 ThreadsJoin(threads);
478 ThreadsJoin(threads);
[all …]
H A Dutils_safe_block_queue_tracking.cpp159 std::thread threads[THREAD_NUM]; variable
192 for (auto& t : threads) {
230 std::thread threads[THREAD_NUM]; variable
272 for (auto& t : threads) {
310 std::thread threads[THREAD_NUM]; variable
350 for (auto& t : threads) {
369 std::thread threads[THREAD_NUM]; variable
408 for (auto& t : threads) {
491 for (auto& thd : threads) {
557 for (auto& t : threads) {
[all …]
H A Dutils_safe_map_test.cpp237 std::thread threads[THREAD_NUM]; variable
255 … threads[i] = std::thread(lamfuncIterate, std::ref(demoData), i, system_clock::from_time_t(timeT));
259 for (auto& t : threads) {
276 std::thread threads[THREAD_NUM]; variable
304 for (auto& t : threads) {
322 std::thread threads[THREAD_NUM]; variable
349 threads[i] = std::thread(lamfuncInsert, std::ref(demoData),
356 for (auto& t : threads) {
410 std::thread threads[THREAD_NUM]; variable
437 threads[i] = std::thread(lamfuncInsert, std::ref(demoData),
[all …]
/ohos5.0/base/security/huks/test/reliability/src/
H A Dapi_pressure_test.cpp930 for (auto &t : threads) {
951 for (auto &t : threads) {
972 for (auto &t : threads) {
993 for (auto &t : threads) {
1026 for (auto &t : threads) {
1056 for (auto &t : threads) {
1077 for (auto &t : threads) {
1107 for (auto &t : threads) {
1137 for (auto &t : threads) {
1158 for (auto &t : threads) {
[all …]
H A Dthree_stage_multi_thread.cpp236 std::vector<std::thread> threads; in ThreeStageTest() local
242 threads.emplace_back(std::thread(AbortSessionTest, &handleBlob)); in ThreeStageTest()
244 threads.emplace_back(std::thread(UpdateSessionTest, &handleBlob)); in ThreeStageTest()
248 for (auto &t : threads) { in ThreeStageTest()
275 std::vector<std::thread> threads; variable
278 threads.emplace_back(std::thread(&ThreeStageTest, i));
281 for (auto &t : threads) {
/ohos5.0/commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_benchmark_test/
H A Dsafe_block_queue_benchmark_test.cpp225 for (auto& t : threads) { in QueueFullHandler()
240 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
261 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
286 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
321 for (auto& t : threads) { in BENCHMARK_F()
339 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
371 for (auto& t : threads) { in BENCHMARK_F()
390 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
439 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
468 for (auto& t : threads) { in BENCHMARK_F()
[all …]
/ohos5.0/commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_tracking_benchmark_test/
H A Dsafe_block_queue_tracking_benchmark_test.cpp162 for (auto& t : threads) { in JoinAllThreads()
236 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
270 JoinAllThreads(threads); in BENCHMARK_F()
287 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
321 JoinAllThreads(threads); in BENCHMARK_F()
339 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
374 JoinAllThreads(threads); in BENCHMARK_F()
421 JoinAllThreads(threads); in BENCHMARK_F()
488 JoinAllThreads(threads); in BENCHMARK_F()
539 JoinAllThreads(threads); in BENCHMARK_F()
[all …]
/ohos5.0/foundation/multimedia/audio_framework/frameworks/native/audioutils/test/unittest/
H A Daudio_utils_unit_test.cpp315 for (auto& t : threads) { in ThreadsJoin()
336 std::thread threads[THREAD_NUM]; variable
363 ThreadsJoin(threads);
390 std::thread threads[THREAD_NUM]; variable
424 ThreadsJoin(threads);
456 std::thread threads[THREAD_NUM]; variable
490 ThreadsJoin(threads);
540 ThreadsJoin(threads);
595 ThreadsJoin(threads);
645 ThreadsJoin(threads);
[all …]
/ohos5.0/docs/en/application-dev/reference/apis-arkdata/
H A Djs-apis-data-sendableRelationalStore.md19 …e (KV) pair that cannot be transferred across threads into the data that can be transferred across…
33 | [ValuesBucket](#valuesbucket) | Data that can be transferred across threads. |
82 …rts a KV pair that can be transferred across threads into the data that cannot be transferred acro…
96 | [NonSendableBucket](#nonsendablebucket) | Data that cannot be transferred across threads. |
145 … asset data that cannot be transferred across threads into the data that can be transferred across…
159 | [Asset](#asset) | Asset data that can be transferred across threads. |
186 …he asset data that can be transferred across threads into the data that cannot be transferred acro…
194 | asset | [Asset](#asset) | Yes | Asset data that can be transferred across threads. |
246 Represent an array of [Assets](#asset), which allows assets to be transferred across threads.
278 Represents the KV pair that can be transferred across threads.
[all …]
/ohos5.0/commonlibrary/c_utils/docs/en/
H A Dc_utils_thread_pool.md6 Give a thread-safe thread pool. The thread-safe is for threadpool itself not for the threads in poo…
19 …ol**(const std::string& name = std::string())<br>Construct ThreadPool. Name the threads in pool. |
25 | size_t | **GetThreadsNum**() const<br>Get the current amount of threads in pool. |
27 | uint32_t | **Start**(int threadsNum)<br>Start a given number(threadNum) of threads, which will ex…
28 | void | **Stop**()<br>Stop ThreadPool and waiting all threads in pool to stop. |
41 …threads in pool. The real name of threads in pool will be like: name + No. The thread name is a me…
/ohos5.0/docs/en/device-dev/kernel/
H A Dkernel-small-apx-library.md37 int g_startNum = 0; /* Number of threads to start */
38 int g_wakenNum = 0; /* Number of threads to wake up */
108 /* Create child threads in batches. */
118 /* Wait until all child threads obtain a mutex. */
123 /* Acquire a mutex and block all threads using pthread_cond_wait. */
148 /* Check whether all child threads are woken up. */
153 dprintf("all threads awaked\n");
155 /* Join all child threads, that is, wait for the end of all child threads. */
163 dprintf("all threads join ok\n");
183 all threads awaked
[all …]
/ohos5.0/docs/en/application-dev/application-models/
H A Dthread-model-fa.md4 There are three types of threads in the FA model:
9 Manages other threads.
22 …threads. Service interaction requires inter-thread communication. Threads can communicate with eac…
26 …ent synchronization within the ability thread, between a pair of ability threads, or between the a…
H A Dthread-model-stage.md4 There are three types of threads in the stage model:
8 …instances of other threads, for example, using **TaskPool** to create or cancel tasks, and startin…
11 - Receives messages sent by the **TaskPool** and **Worker** threads.
24 … threads that can be created and their lifecycle. However, you need to maintain the lifecycle of […
30 …lication-eventHub.md) provides APIs for sending and processing events in threads, including subscr…
/ohos5.0/docs/en/application-dev/faqs/
H A Dfaqs-arkts-utils.md24 ## Which is recommended in concurrent scenarios where threads need to be reused?
47 ## Some applications have more than 200 threads. Neither TaskPool nor Worker supports so many threa…
53 To address the problem that a large number of threads are required, you are advised to:
330 …the number of threads? What will happen if the maximum number is reached? Will the task pool be af…
334 A maximum of eight worker threads can be created. No more worker threads can be created when the ma…
362 ## Can context be transferred across threads? (API version 10)
437 Serialized transfer: Deep copy to other threads is supported.
486 …ted to the I/O thread pool and do not block application threads. Therefore, the number of threads …
491 Multiple threads can use SharedArrayBuffer to operate the memory block.
602 To address the problem that a large number of threads are required, you are advised to:
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dcpuworker_manager.cpp68 auto result = groupCtl[workerQos].threads.emplace(worker, std::move(uniqueWorker)); in IncWorker()
91 return groupCtl[qos()].threads.size(); in GetWorkerCount()
168 if (GetStealingWorkers(thread->GetQos()) > groupCtl[thread->GetQos()].threads.size() / 2) { in StealTaskBatch()
174 groupCtl[thread->GetQos()].threads.begin(); in StealTaskBatch()
175 while (iter != groupCtl[thread->GetQos()].threads.end()) { in StealTaskBatch()
233 auto worker = std::move(groupCtl[qos].threads[thread]); in WorkerRetired()
234 int ret = groupCtl[qos].threads.erase(thread); in WorkerRetired()
H A Dscpuworker_manager.cpp66 if (groupCtl[qos].threads.empty()) { in ~SCPUWorkerManager()
89 auto worker = std::move(groupCtl[qos].threads[thread]); in WorkerRetiredSimplified()
90 int ret = groupCtl[qos].threads.erase(thread); in WorkerRetiredSimplified()
94 isEmptyQosThreads = groupCtl[qos].threads.empty(); in WorkerRetiredSimplified()
128 bool isEmpty = groupCtl[qos].threads.empty(); in AddDelayedTask()
H A Dworker_manager.cpp24 for (auto& thread : tgwrap.threads) { in JoinRtg()
50 for (auto& thread : tgwrap.threads) { in JoinTG()
74 for (auto& thread : groupCtl[qos].threads) { in LeaveTG()
/ohos5.0/base/security/huks/test/unittest/huks_standard_test/module_test/utils_test/src/
H A Dhks_condition_test.cpp162 pthread_t threads[TSET_THREADS_COUNT] {}; variable
164 EXPECT_EQ(pthread_create(&threads[i], nullptr, WaitThread, condition), 0);
168 EXPECT_EQ(pthread_join(threads[i], nullptr), 0);
303 pthread_t threads[TEST_THREADS_COUNT] {}; variable
305 EXPECT_EQ(pthread_create(&threads[i], nullptr, functions[i], condition), 0);
309 EXPECT_EQ(pthread_join(threads[i], nullptr), 0);
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_rtg.cpp164 std::vector<std::thread> threads; variable
185 threads.emplace_back(std::thread(f));
213 for (auto& thread : threads) {
232 std::vector<std::thread> threads; variable
253 threads.emplace_back(std::thread(f));
298 for (auto& thread : threads) {
/ohos5.0/base/hiviewdfx/faultloggerd/test/unittest/signal_handler/
H A Dsignal_handler_test.cpp353 std::vector<std::thread> threads; variable
356 threads.push_back(std::thread(TestThread2, i, SIGSEGV, testThreadCount, false));
359 for (auto& thread : threads) {
383 std::vector<std::thread> threads; variable
390 threads.push_back(std::thread (TestThread2, i, SIGSEGV, testThreadCount, exitEarly));
393 for (auto& thread : threads) {
506 std::vector<std::thread> threads; variable
509 threads.push_back(std::thread (TestThread2, i, SIGSEGV, testThreadCount, true));
512 for (auto& thread : threads) {
/ohos5.0/base/global/resource_management_lite/frameworks/resmgr_lite/test/unittest/lite/common/
H A Dstring_utils_test.cpp84 std::vector<std::thread> threads; in TestThread() local
86 threads.push_back(std::thread(FuncMultiThread, num, lock)); in TestThread()
88 for (auto &thread : threads) { in TestThread()
/ohos5.0/commonlibrary/c_utils/base/test/benchmarktest/safe_map_benchmark_test/
H A Dsafe_map_benchmark_test.cpp421 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
436 threads[i] = std::thread(lamfuncIterate, std::ref(demoData), i, timeT); in BENCHMARK_F()
439 for (auto& t : threads) { in BENCHMARK_F()
466 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
487 threads[i] = std::thread(lamfuncInsert, std::ref(demoData), key, i, timeT); in BENCHMARK_F()
491 for (auto& t : threads) { in BENCHMARK_F()
518 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
543 for (auto& t : threads) { in BENCHMARK_F()
567 std::thread threads[THREAD_NUM]; in BENCHMARK_F() local
588 threads[i] = std::thread(lamfuncInsert, std::ref(demoData), in BENCHMARK_F()
[all …]
/ohos5.0/docs/en/application-dev/ffrt/
H A Dffrt-overview.md5 …ort more concurrent tasks and improve the thread usage with fewer system threads. It leverages the…
15 …threads and assign tasks to them for parallel execution to achieve the optimal runtime performance…
16 …threads| Programmers are responsible for creating threads. The maximum number of threads that can …
17 …threads during static programming. Improper mapping or uncertain task execution time will cause a …
19 …table state once it is created, and it is executed parallelly with other threads, causing frequent…
97 For non-worker threads in FFRT processes, the behavior of the **thread_local** variable is not affe…
164 …rts a maximum of eight worker threads. When eight tasks use **std::mutex** at the same time, deadl…
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Dtask_queue_factory.cpp145 auto threads = array_view<ThreadContext>(threads_.get(), threadCount_); in ThreadPool() local
146 for (ThreadContext& context : threads) { in ThreadPool()
314 auto threads = array_view(threads_.get(), threadCount_); in Stop() local
317 for (auto& context : threads) { in Stop()
328 auto threads = array_view(threads_.get(), threadCount_); in Stop() local
329 for (auto& context : threads) { in Stop()

12345678910>>...12