Home
last modified time | relevance | path

Searched refs:LinkedBlockingQueue (Results 1 – 25 of 87) sorted by relevance

1234

/aosp12/frameworks/av/media/libstagefright/webm/
H A DWebmFrameThread.h69 LinkedBlockingQueue<const sp<WebmFrame> >& videoSource,
70 LinkedBlockingQueue<const sp<WebmFrame> >& audioSource,
83 LinkedBlockingQueue<const sp<WebmFrame> >& mVideoFrames;
84 LinkedBlockingQueue<const sp<WebmFrame> >& mAudioFrames;
102 WebmFrameSourceThread(int type, LinkedBlockingQueue<const sp<WebmFrame> >& sink);
106 LinkedBlockingQueue<const sp<WebmFrame> >& mSink;
115 WebmFrameEmptySourceThread(int type, LinkedBlockingQueue<const sp<WebmFrame> >& sink) in WebmFrameEmptySourceThread()
129 LinkedBlockingQueue<const sp<WebmFrame> >& sink,
H A DLinkedBlockingQueue.h27 class LinkedBlockingQueue {
44 DISALLOW_EVIL_CONSTRUCTORS(LinkedBlockingQueue);
47 LinkedBlockingQueue() { in LinkedBlockingQueue() function
50 ~LinkedBlockingQueue() { in ~LinkedBlockingQueue()
/aosp12/packages/apps/UniversalMediaPlayer/java/com/android/pump/concurrent/
H A DExecutors.java27 import java.util.concurrent.LinkedBlockingQueue;
64 new LinkedBlockingQueue<>()); in newFixedUniqueThreadPool()
70 new LinkedBlockingQueue<>(), threadFactory); in newFixedUniqueThreadPool()
75 new LinkedBlockingQueue<>()); in newCachedUniqueThreadPool()
81 new LinkedBlockingQueue<>(), threadFactory); in newCachedUniqueThreadPool()
/aosp12/frameworks/opt/telephony/tests/telephonytests/src/android/telephony/ims/
H A DImsConfigImplTest.java35 import java.util.concurrent.LinkedBlockingQueue;
111 final LinkedBlockingQueue<Pair<Integer, Integer>> mConfigChanges = in testIntCaching()
112 new LinkedBlockingQueue<>(); in testIntCaching()
140 final LinkedBlockingQueue<Pair<Integer, String>> mConfigChanges = in testStringCaching()
141 new LinkedBlockingQueue<>(); in testStringCaching()
/aosp12/packages/modules/Connectivity/tests/cts/hostside/app/src/com/android/cts/net/hostside/
H A DMyActivity.java25 import java.util.concurrent.LinkedBlockingQueue;
29 private final LinkedBlockingQueue<Integer> mResult = new LinkedBlockingQueue<>(1);
/aosp12/frameworks/base/tests/Input/src/com/android/test/input/
H A DInputEventSenderAndReceiverTest.kt28 import java.util.concurrent.LinkedBlockingQueue
49 private fun <T> getEvent(queue: LinkedBlockingQueue<T>): T {
59 private val mInputEvents = LinkedBlockingQueue<InputEvent>()
80 private val mFinishedSignals = LinkedBlockingQueue<FinishedSignal>()
81 private val mTimelines = LinkedBlockingQueue<Timeline>()
/aosp12/packages/apps/Calendar/src/com/android/calendar/
H A DEventLoader.java30 import java.util.concurrent.LinkedBlockingQueue;
39 private LinkedBlockingQueue<LoadRequest> mLoaderQueue;
161 LinkedBlockingQueue<LoadRequest> mQueue;
164 public LoaderThread(LinkedBlockingQueue<LoadRequest> queue, EventLoader eventLoader) { in LoaderThread()
211 mLoaderQueue = new LinkedBlockingQueue<LoadRequest>(); in EventLoader()
/aosp12/packages/providers/MediaProvider/tests/src/com/android/providers/media/
H A DGetResultActivity.java24 import java.util.concurrent.LinkedBlockingQueue;
28 private static LinkedBlockingQueue<Result> sResult;
63 sResult = new LinkedBlockingQueue<>(); in clearResult()
/aosp12/packages/services/Car/tests/carservice_test/src/com/android/car/
H A DMockedVmsTestBase.java48 import java.util.concurrent.LinkedBlockingQueue;
128 new LinkedBlockingQueue<>();
153 private BlockingQueue<Pair<VmsLayer, byte[]>> mMessages = new LinkedBlockingQueue<>();
154 private BlockingQueue<VmsAvailableLayers> mAvailableLayers = new LinkedBlockingQueue<>();
178 private BlockingQueue<VehiclePropValue> mMessages = new LinkedBlockingQueue<>();
/aosp12/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/
H A DSingleThreadNamedTaskExecutor.java21 import java.util.concurrent.LinkedBlockingQueue;
32 private final LinkedBlockingQueue<NamedTask> mQueue;
37 mQueue = new LinkedBlockingQueue<NamedTask>(); in SingleThreadNamedTaskExecutor()
/aosp12/frameworks/base/core/java/android/speech/tts/
H A DAudioPlaybackHandler.java21 import java.util.concurrent.LinkedBlockingQueue;
27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue =
28 new LinkedBlockingQueue<PlaybackQueueItem>();
/aosp12/packages/apps/DocumentsUI/src/com/android/documentsui/
H A DProviderExecutor.java27 import java.util.concurrent.LinkedBlockingQueue;
51 private final LinkedBlockingQueue<Runnable> mQueue = new LinkedBlockingQueue<Runnable>();
/aosp12/frameworks/base/core/java/android/os/
H A DTestLooperManager.java19 import java.util.concurrent.LinkedBlockingQueue;
37 private final LinkedBlockingQueue<MessageExecution> mExecuteQueue = new LinkedBlockingQueue<>();
/aosp12/frameworks/base/telecomm/java/android/telecom/Logging/
H A DEventManager.java40 import java.util.concurrent.LinkedBlockingQueue;
71 private LinkedBlockingQueue<EventRecord> mEventRecords =
72 new LinkedBlockingQueue<>(DEFAULT_EVENTS_TO_CACHE);
363 LinkedBlockingQueue<EventRecord> oldEventLog = mEventRecords; in changeEventCacheSize()
364 mEventRecords = new LinkedBlockingQueue<>(newSize); in changeEventCacheSize()
395 public LinkedBlockingQueue<EventRecord> getEventRecords() { in getEventRecords()
/aosp12/packages/modules/Connectivity/tests/cts/net/api23Test/src/android/net/cts/api23test/
H A DConnectivityManagerApi23Test.java33 import java.util.concurrent.LinkedBlockingQueue;
118 final LinkedBlockingQueue<Integer> result = new LinkedBlockingQueue<>(1); in sendOrderedBroadcastAndReturnResultCode()
/aosp12/frameworks/ex/camera2/public/src/com/android/ex/camera2/utils/
H A DStateWaiter.java26 import java.util.concurrent.LinkedBlockingQueue;
55 private final LinkedBlockingQueue<Integer> mQueuedStates = new LinkedBlockingQueue<>();
/aosp12/frameworks/ex/camera2/public/src/com/android/ex/camera2/blocking/
H A DBlockingStateCallback.java27 import java.util.concurrent.LinkedBlockingQueue;
52 private final LinkedBlockingQueue<Integer> mRecentStates =
53 new LinkedBlockingQueue<Integer>();
H A DBlockingOfflineSessionCallback.java29 import java.util.concurrent.LinkedBlockingQueue;
54 private final LinkedBlockingQueue<Integer> mRecentStates =
55 new LinkedBlockingQueue<Integer>();
/aosp12/packages/apps/Dialer/java/com/android/dialer/persistentlog/
H A DPersistentLogger.java36 import java.util.concurrent.LinkedBlockingQueue;
64 private static final LinkedBlockingQueue<byte[]> messageQueue = new LinkedBlockingQueue<>();
/aosp12/frameworks/opt/net/ims/tests/src/com/android/ims/
H A DImsUtTest.java46 import java.util.concurrent.LinkedBlockingQueue;
61 private final LinkedBlockingQueue<ImsSsInfo> mPendingSsInfos = new LinkedBlockingQueue<>(1);
/aosp12/frameworks/base/core/tests/coretests/src/android/os/
H A DBinderWorkSourceNestedService.java26 import java.util.concurrent.LinkedBlockingQueue;
53 new LinkedBlockingQueue<>();
/aosp12/packages/apps/Launcher3/src/com/android/launcher3/util/
H A DExecutors.java22 import java.util.concurrent.LinkedBlockingQueue;
41 POOL_SIZE, POOL_SIZE, KEEP_ALIVE, TimeUnit.SECONDS, new LinkedBlockingQueue<>());
/aosp12/frameworks/opt/bitmap/src/com/android/bitmap/
H A DUnrefedPooledCache.java26 import java.util.concurrent.LinkedBlockingQueue;
47 private final LinkedBlockingQueue<V> mPool;
61 mPool = new LinkedBlockingQueue<V>(); in UnrefedPooledCache()
/aosp12/frameworks/base/tests/ActivityManagerPerfTests/tests/src/com/android/frameworks/perftests/am/util/
H A DTimeReceiver.java24 import java.util.concurrent.LinkedBlockingQueue;
36 private BlockingQueue<ReceivedMessage> mQueue = new LinkedBlockingQueue<>();
/aosp12/frameworks/base/packages/FusedLocation/test/src/com/android/location/fused/tests/
H A DFusedLocationServiceTest.java53 import java.util.concurrent.LinkedBlockingQueue;
147 private final LinkedBlockingQueue<Location> mLocations;
150 mLocations = new LinkedBlockingQueue<>(); in LocationProviderManagerCapture()

1234