Searched refs:num_blocking_threads (Results 1 – 11 of 11) sorted by relevance
| /aosp_15_r20/external/tensorflow/tensorflow/core/framework/ |
| H A D | run_handler.cc | 314 int num_blocking_threads, int num_non_blocking_threads, Env* env, in RunHandlerThreadPool() argument
318 : num_threads_(num_blocking_threads + num_non_blocking_threads), in RunHandlerThreadPool()
319 num_blocking_threads_(num_blocking_threads), in RunHandlerThreadPool()
330 std::vector<int>({num_blocking_threads / 2, in RunHandlerThreadPool()
331 num_blocking_threads - num_blocking_threads / 2}))), in RunHandlerThreadPool()
359 int num_blocking_threads = num_blocking_threads_; in Start() local
369 const bool is_blocking_thread = (i < num_blocking_threads) ? true : false; in Start()
996 int num_blocking_threads = run_handler_thread_pool()->NumBlockingThreads(); in RecomputePoolStats() local
997 int num_non_blocking_threads = num_threads - num_blocking_threads; in RecomputePoolStats()
1000 num_active_requests, num_blocking_threads); in RecomputePoolStats()
[all …]
|
| H A D | run_handler.h | 223 RunHandlerThreadPool(int num_blocking_threads, int num_non_blocking_threads,
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/tfrt/run_handler_thread_pool/ |
| H A D | run_handler.h | 287 int num_blocking_threads; member
297 Options(int num_blocking_threads, int num_non_blocking_threads, in Options()
305 : num_blocking_threads(num_blocking_threads), in Options()
|
| H A D | run_handler.cc | 340 : num_threads_(options.num_blocking_threads + in RunHandlerThreadPool()
342 num_blocking_threads_(options.num_blocking_threads), in RunHandlerThreadPool()
388 int num_blocking_threads = num_blocking_threads_; in Start() local
399 env_.CreateThread([this, i, num_blocking_threads]() { in Start()
400 WorkerLoop(i, i < num_blocking_threads); in Start()
956 int num_blocking_threads = run_handler_thread_pool()->NumBlockingThreads(); in RecomputePoolStats() local
957 int num_non_blocking_threads = num_threads - num_blocking_threads; in RecomputePoolStats()
959 for (int i = 0; i < num_blocking_threads + num_non_blocking_threads; ++i) { in RecomputePoolStats()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/ |
| D | rt_unstable_metrics.rs | 30 fn num_blocking_threads() { in num_blocking_threads() function
32 assert_eq!(0, rt.metrics().num_blocking_threads()); in num_blocking_threads()
34 assert_eq!(1, rt.metrics().num_blocking_threads()); in num_blocking_threads()
37 assert_eq!(0, rt.metrics().num_blocking_threads()); in num_blocking_threads()
39 assert_eq!(1, rt.metrics().num_blocking_threads()); in num_blocking_threads()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/metrics/ |
| D | runtime.rs | 123 pub fn num_blocking_threads(&self) -> usize {
124 self.handle.inner.num_blocking_threads()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/ |
| D | mod.rs | 251 pub(crate) fn num_blocking_threads(&self) -> usize {
252 match_flavor!(self, Handle(handle) => handle.num_blocking_threads())
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/handle/ |
| D | metrics.rs | 27 pub(crate) fn num_blocking_threads(&self) -> usize {
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/handle/ |
| D | metrics.rs | 10 pub(crate) fn num_blocking_threads(&self) -> usize { in num_blocking_threads() method
|
| /aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| H A D | bef_thunk.cc | 182 [&](int num_threads, int num_blocking_threads) { in GetCoreRuntimeAndWorkQueue() argument
186 num_blocking_threads)); in GetCoreRuntimeAndWorkQueue()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/current_thread/ |
| D | mod.rs | 586 pub(crate) fn num_blocking_threads(&self) -> usize {
|