| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-currentthread.hpp | 131 struct current_thread : public scheduler_interface struct
134 typedef current_thread this_type;
137 typedef detail::action_queue queue_type;
139 struct derecurser : public worker_interface
165 struct current_worker : public worker_interface
237 std::shared_ptr<current_worker> wi;
240 current_thread() in current_thread() argument
244 virtual ~current_thread() in ~current_thread()
248 static bool is_schedule_required() { return !queue_type::owned(); } in is_schedule_required()
250 inline bool is_tail_recursion_allowed() const { in is_tail_recursion_allowed()
[all …]
|
| /external/pigweed/pw_sync_threadx/ |
| D | interrupt_spin_lock.cc | 38 TX_THREAD* current_thread = tx_thread_identify(); in lock() local
75 TX_THREAD* current_thread = tx_thread_identify(); in unlock() local
|
| /external/webrtc/rtc_base/synchronization/ |
| D | sequence_checker.cc | 49 const rtc::PlatformThreadRef current_thread = rtc::CurrentThreadRef(); in IsCurrent() local
78 const rtc::PlatformThreadRef current_thread = rtc::CurrentThreadRef(); in ExpectationToString() local
|
| /external/webrtc/rtc_base/ |
| D | race_checker.cc | 26 const PlatformThreadRef current_thread = CurrentThreadRef(); in Acquire() local
|
| D | operations_chain_unittest.cc | 82 Thread* current_thread = Thread::Current(); in StartAsynchronousOperation() local
|
| D | thread.cc | 894 Thread* current_thread = Thread::Current(); in PreRun() local
|
| D | thread_unittest.cc | 278 Thread* current_thread = Thread::Current(); in TEST() local
|
| /external/pigweed/pw_thread_freertos/ |
| D | util.cc | 65 void* current_thread; in ForEachThreadInList() local
|
| /external/webrtc/sdk/android/src/jni/ |
| D | android_media_codec_common.h | 67 rtc::Thread* current_thread = rtc::Thread::Current(); in AllowBlockingCalls() local
|
| /external/webrtc/video/ |
| D | receive_statistics_proxy2.cc | 92 rtc::Thread* current_thread = rtc::ThreadManager::Instance()->CurrentThread(); in IsCurrentTaskQueueOrThread() local
|
| /external/crosvm/common/cros_asyncv2/src/ |
| D | executor.rs | 346 let current_thread = thread::current().id(); in run_until() localVariable
|
| /external/python/cpython2/Lib/ |
| D | threading.py | 1156 current_thread = currentThread variable
|
| /external/rust/crates/rayon-core/src/ |
| D | registry.rs | 293 pub(super) fn current_thread(&self) -> Option<&WorkerThread> { in current_thread() method
|
| /external/libvpx/libvpx/third_party/googletest/src/src/ |
| D | gtest-port.cc | 543 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local
|
| /external/googletest/googletest/src/ |
| D | gtest-port.cc | 548 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local
|
| /external/libaom/libaom/third_party/googletest/src/googletest/src/ |
| D | gtest-port.cc | 512 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local
|
| /external/mesa3d/src/gtest/src/ |
| D | gtest-port.cc | 539 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local
|
| /external/rust/crates/quiche/deps/boringssl/src/third_party/googletest/src/ |
| D | gtest-port.cc | 544 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local
|
| /external/python/cpython3/Lib/ |
| D | threading.py | 1423 def current_thread(): function
|
| /external/crosvm/cros_async/src/ |
| D | uring_executor.rs | 398 let current_thread = thread::current().id(); in run() localVariable
|
| /external/crosvm/common/cros_async/src/ |
| D | uring_executor.rs | 398 let current_thread = thread::current().id(); in run() localVariable
|
| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/test/gmock-1.8.0/ |
| D | gmock-gtest-all.cc | 8949 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local
|