HomeSort by relevance Sort by last modified time
    Searched refs:LinkedBlockingQueue (Results 1 - 25 of 65) sorted by null

1 2 3

  /external/guava/guava/src/com/google/common/collect/
Queues.java 28 import java.util.concurrent.LinkedBlockingQueue;
87 // LinkedBlockingQueue
90 * Creates an empty {@code LinkedBlockingQueue} instance.
92 * @return a new, empty {@code LinkedBlockingQueue}
94 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() {
95 return new LinkedBlockingQueue<E>();
99 * Creates a {@code LinkedBlockingQueue} with the given (fixed) capacity.
102 * @return a new, empty {@code LinkedBlockingQueue}
105 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue(int capacity) {
106 return new LinkedBlockingQueue<E>(capacity)
    [all...]
  /frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/
AwaitableCompletionListener.java 22 import java.util.concurrent.LinkedBlockingQueue;
33 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>();
AwaitableErrorListener.java 22 import java.util.concurrent.LinkedBlockingQueue;
31 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>();
  /external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/
AbstractKernel.java 36 import java.util.concurrent.LinkedBlockingQueue;
67 private LinkedBlockingQueue<Envelope> envelopes = new LinkedBlockingQueue<Envelope>();
  /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/
SingleThreadNamedTaskExecutor.java 21 import java.util.concurrent.LinkedBlockingQueue;
32 private final LinkedBlockingQueue<NamedTask> mQueue;
37 mQueue = new LinkedBlockingQueue<NamedTask>();
  /frameworks/base/core/java/android/speech/tts/
AudioPlaybackHandler.java 21 import java.util.concurrent.LinkedBlockingQueue;
27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue =
28 new LinkedBlockingQueue<PlaybackQueueItem>();
  /frameworks/base/packages/DocumentsUI/src/com/android/documentsui/
ProviderExecutor.java 30 import java.util.concurrent.LinkedBlockingQueue;
54 private final LinkedBlockingQueue<Runnable> mQueue = new LinkedBlockingQueue<Runnable>();
  /cts/libs/vogar-expect/src/vogar/util/
Threads.java 20 import java.util.concurrent.LinkedBlockingQueue;
50 new LinkedBlockingQueue<Runnable>(Integer.MAX_VALUE), threadFactory) {
  /development/samples/WiFiDirectServiceDiscovery/src/com/example/android/wifidirect/discovery/
GroupOwnerSocketHandler.java 9 import java.util.concurrent.LinkedBlockingQueue;
42 new LinkedBlockingQueue<Runnable>());
  /external/mockwebserver/src/main/java/com/google/mockwebserver/
QueueDispatcher.java 20 import java.util.concurrent.LinkedBlockingQueue;
28 = new LinkedBlockingQueue<MockResponse>();
  /packages/apps/Mms/src/com/android/mms/util/
BackgroundLoaderManager.java 24 import java.util.concurrent.LinkedBlockingQueue;
70 final LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
  /development/samples/training/threadsample/src/com/example/android/threadsample/
PhotoManager.java 28 import java.util.concurrent.LinkedBlockingQueue;
130 mDownloadWorkQueue = new LinkedBlockingQueue<Runnable>();
136 mDecodeWorkQueue = new LinkedBlockingQueue<Runnable>();
142 mPhotoTaskWorkQueue = new LinkedBlockingQueue<PhotoTask>();
  /external/okhttp/src/main/java/com/squareup/okhttp/internal/http/
Dispatcher.java 27 import java.util.concurrent.LinkedBlockingQueue;
34 8, 8, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
  /packages/apps/Calendar/src/com/android/calendar/
EventLoader.java 30 import java.util.concurrent.LinkedBlockingQueue;
39 private LinkedBlockingQueue<LoadRequest> mLoaderQueue;
161 LinkedBlockingQueue<LoadRequest> mQueue;
164 public LoaderThread(LinkedBlockingQueue<LoadRequest> queue, EventLoader eventLoader) {
211 mLoaderQueue = new LinkedBlockingQueue<LoadRequest>();
  /frameworks/ex/camera2/public/src/com/android/ex/camera2/blocking/
BlockingStateListener.java 27 import java.util.concurrent.LinkedBlockingQueue;
52 private final LinkedBlockingQueue<Integer> mRecentStates =
53 new LinkedBlockingQueue<Integer>();
  /packages/apps/Email/emailsync/src/com/android/emailsync/
AbstractSyncService.java 31 import java.util.concurrent.LinkedBlockingQueue;
70 protected LinkedBlockingQueue<Request> mRequestQueue = new LinkedBlockingQueue<Request>();
  /packages/apps/UnifiedEmail/src/com/android/bitmap/
AltPooledCache.java 23 import java.util.concurrent.LinkedBlockingQueue;
45 private final LinkedBlockingQueue<V> mPool;
58 mPool = new LinkedBlockingQueue<V>();
  /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>();
  /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/spellcheck/
DictionaryPool.java 29 import java.util.concurrent.LinkedBlockingQueue;
39 public final class DictionaryPool extends LinkedBlockingQueue<DictAndKeyboard> {
  /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>();
  /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")
  /packages/apps/Email/tests/src/com/android/email/
ThrottleTest.java 29 import java.util.concurrent.LinkedBlockingQueue;
177 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 31 import java.util.concurrent.LinkedBlockingQueue;
113 new LinkedBlockingQueue<Runnable>() /* workQueue */);
  /libcore/luni/src/main/java/java/util/concurrent/
ExecutorCompletionService.java 112 * {@link LinkedBlockingQueue} as a completion queue.
123 this.completionQueue = new LinkedBlockingQueue<Future<V>>();

Completed in 2683 milliseconds

1 2 3