/libcore/luni/src/main/java/java/util/concurrent/ |
ForkJoinWorkerThread.java | 29 * This class just maintains links to its pool and WorkQueue. The 31 * workQueue field is not set until a call to registerWorker 33 * by requiring that the workQueue field is only accessed by the 38 final ForkJoinPool.WorkQueue workQueue; // work-stealing mechanics 50 this.workQueue = pool.registerWorker(this); 73 return workQueue.poolIndex >>> 1; // ignore odd/even tag bit 108 pool.runWorker(workQueue);
|
ThreadPoolExecutor.java | 405 * threads. We do not require that workQueue.poll() returning 406 * null necessarily means that workQueue.isEmpty(), so rely 414 private final BlockingQueue<Runnable> workQueue; 664 (runStateOf(c) == SHUTDOWN && ! workQueue.isEmpty())) 822 BlockingQueue<Runnable> q = workQueue; [all...] |
ForkJoinTask.java | 352 int s; Thread t; ForkJoinWorkerThread wt; ForkJoinPool.WorkQueue w; 355 (w = (wt = (ForkJoinWorkerThread)t).workQueue). 370 (wt = (ForkJoinWorkerThread)t).pool.awaitJoin(wt.workQueue, this) : 660 ((ForkJoinWorkerThread)t).workQueue.push(this); [all...] |
ForkJoinPool.java | 150 * class WorkQueue). These are special forms of Deques that 305 * field WorkQueue.nextWait. Queuing deals with several intrinsic 471 * fields of WorkQueue maintain data structures managed by 547 * in WorkQueue.tryRemoveAndExec. We don't need the proxy to 600 * do not want multiple WorkQueue instances or multiple queue 606 static final class WorkQueue { [all...] |
/frameworks/base/tools/aapt/ |
WorkQueue.h | 34 class WorkQueue { 50 WorkQueue(size_t maxThreads, bool canCallJava = true); 55 ~WorkQueue(); 91 WorkThread(WorkQueue* workQueue, bool canCallJava); 97 WorkQueue* const mWorkQueue;
|
WorkQueue.cpp | 18 #define LOG_TAG "WorkQueue" 21 #include "WorkQueue.h" 25 // --- WorkQueue --- 27 WorkQueue::WorkQueue(size_t maxThreads, bool canCallJava) : 32 WorkQueue::~WorkQueue() { 38 status_t WorkQueue::schedule(WorkUnit* workUnit, size_t backlog) { 48 status_t status = workThread->run("WorkQueue::WorkThread"); 68 status_t WorkQueue::cancel() [all...] |
Resource.cpp | 18 #include "WorkQueue.h" 332 class PreProcessImageWorkUnit : public WorkQueue::WorkUnit { 360 WorkQueue wq(MAX_THREADS, false); [all...] |
/cts/tests/tests/accessibilityservice/src/android/accessibilityservice/cts/ |
AccessibilityFocusAndInputFocusSyncTest.java | 213 Queue<AccessibilityNodeInfo> workQueue = new LinkedList<AccessibilityNodeInfo>(); 214 workQueue.add(root); 215 while (!workQueue.isEmpty()) { 216 AccessibilityNodeInfo current = workQueue.poll(); 224 workQueue.offer(child);
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
ThreadPoolExecutorSubclassTest.java | 126 BlockingQueue<Runnable> workQueue) { 128 workQueue); 134 BlockingQueue<Runnable> workQueue, 136 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, 144 BlockingQueue<Runnable> workQueue, 146 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, 153 BlockingQueue<Runnable> workQueue, 157 workQueue, threadFactory, handler); 746 * Constructor throws if workQueue is set to null 806 * Constructor throws if workQueue is set to nul [all...] |
/frameworks/base/services/core/java/com/android/server/display/ |
DisplayManagerService.java | 696 private void updateGlobalDisplayStateLocked(List<Runnable> workQueue) { 702 workQueue.add(runnable); [all...] |
/external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
org.eclipse.core.databinding.observable_1.3.0.I20100601-0800.jar | |
/prebuilts/sdk/10/ |
android.jar | |
/prebuilts/sdk/11/ |
android.jar | |
/prebuilts/sdk/13/ |
android.jar | |
/prebuilts/sdk/16/ |
android.jar | |
/prebuilts/sdk/20/ |
android.jar | |
/prebuilts/sdk/5/ |
android.jar | |
/prebuilts/sdk/7/ |
android.jar | |
/prebuilts/sdk/8/ |
android.jar | |
/prebuilts/sdk/9/ |
android.jar | |
/prebuilts/sdk/current/ |
android.jar | |
/prebuilts/sdk/system_current/ |
android.jar | |