Searched refs:thread_ (Results 1 – 10 of 10) sorted by relevance
49 virtual std::shared_ptr<Thread> thread() { return thread_.lock(); } in thread()55 virtual void thread(std::shared_ptr<Thread> value) { thread_ = value; } in thread()58 std::weak_ptr<Thread> thread_;89 if (!detached_ && thread_->joinable()) { in ~Thread()130 thread_ = std::unique_ptr<std::thread>(new std::thread(getThreadFunc(), selfRef)); in start()133 thread_->detach(); in start()148 thread_->join(); in join()155 Thread::id_t getId() const { return thread_.get() ? thread_->get_id() : std::thread::id(); } in getId()170 std::unique_ptr<std::thread> thread_; variable
43 thread_ = threadFactory.newThread(helper_); in start()45 thread_->start(); in start()75 thread_->join(); in stop()
129 std::shared_ptr<concurrency::Thread> thread_; variable
114 thread_ = (HANDLE)_beginthreadex(NULL, 0, thread_proc, this, 0, NULL); in TOverlappedSubmissionThread()115 if (thread_ == 0) { in TOverlappedSubmissionThread()124 ::WaitForSingleObject(thread_, INFINITE); in ~TOverlappedSubmissionThread()125 CloseHandle(thread_); in ~TOverlappedSubmissionThread()
116 HANDLE thread_; variable
724 if (thread_) thread_.join(); in ~this()774 thread_ = null; in timerThread()778 thread_ = new Thread(&timerThread); in startThread()779 thread_.start(); in startThread()796 Thread thread_; member
123 thread_->addWorkItem(&cancelOverlap_); in interrupt()139 TAutoOverlapThread thread_; member in apache::thrift::transport::TNamedPipeServer254 thread_->addWorkItem(&connectOverlap_); in initiateNamedConnect()
113 thread_->addWorkItem(&cancelOverlap_); in ~TWaitableNamedPipeImpl()131 TAutoOverlapThread thread_; member in apache::thrift::transport::TWaitableNamedPipeImpl145 thread_->addWorkItem(&readOverlap_); in beginAsyncRead()
765 std::shared_ptr<Thread> getThread() const { return thread_; } in getThread()768 void setThread(const std::shared_ptr<Thread>& t) { thread_ = t; } in setThread()853 std::shared_ptr<Thread> thread_; variable
1517 if (thread_) { in createNotificationPipe()1521 thread_->join(); in createNotificationPipe()