| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| ConnectionPool.java | 27 import java.util.concurrent.LinkedBlockingQueue;
93 new LinkedBlockingQueue<Runnable>(), Util.threadFactory("OkHttp ConnectionPool", true));
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| WebSocketRecorder.java | 23 import java.util.concurrent.LinkedBlockingQueue;
39 private final BlockingQueue<Object> events = new LinkedBlockingQueue<>();
|
| /frameworks/base/core/java/android/os/ |
| AsyncTask.java | 29 import java.util.concurrent.LinkedBlockingQueue;
197 new LinkedBlockingQueue<Runnable>(128);
|
| /frameworks/support/v4/java/android/support/v4/content/ |
| ModernAsyncTask.java | 25 import java.util.concurrent.LinkedBlockingQueue;
64 new LinkedBlockingQueue<Runnable>(10);
|
| /packages/apps/Nfc/src/com/android/nfc/echoserver/ |
| EchoServer.java | 32 import java.util.concurrent.LinkedBlockingQueue;
115 dataQueue = new LinkedBlockingQueue<byte[]>(QUEUE_SIZE);
|
| /packages/apps/UnifiedEmail/src/com/android/mail/bitmap/ |
| ContactResolver.java | 41 import java.util.concurrent.LinkedBlockingQueue;
68 1, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
|
| /cts/tests/tests/hardware/src/android/hardware/camera2/cts/ |
| CameraManagerTest.java | 46 import java.util.concurrent.LinkedBlockingQueue;
483 final LinkedBlockingQueue<String> availableEventQueue = new LinkedBlockingQueue<>();
484 final LinkedBlockingQueue<String> unavailableEventQueue = new LinkedBlockingQueue<>();
|
| CameraTestUtils.java | 79 import java.util.concurrent.LinkedBlockingQueue;
269 private final LinkedBlockingQueue<Image> mQueue =
270 new LinkedBlockingQueue<Image>();
378 private final LinkedBlockingQueue<TotalCaptureResult> mQueue =
379 new LinkedBlockingQueue<TotalCaptureResult>();
380 private final LinkedBlockingQueue<CaptureFailure> mFailureQueue =
381 new LinkedBlockingQueue<>();
383 private final LinkedBlockingQueue<Pair<CaptureRequest, Long>> mCaptureStartQueue =
384 new LinkedBlockingQueue<>();
[all...] |
| PerformanceTest.java | 55 import java.util.concurrent.LinkedBlockingQueue;
[all...] |
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/notifications/ |
| InteractiveVerifierActivity.java | 43 import java.util.concurrent.LinkedBlockingQueue;
50 private static LinkedBlockingQueue<String> sDeletedQueue = new LinkedBlockingQueue<String>();
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/ |
| MockSpdyPeer.java | 32 import java.util.concurrent.LinkedBlockingQueue;
46 private final BlockingQueue<InFrame> inFrames = new LinkedBlockingQueue<>();
|
| /frameworks/base/keystore/java/android/security/ |
| KeyChain.java | 48 import java.util.concurrent.LinkedBlockingQueue;
532 final BlockingQueue<IKeyChainService> q = new LinkedBlockingQueue<IKeyChainService>(1);
|
| /frameworks/opt/bitmap/src/com/android/bitmap/drawable/ |
| BasicBitmapDrawable.java | 42 import java.util.concurrent.LinkedBlockingQueue;
85 new LinkedBlockingQueue<Runnable>(128), new NamedThreadFactory("decode"));
|
| /packages/apps/Browser/src/com/android/browser/ |
| DataController.java | 38 import java.util.concurrent.LinkedBlockingQueue;
135 = new LinkedBlockingQueue<DCMessage>();
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| GraphRunner.java | 24 import java.util.concurrent.LinkedBlockingQueue;
117 private LinkedBlockingQueue<Event> mEventQueue = new LinkedBlockingQueue<Event>();
[all...] |
| /packages/services/Telecomm/src/com/android/server/telecom/ |
| Log.java | 38 import java.util.concurrent.LinkedBlockingQueue;
216 private static final LinkedBlockingQueue<CallEventRecord> mCallEventRecords =
217 new LinkedBlockingQueue<CallEventRecord>(MAX_CALLS_TO_CACHE);
|
| /external/google-tv-pairing-protocol/java/src/com/google/polo/pairing/ |
| PairingSession.java | 42 import java.util.concurrent.LinkedBlockingQueue;
207 mMessageQueue = new LinkedBlockingQueue<QueueMessage>();
|
| /libcore/support/src/test/java/tests/http/ |
| MockWebServer.java | 46 import java.util.concurrent.LinkedBlockingQueue;
67 = new LinkedBlockingQueue<RecordedRequest>();
|
| /packages/providers/DownloadProvider/src/com/android/providers/downloads/ |
| DownloadService.java | 64 import java.util.concurrent.LinkedBlockingQueue;
122 new LinkedBlockingQueue<Runnable>()) {
|
| /sdk/apps/SdkController/src/com/android/tools/sdkcontroller/lib/ |
| Channel.java | 30 import java.util.concurrent.LinkedBlockingQueue;
181 mMsgQueue = new LinkedBlockingQueue<SdkControllerMessage>();
|
| /cts/tests/tests/hardware/src/android/hardware/multiprocess/ |
| ErrorLoggingService.java | 46 import java.util.concurrent.LinkedBlockingQueue;
339 private final LinkedBlockingQueue<SettableFuture<List<LogEvent>>> mFuturesQueue =
340 new LinkedBlockingQueue<>();
|
| /developers/build/prebuilts/gradle/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/ |
| DiskLruCache.java | 46 import java.util.concurrent.LinkedBlockingQueue;
271 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
[all...] |
| /developers/samples/android/ui/graphics/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/ |
| DiskLruCache.java | 46 import java.util.concurrent.LinkedBlockingQueue;
271 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
[all...] |
| /development/samples/browseable/DisplayingBitmaps/src/com.example.android.displayingbitmaps/util/ |
| DiskLruCache.java | 46 import java.util.concurrent.LinkedBlockingQueue;
271 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
[all...] |
| /external/glide/third_party/disklrucache/src/main/java/com/bumptech/glide/disklrucache/ |
| DiskLruCache.java | 37 import java.util.concurrent.LinkedBlockingQueue;
159 new ThreadPoolExecutor(0, 1, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
|
