| /build/kati/ |
| thread_pool.h | 22 class ThreadPool {
24 virtual ~ThreadPool() = default;
30 ThreadPool() = default;
33 ThreadPool* NewThreadPool(int num_threads);
|
| thread_pool.cc | 25 class ThreadPoolImpl : public ThreadPool {
88 ThreadPool* NewThreadPool(int num_threads) {
|
| /external/opencv3/3rdparty/openexr/IlmImf/ |
| ImfThreading.cpp | 50 return IlmThread::ThreadPool::globalThreadPool().numThreads();
57 IlmThread::ThreadPool::globalThreadPool().setNumThreads (count);
|
| /external/opencv3/3rdparty/openexr/IlmThread/ |
| IlmThreadPool.h | 40 // class Task, class ThreadPool, class TaskGroup
42 // Class ThreadPool manages a set of worker threads and accepts
47 // a ThreadPool works on. Derived classes need to implement the
51 // of tasks. Every task that is added to a ThreadPool belongs to a
55 // Note: if you plan to use the ThreadPool interface in your own
56 // applications note that the implementation of the ThreadPool calls
69 class ThreadPool
78 ThreadPool (unsigned numThreads = 0);
86 virtual ~ThreadPool ();
102 // Add a task for processing. The ThreadPool can handle an
[all...] |
| IlmThreadPool.cpp | 37 // class Task, class ThreadPool, class TaskGroup
57 WorkerThread (ThreadPool::Data* data);
63 ThreadPool::Data * _data;
82 struct ThreadPool::Data
112 WorkerThread::WorkerThread (ThreadPool::Data* data):
193 // held by the threadpool. Therefore it is safe to access
211 // struct ThreadPool::Data
214 ThreadPool::Data::Data (): numTasks (0), numThreads (0), stopping (false)
220 ThreadPool::Data::~Data()
228 ThreadPool::Data::finish (
[all...] |
| /external/llvm/lib/Support/ |
| ThreadPool.cpp | 1 //==-- llvm/Support/ThreadPool.cpp - A ThreadPool implementation -*- C++ -*-==//
14 #include "llvm/Support/ThreadPool.h"
24 ThreadPool::ThreadPool() : ThreadPool(std::thread::hardware_concurrency()) {}
26 ThreadPool::ThreadPool(unsigned ThreadCount)
63 // Adjust `ActiveThreads`, in case someone waits on ThreadPool::wait()
68 // Notify task completion, in case someone waits on ThreadPool::wait(
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/app/ |
| BatchService.java | 24 import com.android.gallery3d.util.ThreadPool;
35 private ThreadPool mThreadPool = new ThreadPool(1, 1);
42 // The threadpool returned by getThreadPool must have only 1 thread
45 public ThreadPool getThreadPool() {
|
| GalleryContext.java | 24 import com.android.gallery3d.util.ThreadPool;
33 public ThreadPool getThreadPool();
|
| GalleryApp.java | 27 import com.android.gallery3d.util.ThreadPool;
34 public ThreadPool getThreadPool();
|
| GalleryAppImpl.java | 30 import com.android.gallery3d.util.ThreadPool;
43 private ThreadPool mThreadPool;
83 public synchronized ThreadPool getThreadPool() {
85 mThreadPool = new ThreadPool();
|
| SlideshowDataAdapter.java | 28 import com.android.gallery3d.util.ThreadPool;
29 import com.android.gallery3d.util.ThreadPool.Job;
30 import com.android.gallery3d.util.ThreadPool.JobContext;
61 private final ThreadPool mThreadPool;
178 jc.setMode(ThreadPool.MODE_NONE);
|
| /external/jetty/src/java/org/eclipse/jetty/util/thread/ |
| ThreadPool.java | 24 /** ThreadPool.
28 public interface ThreadPool
60 public interface SizedThreadPool extends ThreadPool
|
| /external/skia/src/core/ |
| SkTaskGroup.cpp | 40 class ThreadPool : SkNoncopyable {
99 explicit ThreadPool(int threads) {
104 fThreads.push(new SkThread(&ThreadPool::Loop, this));
109 ~ThreadPool() {
148 ThreadPool* pool = (ThreadPool*)arg;
186 static ThreadPool* gGlobal;
190 ThreadPool* ThreadPool::gGlobal = nullptr;
195 SkASSERT(ThreadPool::gGlobal == nullptr)
[all...] |
| /frameworks/wilhelm/src/ |
| ThreadPool.h | 17 /** \file ThreadPool.h ThreadPool interface */
50 /** \brief ThreadPool manages a pool of worker threads that execute Closures */
84 } ThreadPool;
86 extern SLresult ThreadPool_init(ThreadPool *tp, unsigned maxClosures, unsigned maxThreads);
87 extern void ThreadPool_deinit(ThreadPool *tp);
88 extern SLresult ThreadPool_add(ThreadPool *tp, ClosureKind kind,
91 extern Closure *ThreadPool_remove(ThreadPool *tp);
92 extern SLresult ThreadPool_add_ppi(ThreadPool *tp, ClosureHandler_ppi handler,
94 extern SLresult ThreadPool_add_ppii(ThreadPool *tp, ClosureHandler_ppii handler
[all...] |
| ThreadPool.c | 17 /* ThreadPool */
25 ThreadPool *tp = (ThreadPool *) context;
81 static void ThreadPool_deinit_internal(ThreadPool *tp, unsigned initialized, unsigned nThreads);
83 // Initialize a ThreadPool
87 SLresult ThreadPool_init(ThreadPool *tp, unsigned maxClosures, unsigned maxThreads)
90 memset(tp, 0, sizeof(ThreadPool));
167 static void ThreadPool_deinit_internal(ThreadPool *tp, unsigned initialized, unsigned nThreads)
242 void ThreadPool_deinit(ThreadPool *tp)
250 SLresult ThreadPool_add(ThreadPool *tp, ClosureKind kind, ClosureHandler_generic handler
[all...] |
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| ThreadPool.java | 37 public class ThreadPool {
60 private ThreadPool(ExecutorService executor,
86 final static ThreadPool defaultThreadPool = createDefault();
90 static ThreadPool getDefault() {
95 static ThreadPool createDefault() {
110 return new ThreadPool(executor, false, initialSize);
114 static ThreadPool create(int nThreads, ThreadFactory factory) {
118 return new ThreadPool(executor, true, nThreads);
122 public static ThreadPool wrap(ExecutorService executor, int initialSize) {
141 return new ThreadPool(executor, false, initialSize)
[all...] |
| /art/runtime/ |
| thread_pool.h | 29 class ThreadPool;
66 ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name, size_t stack_size);
70 ThreadPool* const thread_pool_;
76 friend class ThreadPool;
80 class ThreadPool {
100 ThreadPool(const char* name, size_t num_threads);
101 virtual ~ThreadPool();
153 DISALLOW_COPY_AND_ASSIGN(ThreadPool);
|
| thread_pool.cc | 36 ThreadPoolWorker::ThreadPoolWorker(ThreadPool* thread_pool, const std::string& name,
94 void ThreadPool::AddTask(Thread* self, Task* task) {
103 void ThreadPool::RemoveAllTasks(Thread* self) {
108 ThreadPool::ThreadPool(const char* name, size_t num_threads)
132 void ThreadPool::SetMaxActiveWorkers(size_t threads) {
138 ThreadPool::~ThreadPool() {
152 void ThreadPool::StartWorkers(Thread* self) {
160 void ThreadPool::StopWorkers(Thread* self)
[all...] |
| thread_pool_test.cc | 63 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
78 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
103 TreeTask(ThreadPool* const thread_pool, AtomicInteger* count, int depth)
122 ThreadPool* const thread_pool_;
130 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
|
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| PanoramaMetadataJob.java | 24 import com.android.gallery3d.util.ThreadPool.Job;
25 import com.android.gallery3d.util.ThreadPool.JobContext;
|
| SnailItem.java | 23 import com.android.gallery3d.util.ThreadPool.Job;
24 import com.android.gallery3d.util.ThreadPool.JobContext;
|
| /external/llvm/include/llvm/Support/ |
| ThreadPool.h | 1 //===-- llvm/Support/ThreadPool.h - A ThreadPool implementation -*- C++ -*-===//
45 /// A ThreadPool for asynchronous parallel execution on a defined number of
50 class ThreadPool {
66 ThreadPool();
69 ThreadPool(unsigned ThreadCount);
72 ~ThreadPool();
|
| /libcore/luni/src/test/java/tests/support/ |
| ThreadPool.java | 22 public class ThreadPool extends ThreadGroup {
32 public ThreadPool(int numThreads) {
33 super("ThreadPool-" + (threadPoolID++));
93 super(ThreadPool.this, "PooledThread-" + (threadID++));
|
| /external/llvm/unittests/Support/ |
| ThreadPool.cpp | 10 #include "llvm/Support/ThreadPool.h"
93 ThreadPool Pool;
113 ThreadPool Pool;
123 ThreadPool Pool;
138 ThreadPool Pool;
157 ThreadPool Pool;
|
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| JobLimiter.java | 20 import com.android.gallery3d.util.ThreadPool.Job;
21 import com.android.gallery3d.util.ThreadPool.JobContext;
25 // Limit the number of concurrent jobs that has been submitted into a ThreadPool
38 private final ThreadPool mPool;
131 public JobLimiter(ThreadPool pool, int limit) {
|
