| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/executor/ |
| D | threadpool.cc | 55 if (num_threads_ <= 0) num_threads_ = 1; in SharedThreadPoolConstructor()
59 gpr_zalloc(num_threads_ * sizeof(ThreadPoolWorker*))); in SharedThreadPoolConstructor()
60 for (int i = 0; i < num_threads_; ++i) { in SharedThreadPoolConstructor()
79 ThreadPool::ThreadPool(int num_threads) : num_threads_(num_threads) { in ThreadPool()
87 : num_threads_(num_threads), thd_name_(thd_name) { in ThreadPool()
95 : num_threads_(num_threads), in ThreadPool()
108 for (int i = 0; i < num_threads_; ++i) { in ~ThreadPool()
112 for (int i = 0; i < num_threads_; ++i) { in ~ThreadPool()
116 for (int i = 0; i < num_threads_; ++i) { in ~ThreadPool()
130 int ThreadPool::pool_capacity() const { return num_threads_; } in pool_capacity()
|
| D | threadpool.h | 131 int num_threads_ = 0;
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 59 num_threads_(0), in ThreadManager()
67 GPR_ASSERT(num_threads_ == 0); in ~ThreadManager()
77 while (num_threads_ != 0) { in Wait()
105 num_threads_--; in MarkAsCompleted()
106 if (num_threads_ == 0) { in MarkAsCompleted()
138 num_threads_ = min_pollers_; in Initialize()
177 num_threads_++; in MainWorkLoop()
178 if (num_threads_ > max_active_threads_sofar_) { in MainWorkLoop()
179 max_active_threads_sofar_ = num_threads_; in MainWorkLoop()
190 num_threads_--; in MainWorkLoop()
|
| D | thread_manager.h | 168 int num_threads_; variable
|
| /external/grpc-grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 58 num_threads_(0), in ThreadManager()
66 GPR_ASSERT(num_threads_ == 0); in ~ThreadManager()
76 while (num_threads_ != 0) { in Wait()
104 num_threads_--; in MarkAsCompleted()
105 if (num_threads_ == 0) { in MarkAsCompleted()
137 num_threads_ = min_pollers_; in Initialize()
174 num_threads_++; in MainWorkLoop()
175 if (num_threads_ > max_active_threads_sofar_) { in MainWorkLoop()
176 max_active_threads_sofar_ = num_threads_; in MainWorkLoop()
|
| D | thread_manager.h | 165 int num_threads_; variable
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client_sync.cc | 57 num_threads_ = in SynchronousClient()
59 responses_.resize(num_threads_); in SynchronousClient()
60 SetupLoadTest(config, num_threads_); in SynchronousClient()
109 size_t num_threads_; member in grpc::testing::SynchronousClient
117 StartThreads(num_threads_); in SynchronousUnaryClient()
149 context_(num_threads_), in SynchronousStreamingClient()
150 stream_(num_threads_), in SynchronousStreamingClient()
151 stream_mu_(num_threads_), in SynchronousStreamingClient()
152 shutdown_(num_threads_), in SynchronousStreamingClient()
154 messages_issued_(num_threads_) { in SynchronousStreamingClient()
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | executor.cc | 54 gpr_atm_rel_store(&num_threads_, 0); in GrpcExecutor()
86 return gpr_atm_acq_load(&num_threads_) > 0; in IsThreaded()
90 gpr_atm curr_num_threads = gpr_atm_acq_load(&num_threads_); in SetThreading()
99 GPR_ASSERT(num_threads_ == 0); in SetThreading()
100 gpr_atm_rel_store(&num_threads_, 1); in SetThreading()
135 curr_num_threads = gpr_atm_no_barrier_load(&num_threads_); in SetThreading()
142 gpr_atm_rel_store(&num_threads_, 0); in SetThreading()
207 static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
300 cur_thread_count = static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
304 gpr_atm_rel_store(&num_threads_, cur_thread_count + 1); in Enqueue()
|
| D | executor.h | 72 gpr_atm num_threads_; variable
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | executor.cc | 94 gpr_atm_rel_store(&num_threads_, 0); in Executor()
137 return gpr_atm_acq_load(&num_threads_) > 0; in IsThreaded()
141 gpr_atm curr_num_threads = gpr_atm_acq_load(&num_threads_); in SetThreading()
150 GPR_ASSERT(num_threads_ == 0); in SetThreading()
151 gpr_atm_rel_store(&num_threads_, 1); in SetThreading()
185 curr_num_threads = gpr_atm_no_barrier_load(&num_threads_); in SetThreading()
192 gpr_atm_rel_store(&num_threads_, 0); in SetThreading()
266 static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
364 cur_thread_count = static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
368 gpr_atm_rel_store(&num_threads_, cur_thread_count + 1); in Enqueue()
|
| D | executor.h | 113 gpr_atm num_threads_; variable
|
| /external/angle/third_party/abseil-cpp/absl/flags/internal/ |
| D | sequence_lock_test.cc | 36 num_threads_(std::get<1>(GetParam())) {} in ConcurrentSequenceLockTest()
40 const int num_threads_; member in __anon37fabcc30111::ConcurrentSequenceLockTest
62 for (int i = 0; i < num_threads_; i++) { in TEST_P()
83 while (unsuccessful_reads.load(std::memory_order_relaxed) < num_threads_) { in TEST_P()
|
| /external/libchrome/base/threading/ |
| D | simple_thread.cc | 112 num_threads_(num_threads), in DelegateSimpleThreadPool()
124 for (int i = 0; i < num_threads_; ++i) { in Start()
135 AddWork(nullptr, num_threads_); in JoinAll()
138 for (int i = 0; i < num_threads_; ++i) { in JoinAll()
|
| D | simple_thread.h | 221 int num_threads_; variable
|
| /external/libgav1/libgav1/src/utils/ |
| D | threadpool.cc | 92 : threads_(std::move(threads)), num_threads_(num_threads) { in ThreadPool()
116 int ThreadPool::num_threads() const { return num_threads_; } in num_threads()
243 for (int i = 0; i < num_threads_; ++i) { in StartWorkers()
320 for (int i = 0; i < num_threads_; ++i) { in Shutdown()
|
| D | threadpool.h | 156 const int num_threads_ = 0; variable
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | threadpool_dataset_op.cc | 72 OP_REQUIRES_OK(ctx, ctx->GetAttr("num_threads", &num_threads_)); in ThreadPoolHandleOp()
76 ctx, num_threads_ > 0, in ThreadPoolHandleOp()
105 num_threads_, in Compute()
122 int num_threads_; member in tensorflow::data::experimental::__anon3c251a260111::ThreadPoolHandleOp
403 num_threads_(num_threads) { in Dataset()
449 TF_RETURN_IF_ERROR(b->AddScalar(num_threads_, &num_threads_node)); in AsGraphDefInternal()
474 params.runner_threadpool_size = dataset()->num_threads_; in GetNextInternal()
504 const int64 num_threads_; member in tensorflow::data::experimental::__anon3c251a260111::PrivateThreadPoolDatasetOp::Dataset
|
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| D | TensorDeviceThreadPool.h | 109 …ThreadPoolDevice(ThreadPoolInterface* pool, int num_cores) : pool_(pool), num_threads_(num_cores) … in ThreadPoolDevice()
134 return num_threads_; in numThreads()
143 return l3CacheSize() / num_threads_; in lastLevelCacheSize()
273 int num_threads_; member
|
| D | TensorContractionThreadPool.h | 313 num_threads_(num_threads),
404 const int num_threads_;
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | run_handler.cc | 318 : num_threads_(num_blocking_threads + num_non_blocking_threads), in RunHandlerThreadPool()
321 thread_data_(num_threads_), in RunHandlerThreadPool()
338 thread_data_.resize(num_threads_);
360 for (int i = 0; i < num_threads_; i++) { in Start()
458 int RunHandlerThreadPool::NumThreads() const { return num_threads_; } in NumThreads()
|
| D | run_handler.h | 290 const int num_threads_; variable
|