| /aosp_15_r20/cts/tests/tests/os/src/android/os/cts/ |
| H A D | MessageQueueTest.java | 134 public void run() { in run() method in MessageQueueTest.TestLooperThread
303 MessageQueue queue = Looper.getMainLooper().getQueue(); in testRegisterFileDescriptorCallbackThrowsWhenFdIsNull() local
321 MessageQueue queue = Looper.getMainLooper().getQueue(); in testRegisterFileDescriptorCallbackThrowsWhenCallbackIsNull() local
337 MessageQueue queue = Looper.getMainLooper().getQueue(); in testUnregisterFileDescriptorCallbackThrowsWhenFdIsNull() local
350 MessageQueue queue = Looper.getMainLooper().getQueue(); in testUnregisterFileDescriptorCallbackDoesNothingWhenFdNotRegistered() local
367 final MessageQueue queue = thread.getLooper().getQueue(); in testFileDescriptorCallbacks() local
498 final MessageQueue queue = thread.getLooper().getQueue(); in testPathologicalFileDescriptorReuseCallbacks1() local
579 final MessageQueue queue = thread.getLooper().getQueue(); in testPathologicalFileDescriptorReuseCallbacks2() local
670 final MessageQueue queue = thread.getLooper().getQueue(); in testPathologicalFileDescriptorReuseCallbacks3() local
760 final MessageQueue queue = thread.getLooper().getQueue(); in testPathologicalFileDescriptorReuseCallbacks4() local
[all …]
|
| /aosp_15_r20/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| H A D | TrafficControlProxy.java | 139 private final MessageQueue queue; field in TrafficControlProxy.Reader
141 Reader(MessageQueue queue) { in Reader()
146 public void run() { in run() method in TrafficControlProxy.Reader
162 private final MessageQueue queue; field in TrafficControlProxy.Writer
164 Writer(MessageQueue queue) { in Writer()
169 public void run() { in run() method in TrafficControlProxy.Writer
189 BlockingQueue<Message> queue = new DelayQueue<>(); field in TrafficControlProxy.MessageQueue
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/24/libcore/ojluni/src/main/java/java/util/ |
| D | Timer.java | 131 private final TaskQueue queue = new TaskQueue(); field in Timer
147 private final TaskQueue queue; field in Timer.ThreadReaper
150 ThreadReaper(TaskQueue queue, TimerThread thread) { in ThreadReaper()
155 public void run() { in run() method in Timer.ThreadReaper
569 private TaskQueue queue; field in TimerThread
571 TimerThread(TaskQueue queue) { in TimerThread()
575 public void run() { in run() method in TimerThread
657 private TimerTask[] queue = new TimerTask[128]; field in TaskQueue
|
| /aosp_15_r20/libcore/ojluni/src/main/java/java/util/ |
| H A D | Timer.java | 131 private final TaskQueue queue = new TaskQueue(); field in Timer
147 private final TaskQueue queue; field in Timer.ThreadReaper
150 ThreadReaper(TaskQueue queue, TimerThread thread) { in ThreadReaper()
155 public void run() { in run() method in Timer.ThreadReaper
569 private TaskQueue queue; field in TimerThread
571 TimerThread(TaskQueue queue) { in TimerThread()
575 public void run() { in run() method in TimerThread
657 private TimerTask[] queue = new TimerTask[128]; field in TaskQueue
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/ |
| D | Timer.java | 131 private final TaskQueue queue = new TaskQueue(); field in Timer
147 private final TaskQueue queue; field in Timer.ThreadReaper
150 ThreadReaper(TaskQueue queue, TimerThread thread) { in ThreadReaper()
155 public void run() { in run() method in Timer.ThreadReaper
569 private TaskQueue queue; field in TimerThread
571 TimerThread(TaskQueue queue) { in TimerThread()
575 public void run() { in run() method in TimerThread
657 private TimerTask[] queue = new TimerTask[128]; field in TaskQueue
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| H A D | EventLoop.common.kt | 58 val queue = unconfinedQueue ?: return Long.MAX_VALUE in <lambda>() constant in kotlinx.coroutines.EventLoop
63 val queue = unconfinedQueue ?: return false in <lambda>() constant
81 val queue = unconfinedQueue ?: in <lambda>() constant
193 return when (val queue = _queue.value) { constant in kotlinx.coroutines.EventLoopImplBase
203 val queue = _queue.value constant
296 _queue.loop { queue -> in enqueueImpl() method
323 _queue.loop { queue -> in dequeue() method
341 _queue.loop { queue -> in closeQueue() method
490 override fun run() { with(cont) { resumeUndispatched(Unit) } } in toString() method in kotlinx.coroutines.EventLoopImplBase
498 override fun run() { block.run() } in run() method
|
| /aosp_15_r20/external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| H A D | TargetVM.java | 107 public void run() { in run() method in TargetVM
261 EventQueueImpl queue = (EventQueueImpl)iter.next(); in notifyDequeueEventSet() local
274 EventQueueImpl queue = (EventQueueImpl)iter.next(); in queueEventSet() local
313 void addEventQueue(EventQueueImpl queue) { in addEventQueue()
350 public void run() { in run() method in TargetVM.EventController
|
| H A D | InternalEventHandler.java | 34 EventQueueImpl queue; field in InternalEventHandler
37 InternalEventHandler(VirtualMachineImpl vm, EventQueueImpl queue) in InternalEventHandler()
47 public void run() { in run() method in InternalEventHandler
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jsAndWasmShared/test/ |
| H A D | MessageQueueTest.kt | 9 private val queue = object : MessageQueue() { in <lambda>() constant in kotlinx.coroutines.MessageQueueTest
21 override fun run() { in <lambda>() method in kotlinx.coroutines.MessageQueueTest.Box
27 override fun run() { in <lambda>() method in kotlinx.coroutines.MessageQueueTest.ReBox
|
| /aosp_15_r20/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/audio_util/ |
| D | MediaPlayerList.java | 115 void run(MediaData data); in run() method
117 void run(boolean availablePlayers, boolean addressedPlayers, boolean uids); in run() method
121 void run(int playerId, boolean success, String rootId, int numItems); in run() method
125 void run(String parentId, List<ListItem> items); in run() method
485 final List<Metadata> queue = player.getCurrentQueue(); in getCurrentMediaId() local
933 List<Metadata> queue = new ArrayList<Metadata>(); in removeMediaPlayer() local
1194 List<Metadata> queue = new ArrayList<Metadata>(); in updateMediaForAudioPlayback() local
|
| /aosp_15_r20/external/ComputeLibrary/src/core/CL/kernels/ |
| H A D | CLInstanceNormalizationLayerKernel.cpp | 128 void CLComputeMeanVariance::run(const Window &window, cl::CommandQueue &queue) in run() function in arm_compute::CLComputeMeanVariance
205 void CLInstanceNormalizationLayerKernel::run(const Window &window, cl::CommandQueue &queue) in run() function in arm_compute::CLInstanceNormalizationLayerKernel
|
| /aosp_15_r20/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ref/ |
| H A D | ReferenceTest.java | 181 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in test_get_WeakReference() local
233 public void run() { in test_subclass() method in ReferenceTest.TestThread
288 private WeakReference<Object> newWeakReference(ReferenceQueue<Object> queue) { in newWeakReference()
346 public void run() { in test_finalizeReferenceInteraction() method in ReferenceTest.TestThread
|
| /aosp_15_r20/external/guava/android/guava/src/com/google/common/base/internal/ |
| H A D | Finalizer.java | 65 ReferenceQueue<Object> queue, in startFinalizer()
115 private final ReferenceQueue<Object> queue; field in Finalizer
130 ReferenceQueue<Object> queue, in Finalizer()
143 public void run() { in run() method in Finalizer
|
| /aosp_15_r20/external/guava/guava/src/com/google/common/base/internal/ |
| H A D | Finalizer.java | 65 ReferenceQueue<Object> queue, in startFinalizer()
115 private final ReferenceQueue<Object> queue; field in Finalizer
130 ReferenceQueue<Object> queue, in Finalizer()
143 public void run() { in run() method in Finalizer
|
| /aosp_15_r20/external/webrtc/api/task_queue/ |
| H A D | task_queue_test.cc | 34 auto queue = CreateTaskQueue(factory, "Construct"); in TEST_P() local
41 auto queue = CreateTaskQueue(factory, "PostAndCheckCurrent"); in TEST_P() local
59 auto queue = CreateTaskQueue(factory, "PostCustomImplementation"); in TEST_P() local
78 auto queue = CreateTaskQueue(factory, "PostDelayedZero"); in TEST_P() local
87 auto queue = CreateTaskQueue(factory, "PostFromQueue"); in TEST_P() local
97 auto queue = in TEST_P() local
118 auto queue = CreateTaskQueue(factory, "PostMultipleDelayed"); in TEST_P() local
137 rtc::Event run; in TEST_P() local
139 auto queue = CreateTaskQueue(factory, "PostDelayedAfterDestruct"); in TEST_P() local
257 auto queue = CreateTaskQueue(factory, "PostTwoWithSharedUnprotectedState"); in TEST_P() local
|
| /aosp_15_r20/external/python/cpython3/Lib/test/ |
| D | test_queue.py | 33 def run(self): member in _TriggerThread
251 queue = py_queue variable in PyQueueTest
256 queue = c_queue variable in CQueueTest
267 queue = py_queue variable in PyLifoQueueTest
272 queue = c_queue variable in CLifoQueueTest
283 queue = py_queue variable in PyPriorityQueueTest
288 queue = c_queue variable in CPriorityQueueTest
413 queue = py_queue variable in PyFailingQueueTest
418 queue = c_queue variable in CFailingQueueTest
603 queue = py_queue variable in PySimpleQueueTest
[all …]
|
| /aosp_15_r20/external/webrtc/api/ |
| H A D | sequence_checker_unittest.cc | 46 void RunOnDifferentThread(rtc::FunctionView<void()> run) { in RunOnDifferentThread()
82 TaskQueueForTest queue; in TEST() local
87 TaskQueueForTest queue; in TEST() local
103 TaskQueueForTest queue; in TEST() local
175 TaskQueueForTest queue; in TestAnnotationsOnWrongQueue() local
|
| /aosp_15_r20/external/icu/android_icu4j/src/main/java/android/icu/impl/ |
| H A D | ICUNotifier.java | 120 private final List<EventListener[]> queue = new ArrayList<EventListener[]>(); field in ICUNotifier.NotifyThread
129 public void queue(EventListener[] list) { in queue() method in ICUNotifier.NotifyThread
141 public void run() { in run() method in ICUNotifier.NotifyThread
|
| /aosp_15_r20/external/icu/icu4j/main/core/src/main/java/com/ibm/icu/impl/ |
| H A D | ICUNotifier.java | 118 private final List<EventListener[]> queue = new ArrayList<EventListener[]>(); field in ICUNotifier.NotifyThread
127 public void queue(EventListener[] list) { in queue() method in ICUNotifier.NotifyThread
139 public void run() { in run() method in ICUNotifier.NotifyThread
|
| /aosp_15_r20/external/ComputeLibrary/src/common/ |
| H A D | IOperator.cpp | 49 StatusCode IOperator::run(ITensorPack &tensors) in run() function in arm_compute::IOperator
55 StatusCode IOperator::run(IQueue &queue, ITensorPack &tensors) in run() function in arm_compute::IOperator
|
| /aosp_15_r20/external/google-cloud-java/java-tasks/google-cloud-tasks/src/test/java/com/google/cloud/tasks/v2beta3/ |
| H A D | CloudTasksSmokeTest.java | 36 static Queue queue; field in CloudTasksSmokeTest
67 public void run() { in run() method in CloudTasksSmokeTest
71 public static void createTask(String project, String location, String queue) throws IOException { in createTask()
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | UninterruptiblesTest.java | 210 BlockingQueue<String> queue = new ArrayBlockingQueue<>(999); in testPutWithNoWait() local
217 TimedPutQueue queue = TimedPutQueue.createWithDelay(20); in testPutNoInterrupt() local
223 TimedPutQueue queue = TimedPutQueue.createWithDelay(50); in testPutSingleInterrupt() local
230 TimedPutQueue queue = TimedPutQueue.createWithDelay(100); in testPutMultiInterrupt() local
239 BlockingQueue<String> queue = new ArrayBlockingQueue<>(1); in testTakeWithNoWait() local
246 TimedTakeQueue queue = TimedTakeQueue.createWithDelay(20); in testTakeNoInterrupt() local
252 TimedTakeQueue queue = TimedTakeQueue.createWithDelay(50); in testTakeSingleInterrupt() local
259 TimedTakeQueue queue = TimedTakeQueue.createWithDelay(100); in testTakeMultiInterrupt() local
569 final BlockingQueue<String> queue; field in UninterruptiblesTest.Completion.TimedPutQueue
594 private static void scheduleEnableWrites(BlockingQueue<String> queue, long countdownInMillis) { in scheduleEnableWrites()
[all …]
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | UninterruptiblesTest.java | 209 BlockingQueue<String> queue = new ArrayBlockingQueue<>(999); in testPutWithNoWait() local
216 TimedPutQueue queue = TimedPutQueue.createWithDelay(20); in testPutNoInterrupt() local
222 TimedPutQueue queue = TimedPutQueue.createWithDelay(50); in testPutSingleInterrupt() local
229 TimedPutQueue queue = TimedPutQueue.createWithDelay(100); in testPutMultiInterrupt() local
238 BlockingQueue<String> queue = new ArrayBlockingQueue<>(1); in testTakeWithNoWait() local
245 TimedTakeQueue queue = TimedTakeQueue.createWithDelay(20); in testTakeNoInterrupt() local
251 TimedTakeQueue queue = TimedTakeQueue.createWithDelay(50); in testTakeSingleInterrupt() local
258 TimedTakeQueue queue = TimedTakeQueue.createWithDelay(100); in testTakeMultiInterrupt() local
548 final BlockingQueue<String> queue; field in UninterruptiblesTest.Completion.TimedPutQueue
573 private static void scheduleEnableWrites(BlockingQueue<String> queue, long countdownInMillis) { in scheduleEnableWrites()
[all …]
|
| /aosp_15_r20/libcore/ojluni/src/main/java/jdk/internal/ref/ |
| H A D | CleanerImpl.java | 63 final ReferenceQueue<Object> queue; field in CleanerImpl
101 public CleanerImpl(ReferenceQueue<Object> queue) { in CleanerImpl()
158 public void run() { in run() method in CleanerImpl
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| H A D | LimitedDispatcher.kt | 31 private val queue = LockFreeTaskQueue<Runnable>(singleConsumer = false) in <lambda>() constant
107 override fun run() { in <lambda>() method in kotlinx.coroutines.internal.LimitedDispatcher.<lambda>.Worker
|