| /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/tensorflow/tensorflow/core/lib/core/ |
| D | threadpool.cc | 88 struct ThreadPool::Impl : Eigen::ThreadPoolTempl<EigenEnvironment> {
106 ThreadPool::ThreadPool(Env* env, const string& name, int num_threads) in ThreadPool() function in tensorflow::thread::ThreadPool
107 : ThreadPool(env, ThreadOptions(), name, num_threads, true) {} in ThreadPool()
109 ThreadPool::ThreadPool(Env* env, const ThreadOptions& thread_options, in ThreadPool() function in tensorflow::thread::ThreadPool
111 : ThreadPool(env, thread_options, name, num_threads, true) {} in ThreadPool()
113 ThreadPool::ThreadPool(Env* env, const ThreadOptions& thread_options, in ThreadPool() function in tensorflow::thread::ThreadPool
117 impl_.reset(new ThreadPool::Impl(env, thread_options, "tf_" + name, in ThreadPool()
121 ThreadPool::~ThreadPool() {} in ~ThreadPool()
123 void ThreadPool::Schedule(std::function<void()> fn) { in Schedule()
128 void ThreadPool::ParallelFor(int64 total, int64 cost_per_unit, in ParallelFor()
[all …]
|
| D | threadpool_test.cc | 30 TEST(ThreadPool, Empty) { in TEST() argument
33 ThreadPool pool(Env::Default(), "test", num_threads); in TEST()
37 TEST(ThreadPool, DoWork) { in TEST() argument
46 ThreadPool pool(Env::Default(), "test", num_threads); in TEST()
60 TEST(ThreadPool, ParallelFor) { in TEST() argument
67 ThreadPool pool(Env::Default(), "test", num_threads); in TEST()
83 TEST(ThreadPool, ParallelForWithWorkerId) { in TEST() argument
90 ThreadPool pool(Env::Default(), "test", num_threads); in TEST()
123 ThreadPool pool(Env::Default(), "test", kNumThreads); in BM_Sequential()
148 ThreadPool pool(Env::Default(), "test", kNumThreads); in BM_Parallel()
|
| D | threadpool.h | 28 class ThreadPool {
39 ThreadPool(Env* env, const ThreadOptions& thread_options, const string& name,
46 ThreadPool(Env* env, const string& name, int num_threads);
52 ThreadPool(Env* env, const ThreadOptions& thread_options, const string& name,
57 ~ThreadPool();
105 TF_DISALLOW_COPY_AND_ASSIGN(ThreadPool);
|
| 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/libxcam/xcore/ |
| D | thread_pool.cpp | 32 UserThread (const SmartPtr<ThreadPool> &pool, const char *name) in UserThread()
43 SmartPtr<ThreadPool> _pool;
70 SmartPtr<ThreadPool::UserData> data = _pool->_data_queue.pop (); in loop()
92 ThreadPool::dispatch (const SmartPtr<ThreadPool::UserData> &data) in dispatch()
102 ThreadPool::ThreadPool (const char *name) in ThreadPool() function in XCam::ThreadPool
114 ThreadPool::~ThreadPool () in ~ThreadPool()
122 ThreadPool::set_threads (uint32_t min, uint32_t max) in set_threads()
142 ThreadPool::is_running () in is_running()
149 ThreadPool::start () in start()
173 ThreadPool::stop () in stop()
[all …]
|
| D | thread_pool.h | 32 class ThreadPool
50 explicit ThreadPool (const char *name);
51 virtual ~ThreadPool ();
67 XCAM_DEAD_COPY (ThreadPool);
|
| /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/tensorflow/tensorflow/core/common_runtime/ |
| D | process_util.cc | 30 static thread::ThreadPool* InitComputePool(const SessionOptions& options) { in InitComputePool()
38 return new thread::ThreadPool(Env::Default(), "Compute", in InitComputePool()
44 thread::ThreadPool* ComputePool(const SessionOptions& options) { in ComputePool()
45 static thread::ThreadPool* compute_pool = InitComputePool(options); in ComputePool()
|
| D | eigen_thread_pool.h | 26 explicit EigenThreadPoolWrapper(thread::ThreadPool* pool) : pool_(pool) {} in EigenThreadPoolWrapper()
36 thread::ThreadPool* pool_ = nullptr;
|
| /external/tensorflow/tensorflow/compiler/xla/ |
| D | executable_run_options.h | 32 class ThreadPool; variable
70 tensorflow::thread::ThreadPool* inter_op_thread_pool);
71 tensorflow::thread::ThreadPool* inter_op_thread_pool() const;
92 tensorflow::thread::ThreadPool* inter_op_thread_pool_ = nullptr;
|
| /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 | 31 thread::ThreadPool* threads) { in RunSharding()
55 thread::ThreadPool threads(Env::Default(), "test", 16); in TEST()
66 thread::ThreadPool threads(Env::Default(), "test", 3); in TEST()
80 thread::ThreadPool threads(Env::Default(), "test", 16); in BM_Sharding()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | device_base.h | 54 class ThreadPool; variable
111 thread::ThreadPool* workers = nullptr;
150 virtual thread::ThreadPool* tensorflow_device_thread_pool() { in tensorflow_device_thread_pool()
226 void set_tensorflow_device_thread_pool(thread::ThreadPool* thread_pool) { in set_tensorflow_device_thread_pool()
234 thread::ThreadPool* device_thread_pool_ = nullptr;
|
| /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/icu/icu4c/source/test/intltest/ |
| D | simplethread.h | 65 class ThreadPool : public ThreadPoolBase {
69 ThreadPool(TestClass *test, int howMany, void (TestClass::*runFnPtr)(int32_t threadNumber)) : in ThreadPool() function
71 virtual ~ThreadPool() {}; in ~ThreadPool()
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | service_executable_run_options.h | 38 tensorflow::thread::ThreadPool* xla_intra_op_thread_pool = nullptr)
62 tensorflow::thread::ThreadPool* xla_intra_op_thread_pool() const { in xla_intra_op_thread_pool()
69 tensorflow::thread::ThreadPool* xla_intra_op_thread_pool_;
|
| D | backend.cc | 67 : pool(new tensorflow::thread::ThreadPool(tensorflow::Env::Default(), in EigenThreadPoolWrapper()
73 std::unique_ptr<tensorflow::thread::ThreadPool> pool;
145 inter_op_thread_pool_.reset(new tensorflow::thread::ThreadPool( in Backend()
162 tensorflow::thread::ThreadPool* Backend::inter_op_thread_pool() const { in inter_op_thread_pool()
174 tensorflow::thread::ThreadPool* Backend::eigen_intra_op_thread_pool() const { in eigen_intra_op_thread_pool()
|
| /external/libxcam/modules/soft/ |
| D | soft_worker.h | 31 class ThreadPool; variable
67 bool set_threads (const SmartPtr<ThreadPool> &threads);
93 SmartPtr<ThreadPool> _threads;
|
| D | soft_handler.h | 32 class ThreadPool; variable
59 bool set_threads (const SmartPtr<ThreadPool> &pool);
87 SmartPtr<ThreadPool> _threads;
|
| /external/tensorflow/tensorflow/contrib/boosted_trees/lib/learner/common/partitioners/ |
| D | example_partitioner.h | 36 thread::ThreadPool* const thread_pool,
45 thread::ThreadPool* const thread_pool,
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_env.h | 25 class ThreadPool; variable
61 thread::ThreadPool* compute_pool = nullptr;
|
| /external/tensorflow/tensorflow/contrib/lite/kernels/internal/optimized/ |
| D | multithreaded_conv.h | 40 explicit EigenThreadPoolWrapper(Eigen::ThreadPool* pool) : pool_(pool) {} in EigenThreadPoolWrapper()
50 Eigen::ThreadPool* pool_ = nullptr;
59 static Eigen::ThreadPool* tp = new Eigen::ThreadPool(thread_count); in GetThreadPoolDevice()
|