Home
last modified time | relevance | path

Searched refs:thread_ (Results 1 – 10 of 10) sorted by relevance

/thrift-3.4.0/lib/cpp/src/thrift/concurrency/
DThread.h49 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
/thrift-3.4.0/lib/cpp/test/processor/
DServerThread.cpp43 thread_ = threadFactory.newThread(helper_); in start()
45 thread_->start(); in start()
75 thread_->join(); in stop()
DServerThread.h129 std::shared_ptr<concurrency::Thread> thread_; variable
/thrift-3.4.0/lib/cpp/src/thrift/windows/
DOverlappedSubmissionThread.cpp114 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()
DOverlappedSubmissionThread.h116 HANDLE thread_; variable
/thrift-3.4.0/lib/d/test/
Dtransport_test.d724 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
/thrift-3.4.0/lib/cpp/src/thrift/transport/
DTPipeServer.cpp123 thread_->addWorkItem(&cancelOverlap_); in interrupt()
139 TAutoOverlapThread thread_; member in apache::thrift::transport::TNamedPipeServer
254 thread_->addWorkItem(&connectOverlap_); in initiateNamedConnect()
DTPipe.cpp113 thread_->addWorkItem(&cancelOverlap_); in ~TWaitableNamedPipeImpl()
131 TAutoOverlapThread thread_; member in apache::thrift::transport::TWaitableNamedPipeImpl
145 thread_->addWorkItem(&readOverlap_); in beginAsyncRead()
/thrift-3.4.0/lib/cpp/src/thrift/server/
DTNonblockingServer.h765 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
DTNonblockingServer.cpp1517 if (thread_) { in createNotificationPipe()
1521 thread_->join(); in createNotificationPipe()