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
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