MCPcopy Create free account
hub / github.com/apache/arrow / OwnsThisThread

Method OwnsThisThread

cpp/src/arrow/util/thread_pool.cc:252–255  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

250}
251
252bool SerialExecutor::OwnsThisThread() {
253 std::lock_guard lk(state_->mutex);
254 return std::this_thread::get_id() == state_->current_thread;
255}
256#ifdef ARROW_ENABLE_THREADING
257
258void SerialExecutor::RunLoop() {

Callers 1

TEST_FFunction · 0.80

Calls 1

GetCurrentThreadPoolFunction · 0.85

Tested by 1

TEST_FFunction · 0.64