| /external/libgav1/libgav1/src/utils/ |
| D | threadpool.cc | 66 std::unique_ptr<ThreadPool> ThreadPool::Create(int num_threads) { in Create()
71 std::unique_ptr<ThreadPool> ThreadPool::Create(const char name_prefix[], in Create()
77 std::unique_ptr<ThreadPool> pool(new (std::nothrow) ThreadPool( in Create()
85 ThreadPool::ThreadPool(const char name_prefix[], in ThreadPool() function in libgav1::ThreadPool
97 ThreadPool::~ThreadPool() { Shutdown(); } in ~ThreadPool()
99 void ThreadPool::Schedule(std::function<void()> closure) { in Schedule()
112 int ThreadPool::num_threads() const { return num_threads_; } in num_threads()
117 class ThreadPool::WorkerThread : public Allocable {
120 explicit WorkerThread(ThreadPool* pool);
145 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-7.0/llvm/lib/Support/ |
| D | ThreadPool.cpp | 25 ThreadPool::ThreadPool() : ThreadPool(hardware_concurrency()) {} in ThreadPool() function in ThreadPool
27 ThreadPool::ThreadPool(unsigned ThreadCount) in ThreadPool() function in ThreadPool
72 void ThreadPool::wait() { in wait()
82 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
100 ThreadPool::~ThreadPool() { in ~ThreadPool()
112 ThreadPool::ThreadPool() : ThreadPool(0) {} in ThreadPool() function in ThreadPool
115 ThreadPool::ThreadPool(unsigned ThreadCount) in ThreadPool() function in ThreadPool
123 void ThreadPool::wait() { in wait()
132 std::shared_future<void> ThreadPool::asyncImpl(TaskTy Task) { in asyncImpl()
142 ThreadPool::~ThreadPool() { in ~ThreadPool()
|
| /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, const string& name,
119 ThreadPool(Env* env, const string& name, int num_threads);
125 ThreadPool(Env* env, const ThreadOptions& thread_options, const string& name,
132 explicit ThreadPool(thread::ThreadPoolInterface* user_threadpool);
136 ~ThreadPool();
237 TF_DISALLOW_COPY_AND_ASSIGN(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()
|
| D | blocking_counter_test.cc | 38 thread::ThreadPool* thread_pool = in TEST()
39 new thread::ThreadPool(Env::Default(), "test", N); in TEST()
55 std::unique_ptr<thread::ThreadPool> thread_pool( in BM_BlockingCounter()
56 new thread::ThreadPool(Env::Default(), "test", num_threads)); in BM_BlockingCounter()
|
| /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,
|
| D | threading_strategy.cc | 85 thread_pool_ = ThreadPool::Create("libgav1", thread_count); in Reset()
163 thread_pool_ = ThreadPool::Create("libgav1-fp", thread_count); in Reset()
175 std::unique_ptr<ThreadPool>* const frame_thread_pool, in InitializeThreadPoolsForFrameParallel()
182 *frame_thread_pool = ThreadPool::Create(frame_threads); in InitializeThreadPoolsForFrameParallel()
|
| /external/tensorflow/tensorflow/lite/experimental/ruy/ |
| D | thread_pool.h | 54 class ThreadPool {
56 ThreadPool() {} in ThreadPool() function
58 ~ThreadPool();
90 ThreadPool(const ThreadPool&) = delete;
|
| D | thread_pool.cc | 156 void ThreadPool::ExecuteImpl(int task_count, int stride, Task* tasks) { in ExecuteImpl()
183 void ThreadPool::CreateThreads(int threads_count) { in CreateThreads()
194 ThreadPool::~ThreadPool() { in ~ThreadPool()
|
| /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()
157 thread::ThreadPool* NewThreadPoolFromSessionOptions( in NewThreadPoolFromSessionOptions()
161 return new thread::ThreadPool( in NewThreadPoolFromSessionOptions()
|
| D | single_threaded_cpu_device.cc | 33 thread::ThreadPool* GraphRunnerThreadPool() { in GraphRunnerThreadPool()
34 static thread::ThreadPool* thread_pool = in GraphRunnerThreadPool()
35 new thread::ThreadPool(Env::Default(), "graph_runner", kNumThreads); in GraphRunnerThreadPool()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/include/llvm/Support/ |
| D | ThreadPool.h | 37 class ThreadPool {
44 ThreadPool();
47 ThreadPool(unsigned ThreadCount);
50 ~ThreadPool();
|
| /external/swiftshader/third_party/llvm-7.0/llvm/unittests/Support/ |
| D | ThreadPool.cpp | 91 ThreadPool Pool; in TEST_F()
111 ThreadPool Pool; in TEST_F()
121 ThreadPool Pool; in TEST_F()
136 ThreadPool Pool{2}; in TEST_F()
155 ThreadPool Pool; in TEST_F()
|
| /external/llvm/include/llvm/Support/ |
| D | ThreadPool.h | 51 class ThreadPool {
67 ThreadPool();
70 ThreadPool(unsigned ThreadCount);
73 ~ThreadPool();
|
| /external/llvm/unittests/Support/ |
| D | ThreadPool.cpp | 93 ThreadPool Pool; in TEST_F()
113 ThreadPool Pool; in TEST_F()
123 ThreadPool Pool; in TEST_F()
138 ThreadPool Pool{2}; in TEST_F()
157 ThreadPool Pool; in TEST_F()
|
| /external/tensorflow/tensorflow/core/util/ |
| D | work_sharder_test.cc | 32 thread::ThreadPool* threads) { in RunSharding()
65 thread::ThreadPool threads(Env::Default(), "test", 16); in TEST()
79 thread::ThreadPool threads(Env::Default(), "test", 3); in TEST()
93 thread::ThreadPool threads(Env::Default(), "test", 16); in BM_Sharding()
|
| D | debug_events_writer_test.cc | 101 thread::ThreadPool* thread_pool = in TEST_F()
102 new thread::ThreadPool(Env::Default(), "test_pool", 4); in TEST_F()
126 thread::ThreadPool* thread_pool = in TEST_F()
127 new thread::ThreadPool(Env::Default(), "test_pool", 3); in TEST_F()
203 thread::ThreadPool* thread_pool = in TEST_F()
204 new thread::ThreadPool(Env::Default(), "test_pool", 4); in TEST_F()
423 thread::ThreadPool* thread_pool = in TEST_F()
424 new thread::ThreadPool(Env::Default(), "test_pool", 8); in TEST_F()
464 thread::ThreadPool* thread_pool = in TEST_F()
465 new thread::ThreadPool(Env::Default(), "test_pool", 8); in TEST_F()
[all …]
|
| /external/icu/icu4c/source/test/intltest/ |
| D | simplethread.h | 74 class ThreadPool : public ThreadPoolBase {
78 ThreadPool(TestClass *test, int howMany, void (TestClass::*runFnPtr)(int32_t threadNumber)) : in ThreadPool() function
80 virtual ~ThreadPool() {} in ~ThreadPool()
|
| /external/eigen/unsupported/test/ |
| D | cxx11_tensor_thread_pool.cpp | 29 Eigen::ThreadPool tp(internal::random<int>(3, 11)); in test_multithread_elementwise()
52 Eigen::ThreadPool tp(internal::random<int>(3, 11)); in test_multithread_compound_assignment()
85 Eigen::ThreadPool tp(4); in test_multithread_contraction()
126 Eigen::ThreadPool tp(12); in test_contraction_corner_cases()
216 Eigen::ThreadPool tp(internal::random<int>(2, 11)); in test_multithread_contraction_agrees_with_singlethread()
255 Eigen::ThreadPool tp(internal::random<int>(2, 11)); in test_full_contraction()
275 ThreadPool thread_pool(num_threads); in test_multithreaded_reductions()
299 Eigen::ThreadPool tp(num_threads); in test_memcpy()
316 Eigen::ThreadPool tp(2); in test_multithread_random()
329 ThreadPool threads(num_threads); in test_multithread_shuffle()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | device_base.h | 56 class ThreadPool; variable
130 thread::ThreadPool* workers = nullptr;
171 virtual thread::ThreadPool* tensorflow_device_thread_pool() { in tensorflow_device_thread_pool()
281 void set_tensorflow_device_thread_pool(thread::ThreadPool* thread_pool) { in set_tensorflow_device_thread_pool()
290 thread::ThreadPool* device_thread_pool_ = nullptr;
|