Searched refs:UnboundedThreadPool (Results 1 – 5 of 5) sorted by relevance
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | unbounded_thread_pool.cc | 27 class UnboundedThreadPool::LogicalThreadFactory : public ThreadFactory {
29 explicit LogicalThreadFactory(UnboundedThreadPool* pool) : pool_(pool) {} in LogicalThreadFactory()
37 UnboundedThreadPool* const pool_; // Not owned.
46 class UnboundedThreadPool::LogicalThreadWrapper : public Thread {
64 UnboundedThreadPool::~UnboundedThreadPool() { in ~UnboundedThreadPool()
90 std::shared_ptr<ThreadFactory> UnboundedThreadPool::get_thread_factory() { in get_thread_factory()
94 size_t UnboundedThreadPool::size() { in size()
99 std::unique_ptr<Thread> UnboundedThreadPool::RunOnPooledThread( in RunOnPooledThread()
120 std::bind(&UnboundedThreadPool::PooledThreadFunc, this)); in RunOnPooledThread()
129 void UnboundedThreadPool::PooledThreadFunc() { in PooledThreadFunc()
|
| D | unbounded_thread_pool_test.cc | 26 TEST(UnboundedThreadPool, SingleThread) { in TEST() argument
27 UnboundedThreadPool pool(Env::Default(), "test"); in TEST()
40 TEST(UnboundedThreadPool, MultipleThreads) { in TEST() argument
41 UnboundedThreadPool pool(Env::Default(), "test"); in TEST()
58 TEST(UnboundedThreadPool, MultipleThreadsSleepingRandomly) { in TEST() argument
59 UnboundedThreadPool pool(Env::Default(), "test"); in TEST()
79 TEST(UnboundedThreadPool, ConcurrentThreadCreation) { in TEST() argument
80 UnboundedThreadPool pool(Env::Default(), "test"); in TEST()
104 TEST(UnboundedThreadPool, MultipleBlockingThreads) { in TEST() argument
105 UnboundedThreadPool pool(Env::Default(), "test"); in TEST()
|
| D | unbounded_thread_pool.h | 39 class UnboundedThreadPool {
41 UnboundedThreadPool(Env* env, const string& thread_name) in UnboundedThreadPool() function
43 ~UnboundedThreadPool();
|
| D | multi_device_iterator_ops.cc | 352 UnboundedThreadPool unbounded_thread_pool_;
|
| D | iterator_ops.cc | 295 UnboundedThreadPool unbounded_thread_pool_;
|