Searched refs:m_tasks (Results 1 – 3 of 3) sorted by relevance
34 m_tasks.emplace([task](){ (*task)(); }); in AddTask()59 if (pool->m_tasks.empty()) in Worker()60 … pool->m_tasks_cv.wait(lock, [pool](){ return !pool->m_tasks.empty() || pool->m_stop; }); in Worker()61 if (pool->m_tasks.empty()) in Worker()64 std::function<void()> f = pool->m_tasks.front(); in Worker()65 pool->m_tasks.pop(); in Worker()72 std::queue<std::function<void()>> m_tasks; member in TaskPoolImpl
38 m_tasks = new ArrayList (); in emmaTask()48 while (! m_tasks.isEmpty ()) in execute()50 final NestedTask task = (NestedTask) m_tasks.remove (0); in execute()90 m_tasks.add (task); in addTask()114 private final List /* NestedTask */ m_tasks; field in emmaTask
72 : m_tasks(tasks) in TaskExecutorThread()81 Task* const task = m_tasks.popBack(); in run()91 TaskQueue& m_tasks; member in vkt::__anon5c239db60111::TaskExecutorThread107 TaskQueue m_tasks; member in vkt::__anon5c239db60111::TaskExecutor112 , m_tasks (m_threads.size() * 1024u) in TaskExecutor()115 m_threads[ndx] = ExecThreadSp(new TaskExecutorThread(m_tasks)); in TaskExecutor()121 m_tasks.pushFront(DE_NULL); in ~TaskExecutor()130 m_tasks.pushFront(task); in submit()