| /external/tensorflow/tensorflow/contrib/boosted_trees/lib/learner/common/partitioners/ |
| example_partitioner_test.cc | 28 : thread_pool_(tensorflow::Env::Default(), "test_pool", 2),
35 thread::ThreadPool thread_pool_; member in class:tensorflow::boosted_trees::learner::__anon44712::ExamplePartitionerTest
44 &thread_pool_,
67 &thread_pool_,
90 &thread_pool_,
|
| /external/v8/src/libplatform/ |
| default-worker-threads-task-runner.cc | 16 thread_pool_.push_back(base::make_unique<WorkerThread>(&queue_));
30 thread_pool_.clear();
|
| default-worker-threads-task-runner.h | 40 std::vector<std::unique_ptr<WorkerThread>> thread_pool_; member in class:v8::platform::DefaultWorkerThreadsTaskRunner
|
| /art/runtime/ |
| thread_pool_test.cc | 128 : thread_pool_(thread_pool),
134 thread_pool_->AddTask(self, new TreeTask(thread_pool_, count_, depth_ - 1));
135 thread_pool_->AddTask(self, new TreeTask(thread_pool_, count_, depth_ - 1));
146 ThreadPool* const thread_pool_; member in class:art::TreeTask
|
| thread_pool.cc | 45 : thread_pool_(thread_pool),
90 thread_pool_->creation_barier_.Pass(self);
91 while ((task = thread_pool_->GetTask(self)) != nullptr) {
103 worker->thread_pool_->create_peers_));
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| unbounded_thread_pool.cc | 86 thread_pool_.clear();
96 return thread_pool_.size();
123 thread_pool_.emplace_back(new_thread);
|
| unbounded_thread_pool.h | 71 std::vector<std::unique_ptr<Thread>> thread_pool_ GUARDED_BY(thread_pool_mu_);
|
| dataset_test_base.cc | 133 thread_pool_ = absl::make_unique<thread::ThreadPool>(
160 opts, thread_pool_.get(), nullptr /* cluster_flr */);
162 if (thread_pool_ == nullptr) {
166 thread_pool_->Schedule(std::move(fn));
|
| /external/tensorflow/tensorflow/core/grappler/costs/ |
| measuring_cost_estimator.h | 70 std::unique_ptr<thread::ThreadPool> thread_pool_; member in class:tensorflow::grappler::MeasuringCostEstimator
|
| measuring_cost_estimator.cc | 40 thread_pool_.reset(new thread::ThreadPool(
128 thread_pool_->Schedule([i, &measurement_fn]() { measurement_fn(i); });
|
| /external/grpc-grpc/src/cpp/server/ |
| secure_server_credentials.h | 42 : thread_pool_(CreateDefaultThreadPool()), processor_(processor) {}
48 std::unique_ptr<ThreadPoolInterface> thread_pool_; member in class:grpc::final
|
| /art/runtime/jit/ |
| jit.cc | 299 if (thread_pool_ != nullptr) {
300 thread_pool_->WaitForWorkersToBeCreated();
307 if (thread_pool_ != nullptr) {
311 // Clear thread_pool_ field while the threads are suspended.
313 pool = std::move(thread_pool_);
702 thread_pool_.reset(new ThreadPool("Jit thread pool", 1, kJitPoolNeedsPeers));
704 thread_pool_->SetPthreadPriority(options_->GetThreadPoolPthreadPriority());
711 thread_pool_->AddTask(Thread::Current(), new ZygoteTask());
722 thread_pool_->AddTask(Thread::Current(), new JitProfileTask(dex_files, class_loader));
810 thread_pool_->AddTask(self
[all...] |
| jit.h | 292 return thread_pool_.get();
353 std::unique_ptr<ThreadPool> thread_pool_; member in class:art::jit::Jit
|
| /external/tensorflow/tensorflow/cc/training/ |
| coordinator_test.cc | 61 thread_pool_.reset(new thread::ThreadPool(Env::Default(), "test-pool", 10));
72 thread_pool_->Schedule(
78 thread_pool_->Schedule(std::bind(&MockQueueRunner::SetStatusThread, this,
86 thread_pool_.reset();
113 std::unique_ptr<thread::ThreadPool> thread_pool_; member in class:tensorflow::__anon44040::MockQueueRunner
|
| queue_runner.cc | 76 thread_pool_.reset(new thread::ThreadPool(
99 thread_pool_->Schedule(
103 thread_pool_->Schedule(std::bind(&QueueRunner::Stop, this, sess));
140 thread_pool_.reset();
|
| queue_runner.h | 119 std::unique_ptr<thread::ThreadPool> thread_pool_; member in class:tensorflow::QueueRunner
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| threadpool_dataset_op.cc | 33 : thread_pool_(env, thread_options, name, num_threads, low_latency_hint),
39 thread_pool_.Schedule(std::move(fn));
41 thread_pool_.Schedule(std::bind(
52 int32 NumThreads() { return thread_pool_.NumThreads(); }
57 thread::ThreadPool thread_pool_; member in class:tensorflow::data::__anon45294::ThreadPoolResource
355 thread_pool_ = absl::make_unique<thread::ThreadPool>(
408 thread::ThreadPool* pool = dataset()->thread_pool_.get();
431 std::unique_ptr<thread::ThreadPool> thread_pool_; member in class:tensorflow::data::__anon45294::PrivateThreadPoolDatasetOp::Dataset
|
| /external/grpc-grpc/src/cpp/client/ |
| secure_credentials.h | 78 std::unique_ptr<ThreadPoolInterface> thread_pool_; member in class:grpc::final
|
| /external/tensorflow/tensorflow/core/grappler/clusters/ |
| single_machine.cc | 45 thread_pool_.reset(new thread::ThreadPool(
68 thread_pool_.reset();
266 timeout_s * 1000, thread_pool_.get());
277 if (!session_ || !thread_pool_) {
309 use_timeout ? timeout_s_ * 1000 : -1, thread_pool_.get());
326 // never complete, and the call to thread_pool_.reset() will never return:
332 thread_pool_.reset();
362 thread_pool_.reset(new thread::ThreadPool(
|
| single_machine.h | 77 std::unique_ptr<thread::ThreadPool> thread_pool_; member in class:tensorflow::grappler::SingleMachine
|
| /external/tensorflow/tensorflow/core/kernels/ |
| mutex_ops.cc | 40 thread_pool_(new thread::ThreadPool(
131 thread_pool_->Schedule(std::bind(
162 std::unique_ptr<thread::ThreadPool> thread_pool_; member in class:tensorflow::__anon45433::Mutex
|
| reader_ops.cc | 51 thread_pool_(new thread::ThreadPool(
61 thread_pool_->Schedule([this, context, reader, done]() {
73 std::unique_ptr<thread::ThreadPool> thread_pool_; member in class:tensorflow::ReaderVerbAsyncOpKernel
|
| /external/tensorflow/tensorflow/compiler/jit/ |
| xla_device_context.h | 114 thread::ThreadPool* thread_pool_; member in class:tensorflow::XlaDeviceContext
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| context.cc | 61 thread_pool_(NewThreadPoolFromSessionOptions(opts)),
64 opts.config.graph_options().optimizer_options(), thread_pool_.get())),
81 this->thread_pool_->Schedule(std::move(closure));
446 {}, thread_pool_.get()));
479 {}, thread_pool_.get()));
|
| /external/tensorflow/tensorflow/contrib/bigtable/kernels/ |
| bigtable_kernels.cc | 183 thread_pool_(new thread::ThreadPool(
192 thread_pool_->Schedule([this, ctx, done]() {
352 std::unique_ptr<thread::ThreadPool> thread_pool_; member in class:tensorflow::data::__anon44693::ToBigtableOp
|
