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

1 2

  /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>();
  /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/spellcheck/
DictionaryPool.java 20 import java.util.concurrent.LinkedBlockingQueue;
26 public class DictionaryPool extends LinkedBlockingQueue<DictAndProximity> {
  /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>();
  /cts/libs/vogar-expect/src/vogar/util/
Threads.java 20 import java.util.concurrent.LinkedBlockingQueue;
50 new LinkedBlockingQueue<Runnable>(Integer.MAX_VALUE), threadFactory) {
  /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>();
  /packages/apps/Email/tests/src/com/android/email/
ThrottleTest.java 26 import java.util.concurrent.LinkedBlockingQueue;
174 private final BlockingQueue<Entry> mTasks = new LinkedBlockingQueue<Entry>();
  /packages/apps/Gallery2/src/com/android/gallery3d/util/
ThreadPool.java 20 import java.util.concurrent.LinkedBlockingQueue;
83 TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
  /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 62 new LinkedBlockingQueue<Runnable>());
87 new LinkedBlockingQueue<Runnable>(),
108 new LinkedBlockingQueue<Runnable>()));
129 new LinkedBlockingQueue<Runnable>(),
LinkedBlockingQueue.java 49 public class LinkedBlockingQueue<E> extends AbstractQueue<E>
215 * Creates a {@code LinkedBlockingQueue} with a capacity of
218 public LinkedBlockingQueue() {
223 * Creates a {@code LinkedBlockingQueue} with the given (fixed) capacity.
229 public LinkedBlockingQueue(int capacity) {
236 * Creates a {@code LinkedBlockingQueue} with a capacity of
245 public LinkedBlockingQueue(Collection<? extends E> c) {
  /packages/apps/Exchange/src/com/android/exchange/
AbstractSyncService.java 32 import java.util.concurrent.LinkedBlockingQueue;
74 protected LinkedBlockingQueue<Request> mRequestQueue = new LinkedBlockingQueue<Request>();
  /frameworks/base/core/tests/utillib/src/coretestutils/http/
MockWebServer.java 40 import java.util.concurrent.LinkedBlockingQueue;
57 = new LinkedBlockingQueue<RecordedRequest>();
59 = new LinkedBlockingQueue<MockResponse>();
  /packages/providers/DownloadProvider/tests/src/tests/http/
MockWebServer.java 42 import java.util.concurrent.LinkedBlockingQueue;
56 = new LinkedBlockingQueue<RecordedRequest>();
58 = new LinkedBlockingQueue<MockResponse>();
  /frameworks/base/core/java/android/os/
AsyncTask.java 26 import java.util.concurrent.LinkedBlockingQueue;
172 new LinkedBlockingQueue<Runnable>(10);
  /frameworks/base/keystore/java/android/security/
KeyChain.java 40 import java.util.concurrent.LinkedBlockingQueue;
411 final BlockingQueue<IKeyChainService> q = new LinkedBlockingQueue<IKeyChainService>(1);
  /frameworks/support/v4/java/android/support/v4/content/
ModernAsyncTask.java 25 import java.util.concurrent.LinkedBlockingQueue;
63 new LinkedBlockingQueue<Runnable>(10);
  /packages/apps/Email/tests/src/com/android/email/activity/
ContactStatusLoaderTest.java 35 import java.util.concurrent.LinkedBlockingQueue;
190 public final Queue<Cursor> mCursors = new LinkedBlockingQueue<Cursor>();
  /frameworks/base/services/java/com/android/server/
NativeDaemonConnector.java 32 import java.util.concurrent.LinkedBlockingQueue;
77 mResponseQueue = new LinkedBlockingQueue<String>(responseQueueSize);
  /packages/apps/Browser/src/com/android/browser/
DataController.java 38 import java.util.concurrent.LinkedBlockingQueue;
135 = new LinkedBlockingQueue<DCMessage>();
  /external/mockwebserver/src/main/java/com/google/mockwebserver/
MockWebServer.java 46 import java.util.concurrent.LinkedBlockingQueue;
63 = new LinkedBlockingQueue<RecordedRequest>();
  /libcore/support/src/test/java/tests/http/
MockWebServer.java 45 import java.util.concurrent.LinkedBlockingQueue;
66 = new LinkedBlockingQueue<RecordedRequest>();
  /libcore/luni/src/main/java/libcore/io/
DiskLruCache.java 43 import java.util.concurrent.LinkedBlockingQueue;
154 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
  /packages/apps/VideoEditor/src/com/android/videoeditor/
VideoEditorActivity.java 22 import java.util.concurrent.LinkedBlockingQueue;
    [all...]
  /packages/apps/Email/src/com/android/email/
MessagingController.java 70 import java.util.concurrent.LinkedBlockingQueue;
129 private final BlockingQueue<Command> mCommands = new LinkedBlockingQueue<Command>();
    [all...]

Completed in 1633 milliseconds

1 2