OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:workQueue
(Results
1 - 20
of
20
) sorted by null
/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
16
#include "
WorkQueue
.h"
323
class PreProcessImageWorkUnit : public
WorkQueue
::WorkUnit {
351
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
Completed in 470 milliseconds