| /base/hiviewdfx/hiview/base/ |
| H A D | event_loop.cpp | 19 #include <thread>
133 thread_ = std::make_unique<std::thread>(&EventLoop::Run, this);
in StartLoop()
136 // handle loop in current thread cases
in StartLoop()
407 HIVIEW_LOGW("Failed to optimize memory for current thread");
in Run()
427 // set thread name
in InitThreadName()
431 HIVIEW_LOGW("%{public}s is too long for thread, please change to a shorter one.", name_.c_str());
in InitThreadName()
|
| /base/print/print_fwk/services/print_service/src/ |
| H A D | print_http_request_process.cpp | 410 std::thread writeDataTask([this] {this->StartWriteDataToPrinterLooper();}); in CreatWriteDataTask()
439 std::thread readSendDocTask([this] {this->StartReadSendDocDataFromPrinterLooper();}); in CreatReadSendDocTask()
|
| /third_party/rust/crates/bindgen/bindgen-tests/tests/ |
| H A D | tests.rs | 83 // Write to stdin in a new thread, so that we can read from stdout on this in rustfmt()
84 // thread. This keeps the child from blocking on writing to its stdout which in rustfmt()
87 ::std::thread::spawn(move || stdin.write_all(source.as_bytes())); in rustfmt()
89 // Read stderr on a new thread for similar reasons. in rustfmt()
90 let stderr_handle = ::std::thread::spawn(move || { in rustfmt()
105 .expect("writer thread should not have panicked") in rustfmt()
113 .expect("stderr reader thread should not have panicked") in rustfmt()
|
| /third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/vulkan/ |
| H A D | CommandProcessor.h | 8 // used in an asynchronous worker thread.
17 #include <thread>
74 // Exit the command processor thread
466 // enabled. Issuing the |destroy| command will cause the worker thread to clean up it's resources
558 // Entry point for command processor thread, calls processTasksImpl to do the
559 // work. called by RendererVk::initializeDevice on main thread
562 // Called asynchronously from main thread to queue work that is then processed by the worker
563 // thread
566 // Command processor thread, called by processTasks. The loop waits for work to
567 // be submitted from a separate thread
[all...] |
| /third_party/skia/third_party/externals/oboe/src/aaudio/ |
| H A D | AudioStreamAAudio.cpp | 59 // This runs in its own thread.
77 // This runs in its own thread.
105 // Launch a thread to handle the error.
106 // That other thread can safely stop, close and delete the stream.
123 // Handle error on a separate thread using shared pointer. in internalErrorCallback()
124 std::thread t(oboe_aaudio_error_thread_proc_shared, sharedStream, in internalErrorCallback()
128 // Handle error on a separate thread. in internalErrorCallback()
129 std::thread t(oboe_aaudio_error_thread_proc, oboeStream, in internalErrorCallback()
301 // so another thread cannot call requestStart() right before the close. in close()
448 // is closed from another thread
[all...] |
| /third_party/rust/crates/regex/regex-syntax/src/ast/ |
| H A D | mod.rs | 1471 // We use a thread with an explicit stack size to test that our destructor
1478 use std::thread; in no_stack_overflow_on_drop()
1493 // We run our test on a thread with a small stack size so we can in no_stack_overflow_on_drop()
1495 thread::Builder::new() in no_stack_overflow_on_drop()
|
| /third_party/rust/crates/rustix/src/backend/linux_raw/ |
| H A D | conv.rs | 29 #[cfg(any(feature = "thread", feature = "time", target_arch = "x86"))]
42 #[cfg(any(feature = "thread", feature = "time", target_arch = "x86"))]
270 #[cfg(any(feature = "thread", feature = "time", target_arch = "x86"))]
627 #[cfg(feature = "thread")]
628 impl<'a, Num: ArgNumber> From<(crate::thread::FutexOperation, crate::thread::FutexFlags)>
632 fn from(pair: (crate::thread::FutexOperation, crate::thread::FutexFlags)) -> Self { in from()
|
| /third_party/glslang/StandAlone/ |
| H A D | StandAlone.cpp | 64 #include <thread>
1172 // NOTE: TWorkList::remove is thread-safe in CompileShaders()
1614 // of compilation units. (We don't care about the thread in CompileAndLinkShaderFiles()
1699 // 2) independent arguments, can be tackled by multiple asynchronous threads, for testing thread safety, using the old handle interface in singleMain()
1717 std::array<std::thread, 16> threads; in singleMain()
1719 threads[t] = std::thread(CompileShaders, std::ref(workList)); in singleMain()
1720 if (threads[t].get_id() == std::thread::id()) { in singleMain()
1721 fprintf(stderr, "Failed to create thread\n"); in singleMain()
1726 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in singleMain()
|
| /third_party/node/tools/ |
| H A D | test.py | 155 # Spawn N-1 threads and then use this thread as the last one.
159 thread = threading.Thread(target=self.RunSingle, args=[True, i + 1])
160 threads.append(thread)
161 thread.start()
165 for thread in threads:
167 thread.join(timeout=1000000)
|
| /third_party/rust/crates/rust-openssl/openssl/src/ssl/test/ |
| H A D | mod.rs | 14 use std::thread;
333 let guard = thread::spawn(move || { in test_connect_with_srtp_ctx()
391 let guard = thread::spawn(move || { in test_connect_with_srtp_ssl()
829 let t = thread::spawn(move || { in test_mozilla_server()
1147 let guard = thread::spawn(move || { in keying_export()
|
| /base/accesscontrol/sandbox_manager/interfaces/innerkits/sandbox_manager/src/ |
| H A D | sandbox_manager_client.cpp | 19 #include <thread>
|
| /base/inputmethod/imf/frameworks/native/inputmethod_ability/include/ |
| H A D | input_method_ability.h | 19 #include <thread>
98 /* called from TaskManager worker thread */
|
| /base/hiviewdfx/hilog/services/hilogd/ |
| H A D | log_stats.cpp | 15 #include <thread>
|
| /base/hiviewdfx/hidumper/frameworks/native/src/executor/ |
| H A D | ipc_stat_dumper.cpp | 19 #include <thread>
|
| /base/inputmethod/imf/test/unittest/cpp_test/src/ |
| H A D | task_manager_test.cpp | 28 #include <thread>
|
| /base/account/os_account/frameworks/common/file_operator/src/ |
| H A D | account_file_operator.cpp | 29 #include <thread>
|
| /base/account/os_account/frameworks/osaccount/core/test/unittest/ |
| H A D | os_account_test.cpp | 18 #include <thread>
|
| /base/account/os_account/services/accountmgr/test/unittest/os_account/ |
| H A D | os_account_inner_account_mgr_cov.cpp | 19 #include <thread>
|
| /base/account/os_account/test/fuzztest/osaccount_stub/activateosaccountstub_fuzzer/ |
| H A D | activateosaccountstub_fuzzer.cpp | 18 #include <thread>
|
| /base/hiviewdfx/faultloggerd/tools/crash_validator/ |
| H A D | crash_validator.cpp | 86 kmsgReaderThread_ = std::make_unique<std::thread>([this] { in InitSysEventListener()
|
| /base/hiviewdfx/faultloggerd/test/unittest/local_handler/ |
| H A D | local_handler_test.cpp | 21 #include <thread>
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/observer/ |
| H A D | os_event_listener.cpp | 175 inotifyThread_ = std::make_unique<std::thread>([this] { this->HandleDirEvent(); }); in RegisterDirListener()
|
| /base/account/os_account/services/accountmgr/src/ |
| H A D | account_mgr_service.cpp | 249 std::thread taskThread(task); in MoveAppAccountData()
|
| /base/powermgr/power_manager/test/unittest/src/interface_test/ |
| H A D | power_suspend_controller_test.cpp | 17 #include <thread>
|
| /base/notification/distributed_notification_service/services/ans/test/unittest/ |
| H A D | advanced_notification_live_view_service_test.cpp | 19 #include <thread>
|