OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:LinkedBlockingQueue
(Results
1 - 25
of
103
) 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);
58
private
LinkedBlockingQueue
<Integer> populatedQueue(int n) {
59
LinkedBlockingQueue
<Integer> q =
60
new
LinkedBlockingQueue
<Integer>(n);
75
assertEquals(SIZE, new
LinkedBlockingQueue
(SIZE).remainingCapacity());
76
assertEquals(Integer.MAX_VALUE, new
LinkedBlockingQueue
().remainingCapacity());
84
new
LinkedBlockingQueue
(0);
94
new
LinkedBlockingQueue
(null)
[
all
...]
/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,
/cts/hostsidetests/net/app/src/com/android/cts/net/hostside/
MyActivity.java
28
import java.util.concurrent.
LinkedBlockingQueue
;
32
private final
LinkedBlockingQueue
<Integer> mResult = new
LinkedBlockingQueue
<>(1);
/external/guava/guava/src/com/google/common/collect/
Queues.java
26
import java.util.concurrent.
LinkedBlockingQueue
;
74
//
LinkedBlockingQueue
77
* Creates an empty {@code
LinkedBlockingQueue
} with a capacity of {@link Integer#MAX_VALUE}.
79
public static <E>
LinkedBlockingQueue
<E> newLinkedBlockingQueue() {
80
return new
LinkedBlockingQueue
<E>();
84
* Creates an empty {@code
LinkedBlockingQueue
} with the given (fixed) capacity.
88
public static <E>
LinkedBlockingQueue
<E> newLinkedBlockingQueue(int capacity) {
89
return new
LinkedBlockingQueue
<E>(capacity);
93
* Creates a {@code
LinkedBlockingQueue
} with a capacity of {@link Integer#MAX_VALUE},
98
* @return a new {@code
LinkedBlockingQueue
} containing those element
[
all
...]
/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/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>();
/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/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/vogar/src/vogar/util/
Threads.java
20
import java.util.concurrent.
LinkedBlockingQueue
;
51
new
LinkedBlockingQueue
<Runnable>(Integer.MAX_VALUE), threadFactory) {
/cts/tests/tests/hardware/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
33
import java.util.concurrent.
LinkedBlockingQueue
;
45
private final
LinkedBlockingQueue
<URL> queue = new
LinkedBlockingQueue
<>();
/frameworks/ex/camera2/public/src/com/android/ex/camera2/blocking/
BlockingStateCallback.java
27
import java.util.concurrent.
LinkedBlockingQueue
;
52
private final
LinkedBlockingQueue
<Integer> mRecentStates =
53
new
LinkedBlockingQueue
<Integer>();
/frameworks/ex/camera2/public/src/com/android/ex/camera2/utils/
StateWaiter.java
26
import java.util.concurrent.
LinkedBlockingQueue
;
55
private final
LinkedBlockingQueue
<Integer> mQueuedStates = new
LinkedBlockingQueue
<>();
Completed in 1249 milliseconds
1
2
3
4
5