HomeSort by relevance Sort by last modified time
    Searched refs:LinkedBlockingQueue (Results 26 - 50 of 103) sorted by null

12 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

12 3 4 5