| /build/kati/ |
| thread_pool.cc | 31 threads_.reserve(num_threads);
33 threads_.push_back(thread([this]() { Loop(); }));
52 for (thread& th : threads_) {
81 vector<thread> threads_; member in class:ThreadPoolImpl
|
| /system/extras/memory_replay/ |
| Threads.h | 43 Thread* threads_ = nullptr; member in class:Threads
|
| /toolchain/binutils/binutils-2.27/gold/ |
| workqueue-internal.h | 104 int threads_; member in class:gold::Workqueue_threader_threadpool
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| SimpleThreadPool.h | 25 : env_(env), threads_(num_threads), waiters_(num_threads) {
27 threads_.push_back(env.CreateThread([this, i]() { WorkerLoop(i); }));
51 for (auto t : threads_) {
73 return static_cast<int>(threads_.size());
138 MaxSizeVector<Thread*> threads_; // All threads member in class:Eigen::SimpleThreadPoolTempl
|
| NonBlockingThreadPool.h | 24 threads_(num_threads),
58 threads_.push_back(env_.CreateThread([this, i]() { WorkerLoop(i); }));
70 for (size_t i = 0; i < threads_.size(); i++) delete threads_[i];
71 for (size_t i = 0; i < threads_.size(); i++) delete queues_[i];
101 return static_cast<int>(threads_.size());
125 MaxSizeVector<Thread*> threads_; member in class:Eigen::NonBlockingThreadPoolTempl
211 if (done_ && blocked_ == threads_.size()) {
|
| /external/google-breakpad/src/client/linux/minidump_writer/ |
| linux_dumper.h | 86 // Read information about the |index|-th thread of |threads_|.
91 const wasteful_vector<pid_t> &threads() { return threads_; }
178 wasteful_vector<pid_t> threads_; member in class:google_breakpad::LinuxDumper
|
| /external/libchrome/base/threading/ |
| simple_thread.h | 189 std::vector<DelegateSimpleThread*> threads_; member in class:base::DelegateSimpleThreadPool
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_worker_cache.cc | 45 threads_(kGrpcWorkerCacheThreadCount),
50 threads_.clear(); // Blocks until threads exit.
65 channel, threads_[AssignWorkerToThread(target)].completion_queue(),
125 target, (next_round_robin_assignment_++) % threads_.size()))
135 std::vector<GrpcWorkerCacheThread> threads_; member in class:tensorflow::__anon39542::GrpcWorkerCache
|
| grpc_worker_service.cc | 62 threads_.emplace_back(
78 for (auto& worker_thread : threads_) {
110 for (auto& worker_thread : threads_) {
113 for (auto& worker_thread : threads_) {
347 std::vector<std::unique_ptr<GrpcWorkerServiceThread>> threads_; member in class:tensorflow::__anon39543::GrpcWorkerService
|
| /art/runtime/ |
| thread_pool.h | 88 return threads_.size();
92 return threads_;
162 std::vector<ThreadPoolWorker*> threads_; member in class:art::ThreadPool
|
| /external/libvpx/libvpx/test/ |
| encode_perf_test.cc | 62 encoding_mode_(GET_PARAM(1)), speed_(0), threads_(1) {}
82 cfg_.g_threads = threads_;
114 void set_threads(unsigned int threads) { threads_ = threads; }
121 unsigned int threads_; member in class:__anon26019::VP9EncodePerfTest
|
| vp9_ethread_test.cc | 227 tiles_(GET_PARAM(3)), threads_(GET_PARAM(4)),
309 int threads_; member in class:__anon26065::VPxEncoderThreadTest
334 cfg_.g_threads = threads_;
368 cfg_.g_threads = threads_;
386 cfg_.g_threads = threads_;
|
| /system/core/libmemunreachable/tests/ |
| ThreadCapture_test.cpp | 55 threads_.reserve(threads);
58 threads_.emplace_back([&, threads, this]() {
89 for (auto i = threads_.begin(); i != threads_.end(); i++) {
92 threads_.clear();
121 std::vector<std::thread> threads_; member in class:android::ThreadListTest
|
| /system/extras/iotop/ |
| taskstats.h | 44 int threads() const { return threads_; }
77 int threads_; member in class:TaskStatistics
|
| /external/compiler-rt/lib/sanitizer_common/ |
| sanitizer_thread_registry.h | 93 return threads_[tid];
136 ThreadContextBase **threads_; // Array of thread contexts is leaked. member in class:__sanitizer::ThreadRegistry
|
| /external/google-breakpad/src/google_breakpad/processor/ |
| process_state.h | 106 const vector<CallStack*>* threads() const { return &threads_; }
165 vector<CallStack*> threads_; member in class:google_breakpad::ProcessState
|
| minidump.h | 355 MinidumpThreads* threads_; member in class:google_breakpad::MinidumpThreadList
[all...] |
| /external/tensorflow/tensorflow/core/framework/ |
| rendezvous_test.cc | 68 LocalRendezvousTest() : threads_(Env::Default(), "test", 16) {
75 threads_.Schedule(std::move(fn));
81 thread::ThreadPool threads_; member in class:tensorflow::__anon39590::LocalRendezvousTest
166 // We are scheduling 2*N closures in the this->threads_, which is
|
| /system/extras/simpleperf/ |
| event_selection_set.h | 112 threads_.insert(threads.begin(), threads.end());
117 const std::set<pid_t>& GetMonitoredThreads() const { return threads_; }
120 return !processes_.empty() || !threads_.empty();
176 std::set<pid_t> threads_; member in class:EventSelectionSet
|
| inplace_sampler_lib.cpp | 89 std::map<int, ThreadInfo> threads_; member in class:__anon3021::SampleManager
235 auto it = threads_.find(tid);
236 if (it == threads_.end() || it->second.name != pair.second) {
237 threads_[tid].name = pair.second;
252 for (auto it = threads_.begin(); it != threads_.end();) {
255 it = threads_.erase(it);
|
| record_lib_interface.cpp | 80 threads_.insert(gettid());
93 threads_.insert(threads.begin(), threads.end());
102 std::set<pid_t> threads_; member in class:simpleperf::PerfEventSetImpl
146 if (threads_.empty()) {
150 set->AddMonitoredThreads(threads_);
|
| /external/v8/src/wasm/ |
| wasm-interpreter.cc | 1825 ZoneVector<ThreadImpl> threads_; member in class:v8::internal::wasm::WasmInterpreterInternals
[all...] |
