| /external/libgav1/libgav1/src/utils/ |
| D | threadpool.cc | 70 std::unique_ptr<ThreadPool> ThreadPool::Create(int num_threads) { in Create()
75 std::unique_ptr<ThreadPool> ThreadPool::Create(const char name_prefix[], in Create()
81 std::unique_ptr<ThreadPool> pool(new (std::nothrow) ThreadPool( in Create()
89 ThreadPool::ThreadPool(const char name_prefix[], in ThreadPool() function in libgav1::ThreadPool
101 ThreadPool::~ThreadPool() { Shutdown(); } in ~ThreadPool()
103 void ThreadPool::Schedule(std::function<void()> closure) { in Schedule()
116 int ThreadPool::num_threads() const { return num_threads_; } in num_threads()
121 class ThreadPool::WorkerThread : public Allocable {
124 explicit WorkerThread(ThreadPool* pool);
149 ThreadPool* pool_;
[all …]
|
| D | threadpool.h | 69 class ThreadPool : public Executor, public Allocable {
73 static std::unique_ptr<ThreadPool> Create(int num_threads);
76 static std::unique_ptr<ThreadPool> Create(const char name_prefix[],
81 ~ThreadPool() override;
102 ThreadPool(const char name_prefix[], std::unique_ptr<WorkerThread*[]> threads,
|
| /external/llvm/lib/Support/ |
| D | ThreadPool.cpp | 24 ThreadPool::ThreadPool() : ThreadPool(std::thread::hardware_concurrency()) {} in ThreadPool() function in ThreadPool
26 ThreadPool::ThreadPool(unsigned ThreadCount) in ThreadPool() function in ThreadPool
75 void ThreadPool::wait() { in wait()
85 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
103 ThreadPool::~ThreadPool() { in ~ThreadPool()
115 ThreadPool::ThreadPool() : ThreadPool(0) {} in ThreadPool() function in ThreadPool
118 ThreadPool::ThreadPool(unsigned ThreadCount) in ThreadPool() function in ThreadPool
126 void ThreadPool::wait() { in wait()
139 std::shared_future<ThreadPool::VoidTy> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
154 ThreadPool::~ThreadPool() { in ~ThreadPool()
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
| D | ThreadPool.cpp | 24 ThreadPool::ThreadPool() : ThreadPool(hardware_concurrency()) {} in ThreadPool() function in ThreadPool
26 ThreadPool::ThreadPool(unsigned ThreadCount) in ThreadPool() function in ThreadPool
71 void ThreadPool::wait() { in wait()
81 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
99 ThreadPool::~ThreadPool() { in ~ThreadPool()
111 ThreadPool::ThreadPool() : ThreadPool(0) {} in ThreadPool() function in ThreadPool
114 ThreadPool::ThreadPool(unsigned ThreadCount) in ThreadPool() function in ThreadPool
122 void ThreadPool::wait() { in wait()
131 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
141 ThreadPool::~ThreadPool() { in ~ThreadPool()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/executor/ |
| D | threadpool.cc | 50 void ThreadPool::SharedThreadPoolConstructor() { in SharedThreadPoolConstructor()
66 size_t ThreadPool::DefaultStackSize() { in DefaultStackSize()
74 void ThreadPool::AssertHasNotBeenShutDown() { in AssertHasNotBeenShutDown()
79 ThreadPool::ThreadPool(int num_threads) : num_threads_(num_threads) { in ThreadPool() function in grpc_core::ThreadPool
86 ThreadPool::ThreadPool(int num_threads, const char* thd_name) in ThreadPool() function in grpc_core::ThreadPool
93 ThreadPool::ThreadPool(int num_threads, const char* thd_name, in ThreadPool() function in grpc_core::ThreadPool
104 ThreadPool::~ThreadPool() { in ~ThreadPool()
123 void ThreadPool::Add(grpc_experimental_completion_queue_functor* closure) { in Add()
128 int ThreadPool::num_pending_closures() const { return queue_->count(); } in num_pending_closures()
130 int ThreadPool::pool_capacity() const { return num_threads_; } in pool_capacity()
[all …]
|
| D | threadpool.h | 97 class ThreadPool : public ThreadPoolInterface {
102 explicit ThreadPool(int num_threads);
106 ThreadPool(int num_threads, const char* thd_name);
115 ThreadPool(int num_threads, const char* thd_name,
119 ~ThreadPool() override;
|
| /external/tensorflow/tensorflow/core/platform/ |
| D | threadpool.cc | 89 ThreadPool::ThreadPool(Env* env, const string& name, int num_threads) in ThreadPool() function in tensorflow::thread::ThreadPool
90 : ThreadPool(env, ThreadOptions(), name, num_threads, true, nullptr) {} in ThreadPool()
92 ThreadPool::ThreadPool(Env* env, const ThreadOptions& thread_options, in ThreadPool() function in tensorflow::thread::ThreadPool
94 : ThreadPool(env, thread_options, name, num_threads, true, nullptr) {} in ThreadPool()
96 ThreadPool::ThreadPool(Env* env, const ThreadOptions& thread_options, in ThreadPool() function in tensorflow::thread::ThreadPool
108 ThreadPool::ThreadPool(thread::ThreadPoolInterface* user_threadpool) { in ThreadPool() function in tensorflow::thread::ThreadPool
114 ThreadPool::~ThreadPool() {} in ~ThreadPool()
116 void ThreadPool::Schedule(std::function<void()> fn) { in Schedule()
121 int ThreadPool::NumShardsUsedByFixedBlockSizeScheduling( in NumShardsUsedByFixedBlockSizeScheduling()
130 int ThreadPool::NumShardsUsedByTransformRangeConcurrently( in NumShardsUsedByTransformRangeConcurrently()
[all …]
|
| D | threadpool.h | 42 class ThreadPool {
111 ThreadPool(Env* env, const ThreadOptions& thread_options,
119 ThreadPool(Env* env, const std::string& name, int num_threads);
125 ThreadPool(Env* env, const ThreadOptions& thread_options,
132 explicit ThreadPool(thread::ThreadPoolInterface* user_threadpool);
136 ~ThreadPool();
237 TF_DISALLOW_COPY_AND_ASSIGN(ThreadPool);
|
| /external/llvm-project/llvm/lib/Support/ |
| D | ThreadPool.cpp | 23 ThreadPool::ThreadPool(ThreadPoolStrategy S) in ThreadPool() function in ThreadPool
69 void ThreadPool::wait() { in wait()
75 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
93 ThreadPool::~ThreadPool() { in ~ThreadPool()
106 ThreadPool::ThreadPool(ThreadPoolStrategy S) in ThreadPool() function in ThreadPool
114 void ThreadPool::wait() { in wait()
123 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
133 ThreadPool::~ThreadPool() { wait(); } in ~ThreadPool()
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| D | threadpool_test.cc | 34 TEST(ThreadPool, Empty) { in TEST() argument
37 ThreadPool pool(Env::Default(), "test", num_threads); in TEST()
41 TEST(ThreadPool, DoWork) { in TEST() argument
51 ThreadPool pool(Env::Default(), "test", num_threads); in TEST()
66 void RunWithFixedBlockSize(int64 block_size, int64 total, ThreadPool* threads) { in RunWithFixedBlockSize()
76 ThreadPool::SchedulingParams( in RunWithFixedBlockSize()
77 ThreadPool::SchedulingStrategy::kFixedBlockSize /* strategy */, in RunWithFixedBlockSize()
107 ThreadPool threads(Env::Default(), "test", 16); in TEST()
118 ThreadPool* threads) { in RunWithFixedBlockSizeTransformRangeConcurrently()
156 ThreadPool threads(Env::Default(), "test", 16); in TEST()
[all …]
|
| D | notification_test.cc | 27 thread::ThreadPool* thread_pool = in TEST()
28 new thread::ThreadPool(Env::Default(), "test", 1); in TEST()
56 thread::ThreadPool* thread_pool = in TEST()
57 new thread::ThreadPool(Env::Default(), "test", num_closures); in TEST()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | thread_pool.h | 33 class ThreadPool {
35 explicit ThreadPool(int num_threads) { in ThreadPool() function
37 threads_.push_back(std::thread(&ThreadPool::WorkLoop, this)); in ThreadPool()
41 ThreadPool(const ThreadPool &) = delete;
42 ThreadPool &operator=(const ThreadPool &) = delete;
44 ~ThreadPool() { in ~ThreadPool()
73 mu_.Await(absl::Condition(this, &ThreadPool::WorkAvailable)); in WorkLoop()
|
| /external/abseil-cpp/absl/synchronization/internal/ |
| D | thread_pool.h | 33 class ThreadPool {
35 explicit ThreadPool(int num_threads) { in ThreadPool() function
37 threads_.push_back(std::thread(&ThreadPool::WorkLoop, this)); in ThreadPool()
41 ThreadPool(const ThreadPool &) = delete;
42 ThreadPool &operator=(const ThreadPool &) = delete;
44 ~ThreadPool() { in ~ThreadPool()
73 mu_.Await(absl::Condition(this, &ThreadPool::WorkAvailable)); in WorkLoop()
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | thread_pool.h | 33 class ThreadPool {
35 explicit ThreadPool(int num_threads) { in ThreadPool() function
37 threads_.push_back(std::thread(&ThreadPool::WorkLoop, this)); in ThreadPool()
41 ThreadPool(const ThreadPool &) = delete;
42 ThreadPool &operator=(const ThreadPool &) = delete;
44 ~ThreadPool() { in ~ThreadPool()
73 mu_.Await(absl::Condition(this, &ThreadPool::WorkAvailable)); in WorkLoop()
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/internal/ |
| D | thread_pool.h | 33 class ThreadPool {
35 explicit ThreadPool(int num_threads) { in ThreadPool() function
37 threads_.push_back(std::thread(&ThreadPool::WorkLoop, this)); in ThreadPool()
41 ThreadPool(const ThreadPool &) = delete;
42 ThreadPool &operator=(const ThreadPool &) = delete;
44 ~ThreadPool() { in ~ThreadPool()
73 mu_.Await(absl::Condition(this, &ThreadPool::WorkAvailable)); in WorkLoop()
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/internal/ |
| D | thread_pool.h | 33 class ThreadPool {
35 explicit ThreadPool(int num_threads) { in ThreadPool() function
37 threads_.push_back(std::thread(&ThreadPool::WorkLoop, this)); in ThreadPool()
41 ThreadPool(const ThreadPool &) = delete;
42 ThreadPool &operator=(const ThreadPool &) = delete;
44 ~ThreadPool() { in ~ThreadPool()
73 mu_.Await(absl::Condition(this, &ThreadPool::WorkAvailable)); in WorkLoop()
|
| /external/eigen/unsupported/Eigen/CXX11/ |
| D | ThreadPool | 17 /** \defgroup CXX11_ThreadPool_Module C++11 ThreadPool Module
26 * #include <Eigen/CXX11/ThreadPool>
51 #include "src/ThreadPool/ThreadLocal.h"
52 #include "src/ThreadPool/ThreadYield.h"
53 #include "src/ThreadPool/EventCount.h"
54 #include "src/ThreadPool/RunQueue.h"
55 #include "src/ThreadPool/ThreadPoolInterface.h"
56 #include "src/ThreadPool/ThreadEnvironment.h"
57 #include "src/ThreadPool/SimpleThreadPool.h"
58 #include "src/ThreadPool/NonBlockingThreadPool.h"
|
| /external/libgav1/libgav1/src/ |
| D | threading_strategy.h | 65 ThreadPool* tile_thread_pool() const { in tile_thread_pool()
74 ThreadPool* thread_pool() const { return thread_pool_.get(); } in thread_pool()
79 ThreadPool* row_thread_pool(int tile_index) const { in row_thread_pool()
87 ThreadPool* post_filter_thread_pool() const { in post_filter_thread_pool()
94 ThreadPool* film_grain_thread_pool() const { return thread_pool_.get(); } in film_grain_thread_pool()
97 std::unique_ptr<ThreadPool> thread_pool_;
126 std::unique_ptr<ThreadPool>* frame_thread_pool,
|
| /external/zstd/contrib/pzstd/utils/test/ |
| D | ThreadPoolTest.cpp | 19 TEST(ThreadPool, Ordering) { in TEST() argument
23 ThreadPool executor(1); in TEST()
34 TEST(ThreadPool, AllJobsFinished) { in TEST() argument
39 ThreadPool executor(5); in TEST()
55 TEST(ThreadPool, AddJobWhileJoining) { in TEST() argument
58 ThreadPool executor(1); in TEST()
|
| /external/ruy/ruy/ |
| D | thread_pool.h | 55 class ThreadPool {
57 ThreadPool() {} in ThreadPool() function
59 ~ThreadPool();
99 ThreadPool(const ThreadPool&) = delete;
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | mod.rs | 22 pub(crate) struct ThreadPool { struct
45 impl ThreadPool { impl
46 pub(crate) fn new(size: usize, parker: Parker) -> (ThreadPool, Launch) { in new() argument
49 let thread_pool = ThreadPool { spawner }; in new()
75 impl fmt::Debug for ThreadPool { implementation
81 impl Drop for ThreadPool { implementation
|
| /external/rust/crates/futures-executor/src/ |
| D | thread_pool.rs | 28 pub struct ThreadPool { struct
46 impl AssertSendSync for ThreadPool {} implementation
55 impl fmt::Debug for ThreadPool { implementation
77 impl ThreadPool { implementation
134 impl Spawn for ThreadPool { implementation
170 impl Clone for ThreadPool { implementation
177 impl Drop for ThreadPool { implementation
266 pub fn create(&mut self) -> Result<ThreadPool, io::Error> { in create() argument
268 let pool = ThreadPool { in create()
303 exec: ThreadPool,
[all …]
|
| /external/rust/crates/rayon-core/src/thread_pool/ |
| D | mod.rs | 51 pub struct ThreadPool { struct
55 impl ThreadPool { argument
59 pub fn new(configuration: Configuration) -> Result<ThreadPool, Box<dyn Error>> { in new() argument
65 ) -> Result<ThreadPool, ThreadPoolBuildError> in build() argument
70 Ok(ThreadPool { registry }) in build()
257 impl Drop for ThreadPool { implementation
263 impl fmt::Debug for ThreadPool { implementation
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | process_util.cc | 74 static thread::ThreadPool* InitComputePool(const SessionOptions& options) { in InitComputePool()
80 return new thread::ThreadPool( in InitComputePool()
88 thread::ThreadPool* ComputePool(const SessionOptions& options) { in ComputePool()
89 static thread::ThreadPool* compute_pool = InitComputePool(options); in ComputePool()
156 thread::ThreadPool* NewThreadPoolFromSessionOptions( in NewThreadPoolFromSessionOptions()
160 return new thread::ThreadPool( in NewThreadPoolFromSessionOptions()
|
| /external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| D | ThreadPool.h | 36 class ThreadPool {
43 ThreadPool();
46 ThreadPool(unsigned ThreadCount);
49 ~ThreadPool();
|