| /third_party/boost/boost/thread/executors/ |
| D | thread_executor.hpp | 41 threads_type threads_; member in boost::executors::thread_executor
120 threads_.reserve(threads_.size() + 1); in submit()
122 threads_.push_back(thread_t(boost::move(th))); in submit()
129 threads_.reserve(threads_.size() + 1); in submit()
131 threads_.push_back(thread_t(boost::move(th))); in submit()
139 threads_.reserve(threads_.size() + 1); in submit()
141 threads_.push_back(thread_t(boost::move(th))); in submit()
|
| /third_party/grpc/src/core/lib/iomgr/executor/ |
| D | threadpool.cc | 58 threads_ = static_cast<ThreadPoolWorker**>( in SharedThreadPoolConstructor()
61 threads_[i] = new ThreadPoolWorker(thd_name_, queue_, thread_options_, i); in SharedThreadPoolConstructor()
62 threads_[i]->Start(); in SharedThreadPoolConstructor()
113 threads_[i]->Join(); in ~ThreadPool()
117 delete threads_[i]; in ~ThreadPool()
119 gpr_free(threads_); in ~ThreadPool()
|
| /third_party/benchmark/src/ |
| D | benchmark_api_internal.cc | 29 threads_(thread_count) { in BenchmarkInstance()
79 name_.threads = StrFormat("threads:%d", threads_); in BenchmarkInstance()
90 State st(iters, args_, thread_id, threads_, timer, manager, in Run()
98 State st(/*iters*/ 1, args_, /*thread_id*/ 0, threads_, nullptr, nullptr, in Setup()
106 State st(/*iters*/ 1, args_, /*thread_id*/ 0, threads_, nullptr, nullptr, in Teardown()
|
| D | benchmark_api_internal.h | 40 int threads() const { return threads_; } in threads()
66 int threads_; // Number of concurrent threads to us variable
|
| /third_party/boost/libs/iostreams/src/ |
| D | lzma.cpp | 85 : stream_(new lzma_stream), level_(lzma::default_compression), threads_(1) in lzma_base()
134 threads_ = p.threads; in do_init()
137 if (threads_ == 0) { in do_init()
138 threads_ = lzma_cputhreads(); in do_init()
152 const lzma_mt opt = { 0, threads_, 0, 1000, level_, NULL, LZMA_CHECK_CRC32 }; in init_stream()
|
| /third_party/abseil-cpp/absl/synchronization/internal/ |
| D | thread_pool.h | 37 threads_.push_back(std::thread(&ThreadPool::WorkLoop, this)); in ThreadPool()
47 for (size_t i = 0; i < threads_.size(); i++) { in ~ThreadPool()
51 for (auto &t : threads_) { in ~ThreadPool()
86 std::vector<std::thread> threads_; variable
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/internal/ |
| D | thread_pool.h | 37 threads_.push_back(std::thread(&ThreadPool::WorkLoop, this)); in ThreadPool()
47 for (size_t i = 0; i < threads_.size(); i++) { in ~ThreadPool()
51 for (auto &t : threads_) { in ~ThreadPool()
86 std::vector<std::thread> threads_; variable
|
| /third_party/boost/libs/beast/test/extras/include/boost/beast/test/ |
| D | yield_to.hpp | 41 std::vector<std::thread> threads_; member in boost::beast::test::enable_yield_to
56 threads_.reserve(concurrency); in enable_yield_to()
58 threads_.emplace_back( in enable_yield_to()
65 for(auto& t : threads_) in ~enable_yield_to()
|
| /third_party/gn/src/util/ |
| D | worker_pool.cc | 93 threads_.reserve(thread_count); in WorkerPool()
95 threads_.emplace_back([this]() { Worker(); }); in WorkerPool()
102 processor_group_setter.SetProcessorGroup(&threads_.back()); in WorkerPool()
115 for (auto& task_thread : threads_) { in ~WorkerPool()
|
| D | worker_pool.h | 27 std::vector<std::thread> threads_; variable
|
| /third_party/grpc/test/cpp/qps/ |
| D | client.h | 163 std::vector<Histogram> to_merge(threads_.size()); in Mark()
164 std::vector<StatusHistogram> to_merge_status(threads_.size()); in Mark()
166 for (size_t i = 0; i < threads_.size(); i++) { in Mark()
167 threads_[i]->BeginSwap(&to_merge[i], &to_merge_status[i]); in Mark()
171 for (size_t i = 0; i < threads_.size(); i++) { in Mark()
179 for (size_t i = 0; i < threads_.size(); i++) { in Mark()
180 threads_[i]->MergeStatsInto(&latencies, &statuses); in Mark()
190 threads_[0]->GetMedianPerIntervalList(); in Mark()
191 gpr_log(GPR_INFO, "Num threads: %ld", threads_.size()); in Mark()
341 threads_.emplace_back(new Thread(this, i)); in StartThreads()
[all …]
|
| /third_party/boost/boost/asio/impl/ |
| D | thread_pool.ipp | 69 threads_.create_threads(f, static_cast<std::size_t>(num_threads_));
95 threads_.create_threads(f, static_cast<std::size_t>(num_threads_));
118 if (!threads_.empty())
121 threads_.join();
135 threads_.join();
|
| D | system_context.ipp | 56 threads_.create_threads(f, num_threads_);
63 threads_.join();
79 threads_.join();
|
| /third_party/boost/libs/asio/include/boost/asio/impl/ |
| D | thread_pool.ipp | 69 threads_.create_threads(f, static_cast<std::size_t>(num_threads_));
95 threads_.create_threads(f, static_cast<std::size_t>(num_threads_));
118 if (!threads_.empty())
121 threads_.join();
135 threads_.join();
|
| D | system_context.ipp | 56 threads_.create_threads(f, num_threads_);
63 threads_.join();
79 threads_.join();
|
| /third_party/protobuf/src/google/protobuf/ |
| D | arena.cc | 74 threads_.store(nullptr, std::memory_order_relaxed); in Init()
84 threads_.store(serial, std::memory_order_relaxed); in Init()
213 SerialArena* serial = threads_.load(std::memory_order_acquire); in SpaceUsed()
237 SerialArena* serial = threads_.load(std::memory_order_relaxed); in FreeBlocks()
283 SerialArena* serial = threads_.load(std::memory_order_relaxed); in CleanupList()
337 SerialArena* serial = threads_.load(std::memory_order_acquire); in GetSerialArenaFallback()
350 SerialArena* head = threads_.load(std::memory_order_relaxed); in GetSerialArenaFallback()
353 } while (!threads_.compare_exchange_weak( in GetSerialArenaFallback()
|
| /third_party/boost/libs/asio/example/cpp14/executors/ |
| D | fork_join.cpp | 27 threads_(thread_count) in fork_join_pool()
36 threads_.executor(), in fork_join_pool()
49 threads_.wait(); in fork_join_pool()
58 threads_.wait(); in ~fork_join_pool()
153 static_thread_pool threads_; member in fork_join_pool
|
| D | pipeline.cpp | 30 threads_.push_back(std::move(t)); in add_thread()
37 for (auto& t : threads_) in ~thread_bag()
42 std::vector<std::thread> threads_; member in thread_executor::thread_bag
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/executors/ |
| D | fork_join.cpp | 27 threads_(thread_count) in fork_join_pool()
36 threads_.executor(), in fork_join_pool()
49 threads_.wait(); in fork_join_pool()
58 threads_.wait(); in ~fork_join_pool()
153 static_thread_pool threads_; member in fork_join_pool
|
| D | pipeline.cpp | 44 threads_.push_back(std::move(t)); in add_thread()
50 for (auto& t : threads_) in shutdown()
55 std::vector<std::thread> threads_; member in thread_executor::thread_bag
|
| /third_party/boost/libs/asio/example/cpp11/executors/ |
| D | fork_join.cpp | 27 threads_(thread_count) in fork_join_pool()
36 threads_.executor(), in fork_join_pool()
49 threads_.wait(); in fork_join_pool()
58 threads_.wait(); in ~fork_join_pool()
153 static_thread_pool threads_; member in fork_join_pool
|
| D | pipeline.cpp | 44 threads_.push_back(std::move(t)); in add_thread()
50 for (auto& t : threads_) in shutdown()
55 std::vector<std::thread> threads_; member in thread_executor::thread_bag
|
| /third_party/flutter/engine/flutter/shell/platform/fuchsia/flutter/ |
| D | engine.cc | 62 for (auto& thread : threads_) { in Engine()
151 CreateFMLTaskRunner(threads_[0]->dispatcher()), // gpu in Engine()
152 CreateFMLTaskRunner(threads_[1]->dispatcher()), // ui in Engine()
153 CreateFMLTaskRunner(threads_[2]->dispatcher()) // io in Engine()
288 for (const auto& thread : threads_) { in ~Engine()
291 for (const auto& thread : threads_) { in ~Engine()
|
| /third_party/mindspore/mindspore/lite/src/runtime/kernel/arm/fp32_grad/ |
| D | sparse_softmax_cross_entropy_with_logits.cc | 95 int stride = UP_DIV(outter_size_, threads_); in Execute()
152 threads_ = threads.at(stage); in Run()
153 …r_code = ParallelLaunch(this->ms_context_, SparseSoftmaxCrossEntropyWithLogitsRun, this, threads_); in Run()
|
| /third_party/node/src/ |
| D | node_platform.cc | 175 threads_.push_back(delayed_task_scheduler_->Start()); in WorkerThreadsTaskRunner()
187 threads_.push_back(std::move(t)); in WorkerThreadsTaskRunner()
213 for (size_t i = 0; i < threads_.size(); i++) { in Shutdown()
214 CHECK_EQ(0, uv_thread_join(threads_[i].get())); in Shutdown()
219 return threads_.size(); in NumberOfWorkerThreads()
|