Searched refs:UnboundedThreadPool (Results 1 – 7 of 7) sorted by relevance
34 class UnboundedThreadPool::LogicalThreadWrapper : public Thread {53 class UnboundedThreadPool::LogicalThreadFactory : public ThreadFactory {55 explicit LogicalThreadFactory(UnboundedThreadPool* pool) : pool_(pool) {} in LogicalThreadFactory()65 UnboundedThreadPool* const pool_; // Not owned.68 std::shared_ptr<ThreadFactory> UnboundedThreadPool::get_thread_factory() { in get_thread_factory()72 void UnboundedThreadPool::Schedule(std::function<void()> fn) { in Schedule()80 int UnboundedThreadPool::NumThreads() const { return -1; } in NumThreads()82 int UnboundedThreadPool::CurrentThreadId() const { return -1; } in CurrentThreadId()94 void UnboundedThreadPool::ScheduleOnWorkQueue( in ScheduleOnWorkQueue()
35 class UnboundedThreadPool : public thread::ThreadPoolInterface {37 UnboundedThreadPool(Env* env, const string& thread_name) in UnboundedThreadPool() function39 UnboundedThreadPool(Env* env, const string& thread_name, in UnboundedThreadPool() function42 ~UnboundedThreadPool() override = default;
26 TEST(UnboundedThreadPool, ConcurrentThreadCreation) { in TEST() argument27 UnboundedThreadPool pool(Env::Default(), "test"); in TEST()51 TEST(UnboundedThreadPool, MultipleBlockingThreads) { in TEST() argument52 UnboundedThreadPool pool(Env::Default(), "test"); in TEST()
130 UnboundedThreadPool unbounded_thread_pool_;
138 UnboundedThreadPool unbounded_thread_pool_;
458 UnboundedThreadPool unbounded_thread_pool_;
696 UnboundedThreadPool unbounded_threadpool_;