Home
last modified time | relevance | path

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

12345678910>>...40

/aosp_15_r20/libcore/ojluni/src/test/java/util/concurrent/tck/
H A DLinkedBlockingQueueTest.java57 import java.util.concurrent.LinkedBlockingQueue;
71 return new LinkedBlockingQueue(); in emptyCollection()
79 return new LinkedBlockingQueue(SIZE); in emptyCollection()
108 private LinkedBlockingQueue<Integer> populatedQueue(int n) { in populatedQueue()
109 LinkedBlockingQueue<Integer> q = in populatedQueue()
110 new LinkedBlockingQueue<Integer>(n); in populatedQueue()
127 assertEquals(SIZE, new LinkedBlockingQueue(SIZE).remainingCapacity()); in testConstructor1()
128 assertEquals(Integer.MAX_VALUE, new LinkedBlockingQueue().remainingCapacity()); in testConstructor1()
137 new LinkedBlockingQueue(0); in testConstructor2()
148 new LinkedBlockingQueue(null); in testConstructor3()
[all …]
/aosp_15_r20/libcore/jsr166-tests/src/test/java/jsr166/
H A DLinkedBlockingQueueTest.java23 import java.util.concurrent.LinkedBlockingQueue;
60 private LinkedBlockingQueue<Integer> populatedQueue(int n) { in populatedQueue()
61 LinkedBlockingQueue<Integer> q = in populatedQueue()
62 new LinkedBlockingQueue<Integer>(n); in populatedQueue()
77 assertEquals(SIZE, new LinkedBlockingQueue(SIZE).remainingCapacity()); in testConstructor1()
78 assertEquals(Integer.MAX_VALUE, new LinkedBlockingQueue().remainingCapacity()); in testConstructor1()
86 new LinkedBlockingQueue(0); in testConstructor2()
96 new LinkedBlockingQueue(null); in testConstructor3()
107 new LinkedBlockingQueue(elements); in testConstructor4()
122 new LinkedBlockingQueue(elements); in testConstructor5()
[all …]
/aosp_15_r20/cts/tests/tests/telephony/current/src/android/telephony/cts/
H A DTelephonyRegistryManagerTest.java52 import java.util.concurrent.LinkedBlockingQueue;
118 LinkedBlockingQueue<Pair<Integer, String>> queue = new LinkedBlockingQueue<>(1); in testNotifyCallStateChangedForAllSubscriptions()
145 LinkedBlockingQueue<Pair<Integer, String>> queue = new LinkedBlockingQueue<>(1); in testNotifyCallStateChanged()
179 LinkedBlockingQueue<ServiceState> queue = new LinkedBlockingQueue<>(1); in testNotifyServiceStateChanged()
210 LinkedBlockingQueue<SignalStrength> queue = new LinkedBlockingQueue<>(1); in testNotifySignalStrengthChanged()
239 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testNotifyMessageWaitingChanged()
267 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testNotifyCallForwardingChanged()
293 LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<>(1); in testNotifyDataActivityChangedWithSlot()
321 LinkedBlockingQueue<Pair<Set<String>, Set<Integer>>> carrierPrivilegesQueue = in testCarrierPrivilegesCallback()
322 new LinkedBlockingQueue(2); in testCarrierPrivilegesCallback()
[all …]
H A DSimultaneousCallingRestrictionsTest.java81 import java.util.concurrent.LinkedBlockingQueue;
369 LinkedBlockingQueue<ImsRegistrationAttributes>> result_0 = null; in testCellularDSDASupported_ImsRegisteredWWAN()
371 LinkedBlockingQueue<ImsRegistrationAttributes>> result_1 = null; in testCellularDSDASupported_ImsRegisteredWWAN()
412 LinkedBlockingQueue<ImsRegistrationAttributes>> result_0 = null; in testCellularDSDANotSupported_ImsRegisteredWWAN()
414 LinkedBlockingQueue<ImsRegistrationAttributes>> result_1 = null; in testCellularDSDANotSupported_ImsRegisteredWWAN()
450 LinkedBlockingQueue<ImsRegistrationAttributes>> result_0 = null; in testImsRegisteredWLAN()
452 LinkedBlockingQueue<ImsRegistrationAttributes>> result_1 = null; in testImsRegisteredWLAN()
515 LinkedBlockingQueue<ImsRegistrationAttributes>>
524 LinkedBlockingQueue<ImsRegistrationAttributes> mRegQueue = in attachCarrierImsServiceAndSetUnregistered()
525 new LinkedBlockingQueue<>(); in attachCarrierImsServiceAndSetUnregistered()
[all …]
H A DAsyncSmsMessageListener.java20 import java.util.concurrent.LinkedBlockingQueue;
31 private final LinkedBlockingQueue<String> mMessages = new LinkedBlockingQueue<>(1);
32 private final LinkedBlockingQueue<Intent> mSentMessageResults = new LinkedBlockingQueue<>(1);
33 private final LinkedBlockingQueue<Intent> mDeliveredMessageResults =
34 new LinkedBlockingQueue<>(1);
/aosp_15_r20/cts/tests/tests/voiceinteraction/src/android/voiceinteraction/cts/
H A DVoiceInteractionTestReceiver.java30 import java.util.concurrent.LinkedBlockingQueue;
37 private static LinkedBlockingQueue<Intent> sServiceStartedQueue = new LinkedBlockingQueue<>();
38 private static LinkedBlockingQueue<Intent> sScreenshotReceivedQueue =
39 new LinkedBlockingQueue<>();
40 private static LinkedBlockingQueue<Intent> sAssistDataReceivedQueue =
41 new LinkedBlockingQueue<>();
42 private static LinkedBlockingQueue<Intent> sOnShowReceivedQueue = new LinkedBlockingQueue<>();
110 sServiceStartedQueue = new LinkedBlockingQueue<>(); in reset()
111 sScreenshotReceivedQueue = new LinkedBlockingQueue<>(); in reset()
112 sAssistDataReceivedQueue = new LinkedBlockingQueue<>(); in reset()
[all …]
/aosp_15_r20/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
H A DLinkedBlockingQueue.java41 public class LinkedBlockingQueue<E> extends java.util.AbstractQueue<E> class
44 public LinkedBlockingQueue() { in LinkedBlockingQueue() method in LinkedBlockingQueue
48 public LinkedBlockingQueue(int capacity) { in LinkedBlockingQueue() method in LinkedBlockingQueue
52 public LinkedBlockingQueue(java.util.Collection<? extends E> c) { in LinkedBlockingQueue() method in LinkedBlockingQueue
64 private void enqueue(java.util.concurrent.LinkedBlockingQueue.Node<E> node) { in enqueue()
119 java.util.concurrent.LinkedBlockingQueue.Node<E> p, in unlink()
120 java.util.concurrent.LinkedBlockingQueue.Node<E> trail) { in unlink()
187 transient java.util.concurrent.LinkedBlockingQueue.Node<E> head;
189 private transient java.util.concurrent.LinkedBlockingQueue.Node<E> last;
238 private java.util.concurrent.LinkedBlockingQueue.Node<E> current;
[all …]
/aosp_15_r20/cts/tests/tests/telephony/current/src/android/telephony/ims/cts/
H A DImsServiceTest.java117 import java.util.concurrent.LinkedBlockingQueue;
1113 LinkedBlockingQueue<Integer> state = new LinkedBlockingQueue<>(1); in getFeatureState()
1136 LinkedBlockingQueue<ImsRegistrationAttributes> mRegQueue = in testMmTelManagerRegistrationCallbackS()
1137 new LinkedBlockingQueue<>(); in testMmTelManagerRegistrationCallbackS()
1138 LinkedBlockingQueue<ImsReasonInfo> mDeregQueue = in testMmTelManagerRegistrationCallbackS()
1139 new LinkedBlockingQueue<>(); in testMmTelManagerRegistrationCallbackS()
1247 LinkedBlockingQueue<ImsRegistrationAttributes> mEmerRegQueue = in testMmTelManagerEmergencyRegistrationCallback()
1248 new LinkedBlockingQueue<>(); in testMmTelManagerEmergencyRegistrationCallback()
1250 LinkedBlockingQueue<Integer> mEmerDeregQueue = in testMmTelManagerEmergencyRegistrationCallback()
1251 new LinkedBlockingQueue<>(); in testMmTelManagerEmergencyRegistrationCallback()
[all …]
H A DMmTelFeatureTestOnMockModem.java90 import java.util.concurrent.LinkedBlockingQueue;
342 final LinkedBlockingQueue<Integer> resultQueue = new LinkedBlockingQueue<>(); in testSetTerminalBasedCallWaiting()
448 LinkedBlockingQueue<ConnectionFailureInfo> resultQueue = new LinkedBlockingQueue<>(); in testStartAndStopImsTrafficSession()
472 LinkedBlockingQueue<ConnectionFailureInfo> voiceResultQueue = new LinkedBlockingQueue<>(); in testStartAndStopImsTrafficSession()
489 LinkedBlockingQueue<ConnectionFailureInfo> regResultQueue = new LinkedBlockingQueue<>(); in testStartAndStopImsTrafficSession()
531 resultQueue = new LinkedBlockingQueue<>(); in testStartAndStopImsTrafficSession()
557 resultQueue = new LinkedBlockingQueue<>(); in testStartAndStopImsTrafficSession()
608 LinkedBlockingQueue<ConnectionFailureInfo> resultQueue = new LinkedBlockingQueue<>(); in testStartAndStopImsTrafficSessionWhenServiceDisconnected()
617 LinkedBlockingQueue<ConnectionFailureInfo> voiceResultQueue = new LinkedBlockingQueue<>(); in testStartAndStopImsTrafficSessionWhenServiceDisconnected()
626 LinkedBlockingQueue<ConnectionFailureInfo> regResultQueue = new LinkedBlockingQueue<>(); in testStartAndStopImsTrafficSessionWhenServiceDisconnected()
[all …]
H A DRcsUceAdapterTest.java107 import java.util.concurrent.LinkedBlockingQueue;
292 LinkedBlockingQueue<Uri> queue = new LinkedBlockingQueue<>(1); in testGetAndSetUceSetting()
519 BlockingQueue<Boolean> completeQueue = new LinkedBlockingQueue<>(); in testCapabilitiesRequestAllowed()
520 BlockingQueue<RcsContactUceCapability> capabilityQueue = new LinkedBlockingQueue<>(); in testCapabilitiesRequestAllowed()
521 BlockingQueue<Integer> errorQueue = new LinkedBlockingQueue<>(); in testCapabilitiesRequestAllowed()
655 BlockingQueue<Integer> errorQueue = new LinkedBlockingQueue<>(); in testCapabilitiesRequestWithCmdError()
656 BlockingQueue<Long> retryAfterQueue = new LinkedBlockingQueue<>(); in testCapabilitiesRequestWithCmdError()
751 BlockingQueue<Integer> errorQueue = new LinkedBlockingQueue<>(); in testCapabilitiesRequestRetry()
781 BlockingQueue<List<Uri>> requestQueue = new LinkedBlockingQueue<>(); in testCapabilitiesRequestRetry()
824 BlockingQueue<Integer> errorQueue = new LinkedBlockingQueue<>(); in testCapabilitiesRequestWithResponseError()
[all …]
/aosp_15_r20/frameworks/base/core/tests/coretests/src/android/os/
H A DBinderFrozenStateChangeNotificationTest.java49 import java.util.concurrent.LinkedBlockingQueue;
146 final LinkedBlockingQueue<Boolean> results = new LinkedBlockingQueue<>(); in onStateChangeCalled()
159 final LinkedBlockingQueue<Boolean> results = new LinkedBlockingQueue<>(); in onStateChangeNotCalledAfterCallbackRemoved()
172 final LinkedBlockingQueue<Boolean> results1 = new LinkedBlockingQueue<>(); in multipleCallbacks()
173 final LinkedBlockingQueue<Boolean> results2 = new LinkedBlockingQueue<>(); in multipleCallbacks()
199 final LinkedBlockingQueue<IBinder> results = new LinkedBlockingQueue<>(); in onStateChangeCalledWithTheRightBinder()
237 private void ensureFrozenCallback(LinkedBlockingQueue<Boolean> queue) in ensureFrozenCallback()
242 private void ensureUnfrozenCallback(LinkedBlockingQueue<Boolean> queue) in ensureUnfrozenCallback()
/aosp_15_r20/cts/tests/tests/telecom-cuj/src/android/telecom/cts/cuj/app/integration/
H A DRingerTest.java60 import java.util.concurrent.LinkedBlockingQueue;
105 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testIncomingCall_RingAndVibrate()
159 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testIncomingCallVibrationDisabled_RingAndNoVibrate()
214 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testIncomingCallSilentMode_NoRingAndNoVibrate()
269 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testIncomingCallVibrateMode_VibrateAndNoRing()
329 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testIncomingCallVibrateModeEnableRinger_VibrateAndRing()
400 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testIncomingCallVibrateMode_vibrationSettingsSupported_VibrateAndRing()
470 private AudioPlaybackCallback createAudioPlaybackCallback(LinkedBlockingQueue<Boolean> queue) { in createAudioPlaybackCallback()
/aosp_15_r20/cts/tests/tests/os/src/android/os/cts/
H A DRemoteCallbackListTest.java52 import java.util.concurrent.LinkedBlockingQueue;
201 private <T> void assertEmpty(LinkedBlockingQueue<T> queue) { in assertEmpty()
207 LinkedBlockingQueue<U> queue) { in flushAndAssertEmpty()
233 LinkedBlockingQueue<IInterface> invokedCallbacks = new LinkedBlockingQueue<>(); in testQueueCallbacksWhenFrozen()
257 LinkedBlockingQueue<String> invocationRecords = new LinkedBlockingQueue<>(); in testQueueMostRecentCallbackWhenFrozen()
276 LinkedBlockingQueue<IInterface> invokedCallbacks = new LinkedBlockingQueue<>(); in testRemoveQueuedCallbacksOnUnregistration()
291 LinkedBlockingQueue<String> invocationRecords = new LinkedBlockingQueue<>(); in testDropCallbacksWhenQueueGrowsTooBig()
310 LinkedBlockingQueue<IInterface> invocationRecords = new LinkedBlockingQueue<>(); in testInvokeInterfaceDiedCallback()
/aosp_15_r20/cts/tests/tests/media/common/src/android/media/cts/
H A DMediaCodecCryptoAsyncHelper.java53 import java.util.concurrent.LinkedBlockingQueue;
189 final LinkedBlockingQueue<Throwable> in runShortClearKeyVideoWithNoCryptoErrorOverride()
190 threadExceptionQueue = new LinkedBlockingQueue<>(); in runShortClearKeyVideoWithNoCryptoErrorOverride()
191 final LinkedBlockingQueue<MediaCodecAsyncHelper.SlotEvent> in runShortClearKeyVideoWithNoCryptoErrorOverride()
192 slotQueue = new LinkedBlockingQueue<>(); in runShortClearKeyVideoWithNoCryptoErrorOverride()
308 final LinkedBlockingQueue<MediaCodec.CryptoInfo> in runDecodeShortClearKeyVideo()
309 cryptoInfoQueue = new LinkedBlockingQueue<>(); in runDecodeShortClearKeyVideo()
310 final LinkedBlockingQueue<MediaCodecAsyncHelper.SlotEvent> in runDecodeShortClearKeyVideo()
311 slotQueue = new LinkedBlockingQueue<>(); in runDecodeShortClearKeyVideo()
407 LinkedBlockingQueue<MediaCodecAsyncHelper.SlotEvent> slotQueue) in runComponentWithInput()
[all …]
/aosp_15_r20/cts/tests/tests/telephony/current/src/android/telephony/satellite/cts/
H A DSatelliteManagerTestOnMockService.java132 import java.util.concurrent.LinkedBlockingQueue;
551 LinkedBlockingQueue<Integer> error = new LinkedBlockingQueue<>(1); in testProvisionSatelliteService()
1027 LinkedBlockingQueue<Integer> sosResultListener = new LinkedBlockingQueue<>(1); in testSendKeepAliveDatagramInNotConnectedState()
1028 LinkedBlockingQueue<Integer> keepAliveResultListener = new LinkedBlockingQueue<>(1); in testSendKeepAliveDatagramInNotConnectedState()
1123 LinkedBlockingQueue<Integer> resultListener = new LinkedBlockingQueue<>(1); in sendDatagramWithoutResponse()
1211 LinkedBlockingQueue<Integer> resultListener = new LinkedBlockingQueue<>(1); in verifyNbIotStateTransitionsWithTransferringFailureOnIdle()
1314 LinkedBlockingQueue<Integer> resultListener = new LinkedBlockingQueue<>(1); in verifyNbIotStateTransitionsWithSendingAborted()
1755 LinkedBlockingQueue<Integer> resultListener = new LinkedBlockingQueue<>(1); in testSendSatelliteDatagram_failure()
1823 LinkedBlockingQueue<Integer> resultListener = new LinkedBlockingQueue<>(1); in testSendMultipleSatelliteDatagrams_success()
1850 LinkedBlockingQueue<Integer> resultListener1 = new LinkedBlockingQueue<>(1); in testSendMultipleSatelliteDatagrams_success()
[all …]
H A DSatelliteManagerTest.java70 import java.util.concurrent.LinkedBlockingQueue;
209 LinkedBlockingQueue<Integer> error = new LinkedBlockingQueue<>(1); in testSatelliteTransmissionUpdates()
246 LinkedBlockingQueue<Integer> error = new LinkedBlockingQueue<>(1); in testProvisionSatelliteService()
316 LinkedBlockingQueue<Integer> error = new LinkedBlockingQueue<>(1); in testDeprovisionSatelliteService()
366 LinkedBlockingQueue<Integer> error = new LinkedBlockingQueue<>(1); in testRequestSatelliteEnabled()
531 LinkedBlockingQueue<Integer> resultListener = new LinkedBlockingQueue<>(1); in testSatelliteModemStateChanged()
615 LinkedBlockingQueue<Integer> resultListener = new LinkedBlockingQueue<>(1); in testPollPendingSatelliteDatagrams()
627 LinkedBlockingQueue<Integer> resultListener = new LinkedBlockingQueue<>(1); in testSendSatelliteDatagram()
770 LinkedBlockingQueue<Integer> error = new LinkedBlockingQueue<>(1); in testRequestSatelliteAttachEnabledForCarrier()
815 LinkedBlockingQueue<Integer> error = new LinkedBlockingQueue<>(1); in testAddSatelliteAttachRestrictionForCarrier()
[all …]
/aosp_15_r20/frameworks/av/media/libstagefright/webm/include/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,
/aosp_15_r20/cts/tests/location/common/src/android/location/cts/common/
H A DLocationListenerCapture.java24 import java.util.concurrent.LinkedBlockingQueue;
30 private final LinkedBlockingQueue<Location> mLocations;
31 private final LinkedBlockingQueue<Integer> mFlushes;
32 private final LinkedBlockingQueue<Boolean> mProviderChanges;
36 mLocations = new LinkedBlockingQueue<>(); in LocationListenerCapture()
37 mFlushes = new LinkedBlockingQueue<>(); in LocationListenerCapture()
38 mProviderChanges = new LinkedBlockingQueue<>(); in LocationListenerCapture()
H A DLocationPendingIntentCapture.java32 import java.util.concurrent.LinkedBlockingQueue;
43 private final LinkedBlockingQueue<Location> mLocations;
44 private final LinkedBlockingQueue<Integer> mFlushes;
45 private final LinkedBlockingQueue<Boolean> mProviderChanges;
56 mLocations = new LinkedBlockingQueue<>(); in LocationPendingIntentCapture()
57 mFlushes = new LinkedBlockingQueue<>(); in LocationPendingIntentCapture()
58 mProviderChanges = new LinkedBlockingQueue<>(); in LocationPendingIntentCapture()
/aosp_15_r20/cts/tests/tests/telecom/src/android/telecom/cts/
H A DTelecomManagerTest.java37 import java.util.concurrent.LinkedBlockingQueue;
51 LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue(1); in testGetCurrentTtyMode()
95 LinkedBlockingQueue<Intent> ttyModeQueue = new LinkedBlockingQueue<>(1); in testTtyModeBroadcasts()
140 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in testIsInEmergencyCall_noOngoingEmergencyCall()
173 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in testIsInEmergencyCall_ongoingEmergencyCall()
/aosp_15_r20/cts/tests/tests/telephony/current/LocationAccessingApp/src/android/telephony/cts/locationaccessingapp/
H A DCtsLocationAccessService.java37 import java.util.concurrent.LinkedBlockingQueue;
103 LinkedBlockingQueue<List<CellInfo>> queue = new LinkedBlockingQueue<>(); in listenForCellInfo()
127 LinkedBlockingQueue<CellLocation> queue = new LinkedBlockingQueue<>(); in listenForCellLocation()
151 LinkedBlockingQueue<ServiceState> queue = new LinkedBlockingQueue<>(); in listenForServiceState()
179 LinkedBlockingQueue<List<CellInfo>> queue = new LinkedBlockingQueue<>(); in requestCellInfoUpdate()
/aosp_15_r20/external/guava/android/guava/src/com/google/common/collect/
H A DQueues.java31 import java.util.concurrent.LinkedBlockingQueue;
160 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() { in newLinkedBlockingQueue()
161 return new LinkedBlockingQueue<>(); in newLinkedBlockingQueue()
171 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue(int capacity) { in newLinkedBlockingQueue()
172 return new LinkedBlockingQueue<>(capacity); in newLinkedBlockingQueue()
185 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue(Iterable<? extends E> elements) { in newLinkedBlockingQueue()
187 return new LinkedBlockingQueue<>((Collection<? extends E>) elements); in newLinkedBlockingQueue()
189 LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<>(); in newLinkedBlockingQueue()
/aosp_15_r20/external/guava/guava/src/com/google/common/collect/
H A DQueues.java32 import java.util.concurrent.LinkedBlockingQueue;
161 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() { in newLinkedBlockingQueue()
162 return new LinkedBlockingQueue<>(); in newLinkedBlockingQueue()
172 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue(int capacity) { in newLinkedBlockingQueue()
173 return new LinkedBlockingQueue<>(capacity); in newLinkedBlockingQueue()
186 public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue(Iterable<? extends E> elements) { in newLinkedBlockingQueue()
188 return new LinkedBlockingQueue<>((Collection<? extends E>) elements); in newLinkedBlockingQueue()
190 LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<>(); in newLinkedBlockingQueue()
/aosp_15_r20/external/cronet/base/android/junit/src/org/chromium/base/task/
H A DAsyncTaskThreadTest.java33 import java.util.concurrent.LinkedBlockingQueue;
45 private final LinkedBlockingQueue<Boolean> mIncomingQueue =
46 new LinkedBlockingQueue<Boolean>();
47 private final LinkedBlockingQueue<Boolean> mOutgoingQueue =
48 new LinkedBlockingQueue<Boolean>();
49 private final LinkedBlockingQueue<Boolean> mInterruptedExceptionQueue =
50 new LinkedBlockingQueue<Boolean>();
88 public LinkedBlockingQueue<Boolean> getInterruptedExceptionQueue() { in getInterruptedExceptionQueue()
/aosp_15_r20/frameworks/base/tests/Input/src/com/android/test/input/
H A DSpyInputEventSenderAndReceiver.kt27 import java.util.concurrent.LinkedBlockingQueue
32 private fun <T> getEvent(queue: LinkedBlockingQueue<T>): T? { in getEvent()
36 private fun <T> assertNoEvents(queue: LinkedBlockingQueue<T>) { in assertNoEvents()
43 private val mInputEvents = LinkedBlockingQueue<InputEvent>()
64 private val mFinishedSignals = LinkedBlockingQueue<FinishedSignal>()
65 private val mTimelines = LinkedBlockingQueue<Timeline>()

12345678910>>...40