| /third_party/cef/libcef/common/ |
| D | thread_impl.cc | 47 if (thread_.get()) { in ~CefThreadImpl()
52 base::BindOnce(StopAndDestroy, base::Unretained(thread_.release()))); in ~CefThreadImpl()
54 StopAndDestroy(thread_.release()); in ~CefThreadImpl()
69 thread_.reset(new base::Thread(display_name)); in Create()
104 thread_->init_com_with_mta(com_init_mode == COM_INIT_MODE_MTA); in Create()
108 if (!thread_->StartWithOptions(std::move(options))) { in Create()
109 thread_.reset(); in Create()
113 thread_task_runner_ = new CefTaskRunnerImpl(thread_->task_runner()); in Create()
114 thread_id_ = thread_->GetThreadId(); in Create()
134 if (thread_) in Stop()
[all …]
|
| /third_party/cef/tests/ceftests/ |
| D | thread_unittest.cc | 28 EXPECT_TRUE(!thread_.get()); in CreateTestThread()
34 thread_ = CefThread::CreateThread("test_thread"); in CreateTestThread()
35 EXPECT_TRUE(thread_.get()); in CreateTestThread()
36 EXPECT_TRUE(thread_->IsRunning()); in CreateTestThread()
38 thread_id_ = thread_->GetPlatformThreadId(); in CreateTestThread()
41 thread_task_runner_ = thread_->GetTaskRunner(); in CreateTestThread()
49 EXPECT_TRUE(thread_.get()); in DestroyTestThread()
52 EXPECT_TRUE(thread_->IsRunning()); in DestroyTestThread()
53 thread_->Stop(); in DestroyTestThread()
54 EXPECT_FALSE(thread_->IsRunning()); in DestroyTestThread()
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | std_thread.hpp | 38 : thread_(f) in std_thread()
51 if (thread_.joinable()) in join()
52 thread_.join(); in join()
62 std::thread thread_; member in boost::asio::detail::std_thread
|
| D | wince_thread.hpp | 46 thread_ = ::CreateThread(0, 0, wince_thread_function, in wince_thread()
48 if (!thread_) in wince_thread()
61 ::CloseHandle(thread_); in ~wince_thread()
67 ::WaitForSingleObject(thread_, INFINITE); in join()
107 ::HANDLE thread_;
|
| D | winapp_thread.hpp | 46 thread_ = ::CreateThread(0, 0, winapp_thread_function, in winapp_thread()
48 if (!thread_) in winapp_thread()
61 ::CloseHandle(thread_); in ~winapp_thread()
67 ::WaitForSingleObjectEx(thread_, INFINITE, false); in join()
107 ::HANDLE thread_;
|
| D | thread_group.hpp | 63 first_->thread_.join(); in join()
82 : thread_(f), in item()
87 boost::asio::detail::thread thread_; member
|
| /third_party/boost/boost/asio/detail/ |
| D | std_thread.hpp | 38 : thread_(f) in std_thread()
51 if (thread_.joinable()) in join()
52 thread_.join(); in join()
62 std::thread thread_; member in boost::asio::detail::std_thread
|
| D | wince_thread.hpp | 46 thread_ = ::CreateThread(0, 0, wince_thread_function, in wince_thread()
48 if (!thread_) in wince_thread()
61 ::CloseHandle(thread_); in ~wince_thread()
67 ::WaitForSingleObject(thread_, INFINITE); in join()
107 ::HANDLE thread_;
|
| D | winapp_thread.hpp | 46 thread_ = ::CreateThread(0, 0, winapp_thread_function, in winapp_thread()
48 if (!thread_) in winapp_thread()
61 ::CloseHandle(thread_); in ~winapp_thread()
67 ::WaitForSingleObjectEx(thread_, INFINITE, false); in join()
107 ::HANDLE thread_;
|
| D | thread_group.hpp | 63 first_->thread_.join(); in join()
82 : thread_(f), in item()
87 boost::asio::detail::thread thread_; member
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | winrt_timer_scheduler.ipp | 37 thread_(0),
41 thread_ = new boost::asio::detail::thread(
58 if (thread_)
60 thread_->join();
61 delete thread_;
62 thread_ = 0;
|
| D | win_thread.ipp | 37 ::CloseHandle(thread_);
45 HANDLE handles[2] = { exit_event_, thread_ };
50 ::TerminateThread(thread_, 0);
54 ::QueueUserAPC(apc_function, thread_, 0);
55 ::WaitForSingleObject(thread_, INFINITE);
90 thread_ = reinterpret_cast<HANDLE>(::_beginthreadex(0,
92 if (!thread_)
|
| D | posix_thread.ipp | 35 ::pthread_detach(thread_);
42 ::pthread_join(thread_, 0);
59 int error = ::pthread_create(&thread_, 0,
|
| D | select_reactor.ipp | 63 thread_(0),
69 thread_ = new boost::asio::detail::thread(thread_function(this));
84 if (thread_)
90 if (thread_)
92 thread_->join();
93 delete thread_;
94 thread_ = 0;
|
| D | scheduler.ipp | 123 thread_(0)
131 thread_ = new boost::asio::detail::thread(thread_function(this));
137 if (thread_)
143 thread_->join();
144 delete thread_;
152 if (thread_)
157 if (thread_)
159 thread_->join();
160 delete thread_;
161 thread_ = 0;
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | winrt_timer_scheduler.ipp | 37 thread_(0),
41 thread_ = new boost::asio::detail::thread(
58 if (thread_)
60 thread_->join();
61 delete thread_;
62 thread_ = 0;
|
| D | win_thread.ipp | 37 ::CloseHandle(thread_);
45 HANDLE handles[2] = { exit_event_, thread_ };
50 ::TerminateThread(thread_, 0);
54 ::QueueUserAPC(apc_function, thread_, 0);
55 ::WaitForSingleObject(thread_, INFINITE);
90 thread_ = reinterpret_cast<HANDLE>(::_beginthreadex(0,
92 if (!thread_)
|
| D | posix_thread.ipp | 35 ::pthread_detach(thread_);
42 ::pthread_join(thread_, 0);
59 int error = ::pthread_create(&thread_, 0,
|
| D | select_reactor.ipp | 63 thread_(0),
69 thread_ = new boost::asio::detail::thread(thread_function(this));
84 if (thread_)
90 if (thread_)
92 thread_->join();
93 delete thread_;
94 thread_ = 0;
|
| D | scheduler.ipp | 123 thread_(0)
131 thread_ = new boost::asio::detail::thread(thread_function(this));
137 if (thread_)
143 thread_->join();
144 delete thread_;
152 if (thread_)
157 if (thread_)
159 thread_->join();
160 delete thread_;
161 thread_ = 0;
|
| /third_party/node/src/inspector/ |
| D | main_thread_interface.cc | 94 : thread_(thread), object_id_(object_id) {} in AnotherThreadObjectReference()
100 thread_->Post(NewCreateRequest(object_id_, std::move(factory))); in AnotherThreadObjectReference()
106 thread_->Post(std::make_unique<DeleteRequest>(object_id_)); in ~AnotherThreadObjectReference()
112 thread_->Post(std::unique_ptr<Request>( in Call()
130 std::shared_ptr<MainThreadHandle> thread_; member in node::inspector::__anona07c9ff60111::AnotherThreadObjectReference
137 : thread_(thread), in MainThreadSessionState()
146 Agent* agent = thread_->inspector_agent(); in Connect()
156 MainThreadInterface* thread_; member in node::inspector::__anona07c9ff60111::MainThreadSessionState
186 : thread_(thread), delegate_(thread, object_id) {} in ThreadSafeDelegate()
197 std::shared_ptr<MainThreadHandle> thread_; member in node::inspector::__anona07c9ff60111::ThreadSafeDelegate
|
| D | worker_inspector.h | 88 : thread_(thread) {} in WorkerManager()
99 return thread_; in MainThread()
103 std::shared_ptr<MainThreadHandle> thread_;
|
| /third_party/grpc/test/core/iomgr/ |
| D | work_serializer_test.cc | 47 : lock_(lock), thread_("grpc_execute_many", ExecuteManyLoop, this) { in TestThread()
49 thread_.Start(); in TestThread()
55 thread_.Join(); in ~TestThread()
87 grpc_core::Thread thread_; member in __anona91235c20111::TestThread
|
| /third_party/flutter/engine/flutter/testing/ |
| D | thread_test.cc | 14 thread_ = std::make_unique<fml::Thread>(); in SetUp()
15 thread_task_runner_ = thread_->GetTaskRunner(); in SetUp()
24 thread_ = nullptr; in TearDown()
|
| /third_party/mindspore/mindspore/core/mindrt/src/thread/ |
| D | threadpool.h | 81 std::thread::id thread_id() const { return thread_.get_id(); } in thread_id()
84 pthread_t handle() { return thread_.native_handle(); } in handle()
94 std::thread thread_; variable
|