Home
last modified time | relevance | path

Searched refs:num_threads_ (Results 1 – 20 of 20) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/executor/
Dthreadpool.cc55 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()
Dthreadpool.h131 int num_threads_ = 0;
/external/rust/crates/grpcio-sys/grpc/src/cpp/thread_manager/
Dthread_manager.cc59 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()
Dthread_manager.h168 int num_threads_; variable
/external/grpc-grpc/src/cpp/thread_manager/
Dthread_manager.cc58 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()
Dthread_manager.h165 int num_threads_; variable
/external/grpc-grpc/test/cpp/qps/
Dclient_sync.cc57 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/
Dexecutor.cc54 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()
Dexecutor.h72 gpr_atm num_threads_; variable
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dexecutor.cc94 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()
Dexecutor.h113 gpr_atm num_threads_; variable
/external/libchrome/base/threading/
Dsimple_thread.cc112 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()
Dsimple_thread.h221 int num_threads_; variable
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Dthreadpool_dataset_op.cc72 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::__anon16b1edff0111::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::__anon16b1edff0111::PrivateThreadPoolDatasetOp::Dataset
/external/libgav1/libgav1/src/utils/
Dthreadpool.cc92 : 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()
Dthreadpool.h156 const int num_threads_ = 0; variable
/external/eigen/unsupported/Eigen/CXX11/src/Tensor/
DTensorDeviceThreadPool.h109 …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
DTensorContractionThreadPool.h313 num_threads_(num_threads),
404 const int num_threads_;
/external/tensorflow/tensorflow/core/framework/
Drun_handler.cc318 : 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()
Drun_handler.h290 const int num_threads_; variable