OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:LinkedBlockingQueue
(Results
26 - 50
of
103
) sorted by null
1
2
3
4
5
/cts/tests/tests/mediastress/src/android/mediastress/cts/
NativeMediaActivity.java
30
import java.util.concurrent.
LinkedBlockingQueue
;
56
private final BlockingQueue<Boolean> mNativeWaitQ = new
LinkedBlockingQueue
<Boolean>();
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
OkHttpAsync.java
27
import java.util.concurrent.
LinkedBlockingQueue
;
53
benchmark.concurrencyLevel, 60, TimeUnit.SECONDS, new
LinkedBlockingQueue
<Runnable>())));
/packages/apps/Camera2/src/com/android/camera/widget/
Preloader.java
10
import java.util.concurrent.
LinkedBlockingQueue
;
67
private Queue<List<Y>> mItemLoadTokens = new
LinkedBlockingQueue
<List<Y>>();
/cts/hostsidetests/devicepolicy/app/LauncherTestsSupport/src/com/android/cts/launchertests/support/
LauncherCallbackTestsService.java
36
import java.util.concurrent.
LinkedBlockingQueue
;
64
= new
LinkedBlockingQueue
();
66
= new
LinkedBlockingQueue
();
68
= new
LinkedBlockingQueue
();
/external/jmonkeyengine/engine/src/desktop/com/jme3/app/state/
VideoRecorderAppState.java
114
private
LinkedBlockingQueue
<WorkItem> freeItems;
115
private
LinkedBlockingQueue
<WorkItem> usedItems = new
LinkedBlockingQueue
<WorkItem>();
153
freeItems = new
LinkedBlockingQueue
<WorkItem>();
/cts/tests/tests/hardware/src/android/hardware/cts/helpers/sensoroperations/
ParallelSensorOperation.java
30
import java.util.concurrent.
LinkedBlockingQueue
;
91
new
LinkedBlockingQueue
<Runnable>());
/external/guava/guava-testlib/src/com/google/common/collect/testing/
TestsForQueuesInJavaUtil.java
33
import java.util.concurrent.
LinkedBlockingQueue
;
134
return new
LinkedBlockingQueue
<String>(
138
.named("
LinkedBlockingQueue
")
/external/jetty/src/java/org/eclipse/jetty/server/
LocalConnector.java
24
import java.util.concurrent.
LinkedBlockingQueue
;
37
private final BlockingQueue<Request> _requests = new
LinkedBlockingQueue
<Request>();
AsyncNCSARequestLog.java
27
import java.util.concurrent.
LinkedBlockingQueue
;
/packages/apps/Camera2/src/com/android/camera/async/
ConcurrentBufferQueue.java
23
import java.util.concurrent.
LinkedBlockingQueue
;
96
mQueue = new
LinkedBlockingQueue
<>();
/packages/apps/Email/tests/src/com/android/email/
ThrottleTest.java
30
import java.util.concurrent.
LinkedBlockingQueue
;
179
private final BlockingQueue<Entry> mTasks = new
LinkedBlockingQueue
<Entry>();
/packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/
ThreadPool.java
22
import java.util.concurrent.
LinkedBlockingQueue
;
90
TimeUnit.SECONDS, new
LinkedBlockingQueue
<Runnable>(),
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/dictionarypack/
DictionaryService.java
34
import java.util.concurrent.
LinkedBlockingQueue
;
130
new
LinkedBlockingQueue
<Runnable>() /* workQueue */);
/frameworks/av/media/libstagefright/webm/
WebmFrameThread.cpp
58
LinkedBlockingQueue
<const sp<WebmFrame> >& sink)
81
LinkedBlockingQueue
<const sp<WebmFrame> >& videoSource,
82
LinkedBlockingQueue
<const sp<WebmFrame> >& audioSource,
251
LinkedBlockingQueue
<const sp<WebmFrame> >& sink,
WebmWriter.h
22
#include "
LinkedBlockingQueue
.h"
91
LinkedBlockingQueue
<const sp<WebmFrame> > mSink;
/libcore/luni/src/main/java/java/util/concurrent/
ExecutorCompletionService.java
112
* {@link
LinkedBlockingQueue
} as a completion queue.
123
this.completionQueue = new
LinkedBlockingQueue
<Future<V>>();
Executors.java
64
new
LinkedBlockingQueue
<Runnable>());
127
new
LinkedBlockingQueue
<Runnable>(),
148
new
LinkedBlockingQueue
<Runnable>()));
169
new
LinkedBlockingQueue
<Runnable>(),
LinkedBlockingQueue.java
48
public class
LinkedBlockingQueue
<E> extends AbstractQueue<E>
214
* Creates a {@code
LinkedBlockingQueue
} with a capacity of
217
public
LinkedBlockingQueue
() {
222
* Creates a {@code
LinkedBlockingQueue
} with the given (fixed) capacity.
228
public
LinkedBlockingQueue
(int capacity) {
235
* Creates a {@code
LinkedBlockingQueue
} with a capacity of
244
public
LinkedBlockingQueue
(Collection<? extends E> c) {
/cts/apps/CtsVerifier/src/com/android/cts/verifier/security/
CAInstallNotificationVerifierActivity.java
40
import java.util.concurrent.
LinkedBlockingQueue
;
49
private static
LinkedBlockingQueue
<String> sDeletedQueue = new
LinkedBlockingQueue
<String>();
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/decoder/
MediaDecoder.java
31
import java.util.concurrent.
LinkedBlockingQueue
;
89
private final
LinkedBlockingQueue
<Integer> mEventQueue;
139
mEventQueue = new
LinkedBlockingQueue
<Integer>(MAX_EVENTS);
/frameworks/opt/bitmap/src/com/android/bitmap/
UnrefedPooledCache.java
26
import java.util.concurrent.
LinkedBlockingQueue
;
47
private final
LinkedBlockingQueue
<V> mPool;
61
mPool = new
LinkedBlockingQueue
<V>();
/external/guava/guava-tests/test/com/google/common/collect/
QueuesTest.java
30
import java.util.concurrent.
LinkedBlockingQueue
;
48
new
LinkedBlockingQueue
<Object>(),
49
new
LinkedBlockingQueue
<Object>(10),
/developers/build/prebuilts/gradle/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/
AsyncTask.java
32
import java.util.concurrent.
LinkedBlockingQueue
;
213
new
LinkedBlockingQueue
<Runnable>(10);
/developers/samples/android/ui/graphics/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/
AsyncTask.java
32
import java.util.concurrent.
LinkedBlockingQueue
;
213
new
LinkedBlockingQueue
<Runnable>(10);
/development/samples/browseable/DisplayingBitmaps/src/com.example.android.displayingbitmaps/util/
AsyncTask.java
32
import java.util.concurrent.
LinkedBlockingQueue
;
213
new
LinkedBlockingQueue
<Runnable>(10);
Completed in 880 milliseconds
1
2
3
4
5