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

1 2 3 4 5

  /libcore/jsr166-tests/src/test/java/jsr166/
LinkedBlockingQueueUnboundedTest.java 12 import java.util.concurrent.LinkedBlockingQueue;
17 return new LinkedBlockingQueue();
LinkedBlockingQueueBoundedTest.java 12 import java.util.concurrent.LinkedBlockingQueue;
17 return new LinkedBlockingQueue(SIZE);
LinkedBlockingQueueTest.java 23 import java.util.concurrent.LinkedBlockingQueue;
34 // return new LinkedBlockingQueue();
40 // return new LinkedBlockingQueue(SIZE);
60 private LinkedBlockingQueue<Integer> populatedQueue(int n) {
61 LinkedBlockingQueue<Integer> q =
62 new LinkedBlockingQueue<Integer>(n);
77 assertEquals(SIZE, new LinkedBlockingQueue(SIZE).remainingCapacity());
78 assertEquals(Integer.MAX_VALUE, new LinkedBlockingQueue().remainingCapacity());
86 new LinkedBlockingQueue(0);
96 new LinkedBlockingQueue(null)
    [all...]
  /external/testng/src/main/java/org/testng/internal/remote/
SocketLinkedBlockingQueue.java 6 * <code>SocketLinkedBlockingQueue</code> is a wrapper on LinkedBlockingQueue so
8 * of LinkedBlockingQueue
13 public class SocketLinkedBlockingQueue extends java.util.concurrent.LinkedBlockingQueue<Socket>
  /frameworks/av/media/libstagefright/webm/
LinkedBlockingQueue.h 27 class LinkedBlockingQueue {
44 DISALLOW_EVIL_CONSTRUCTORS(LinkedBlockingQueue);
47 LinkedBlockingQueue() {
50 ~LinkedBlockingQueue() {
WebmFrameThread.h 21 #include "LinkedBlockingQueue.h"
69 LinkedBlockingQueue<const sp<WebmFrame> >& videoSource,
70 LinkedBlockingQueue<const sp<WebmFrame> >& audioSource,
83 LinkedBlockingQueue<const sp<WebmFrame> >& mVideoFrames;
84 LinkedBlockingQueue<const sp<WebmFrame> >& mAudioFrames;
101 WebmFrameSourceThread(int type, LinkedBlockingQueue<const sp<WebmFrame> >& sink);
105 LinkedBlockingQueue<const sp<WebmFrame> >& mSink;
114 WebmFrameEmptySourceThread(int type, LinkedBlockingQueue<const sp<WebmFrame> >& sink)
128 LinkedBlockingQueue<const sp<WebmFrame> >& sink,
  /external/sl4a/Utils/src/com/googlecode/android_scripting/
SingleThreadExecutor.java 19 import java.util.concurrent.LinkedBlockingQueue;
26 super(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
  /cts/hostsidetests/net/app/src/com/android/cts/net/hostside/
MyActivity.java 24 import java.util.concurrent.LinkedBlockingQueue;
28 private final LinkedBlockingQueue<Integer> mResult = new LinkedBlockingQueue<>(1);
  /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 27 import java.util.concurrent.LinkedBlockingQueue;
51 private final LinkedBlockingQueue<Runnable> mQueue = new LinkedBlockingQueue<Runnable>();
  /external/guava/guava/src/com/google/common/collect/
Queues.java 29 import java.util.concurrent.LinkedBlockingQueue;
140 // LinkedBlockingQueue
143 * Creates an empty {@code LinkedBlockingQueue} with a capacity of {@link Integer#MAX_VALUE}.
145 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() {
146 return new LinkedBlockingQueue<E>();
150 * Creates an empty {@code LinkedBlockingQueue} with the given (fixed) capacity.
154 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue(int capacity) {
155 return new LinkedBlockingQueue<E>(capacity);
159 * Creates a {@code LinkedBlockingQueue} with a capacity of {@link Integer#MAX_VALUE},
164 * @return a new {@code LinkedBlockingQueue} containing those element
    [all...]
  /external/jetty/src/java/org/eclipse/jetty/util/thread/
ExecutorThreadPool.java 24 import java.util.concurrent.LinkedBlockingQueue;
56 * an unbounded {@link LinkedBlockingQueue} is used for the job queue;
62 this(new ThreadPoolExecutor(256, 256, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()));
69 * @param queueSize can be -1 for using an unbounded {@link LinkedBlockingQueue}, 0 for using a
74 this(queueSize < 0 ? new ThreadPoolExecutor(256, 256, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()) :
82 * an unbounded {@link LinkedBlockingQueue} is used for the jobs queue;
95 * an unbounded {@link LinkedBlockingQueue} is used for the jobs queue.
103 this(corePoolSize, maximumPoolSize, keepAliveTime, unit, 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>();
  /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
SynchronousHttpClient.java 21 import java.util.concurrent.LinkedBlockingQueue;
33 1, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
  /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/
QueueDispatcher.java 20 import java.util.concurrent.LinkedBlockingQueue;
27 protected final BlockingQueue<MockResponse> responseQueue = new LinkedBlockingQueue<>();
  /external/testng/src/main/java/org/testng/internal/thread/
ExecutorAdapter.java 5 import java.util.concurrent.LinkedBlockingQueue;
23 new LinkedBlockingQueue<Runnable>(),
  /external/vogar/src/vogar/util/
Threads.java 20 import java.util.concurrent.LinkedBlockingQueue;
51 new LinkedBlockingQueue<Runnable>(Integer.MAX_VALUE), threadFactory) {
  /cts/tests/camera/src/android/hardware/camera2/cts/helpers/
CameraSessionUtils.java 39 import java.util.concurrent.LinkedBlockingQueue;
55 private final LinkedBlockingQueue<CameraCaptureSession> mSessionQueue =
56 new LinkedBlockingQueue<>();
95 private final LinkedBlockingQueue<TotalCaptureResult> mResultQueue =
96 new LinkedBlockingQueue<>();
97 private final LinkedBlockingQueue<Long> mCaptureTimeQueue =
98 new LinkedBlockingQueue<>();
  /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/owasp/sanitizer/src/tests/org/owasp/html/
HtmlSanitizerFuzzerTest.java 32 import java.util.concurrent.LinkedBlockingQueue;
69 final LinkedBlockingQueue<Throwable> failures
70 = new LinkedBlockingQueue<Throwable>();
76 10, 10, 10, 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>();
  /external/okhttp/samples/crawler/src/main/java/com/squareup/okhttp/sample/
Crawler.java 32 import java.util.concurrent.LinkedBlockingQueue;
45 private final LinkedBlockingQueue<HttpUrl> queue = new LinkedBlockingQueue<>();

Completed in 465 milliseconds

1 2 3 4 5