| /frameworks/base/services/tests/servicestests/src/com/android/server/people/data/ |
| D | MockScheduledExecutorService.java | 26 import java.util.concurrent.Callable;
92 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule()
134 public <T> Future<T> submit(Callable<T> task) { in submit()
159 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
165 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, in invokeAll()
171 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
177 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
191 private final Callable<V> mCallable;
199 MockScheduledFuture(Callable<V> callable, long delay, TimeUnit timeUnit) { in MockScheduledFuture()
203 private MockScheduledFuture(Runnable runnable, Callable<V> callable, long delay) { in MockScheduledFuture()
[all …]
|
| /frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/ |
| D | TestExecutorService.java | 28 import java.util.concurrent.Callable;
43 private final Callable<T> mTask;
47 CompletedFuture(Callable<T> task) { in CompletedFuture()
52 CompletedFuture(Callable<T> task, long delayMs) { in CompletedFuture()
59 mTask = (Callable<T>) Executors.callable(task); in CompletedFuture()
146 public <T> Future<T> submit(Callable<T> task) { in submit()
162 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll()
167 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, in invokeAll()
173 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) { in invokeAny()
178 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAny()
[all …]
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/apphibernation/ |
| D | HibernationStateDiskStoreTest.java | 42 import java.util.concurrent.Callable;
149 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule()
191 public <T> Future<T> submit(Callable<T> task) { in submit()
206 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
212 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, in invokeAll()
218 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
224 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| /frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/notification/stack/ui/view/ |
| D | NotificationStatsLoggerTest.kt | 34 import java.util.concurrent.Callable in <lambda>()
69 val callable = Callable { locations } in <lambda>()
105 val callable = Callable { locations } in <lambda>()
111 val emptyCallable = Callable { emptyMap<String, Int>() } in <lambda>()
142 val callable = Callable { locations } in <lambda>()
148 val emptyCallable = Callable { emptyMap<String, Int>() } in <lambda>()
197 val callable = spy(Callable { locations }) in <lambda>()
203 val otherCallable = spy(Callable { locations }) in <lambda>()
217 val callable = Callable { locations } in <lambda>()
361 val callable = Callable { locations } in <lambda>()
[all …]
|
| /frameworks/base/services/tests/displayservicetests/src/com/android/server/display/ |
| D | WakelockControllerTest.java | 37 import java.util.concurrent.Callable;
257 Callable<Boolean> isWakelockAcquiredCallable) in verifyWakelockAcquisitionAndReaquisition()
264 Callable<Boolean> isWakelockAcquiredCallable) in verifyWakelockReleaseAndRerelease()
271 Callable<Boolean> isWakelockAcquiredCallable) in verifyWakelockAcquisition()
278 Callable<Boolean> isWakelockAcquiredCallable) in verifyWakelockReacquisition()
284 private void verifyWakelockRelease(int wakelockId, Callable<Boolean> isWakelockAcquiredCallable) in verifyWakelockRelease()
291 Callable<Boolean> isWakelockAcquiredCallable) in verifyWakelockRerelease()
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/notification/stack/ui/view/ |
| D | NotificationStatsLogger.kt | 20 import java.util.concurrent.Callable
33 locationsProvider: Callable<Map<String, Int>>,
|
| /frameworks/libs/systemui/viewcapturelib/src/com/android/app/viewcapture/ |
| D | LooperExecutor.java | 21 import java.util.concurrent.Callable;
52 public <T> Future<T> submit(Callable<T> task) { in submit()
|
| /frameworks/base/tests/testables/src/android/testing/ |
| D | PollingCheck.java | 20 import java.util.concurrent.Callable;
62 public static void check(CharSequence message, long timeout, Callable<Boolean> condition) in check()
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/tests/src/androidx/media/filterfw/ |
| D | MffTestCase.java | 24 import java.util.concurrent.Callable;
43 FutureTask<MffContext> task = new FutureTask<MffContext>(new Callable<MffContext>() { in setUp()
|
| /frameworks/base/packages/SystemUI/shared/src/com/android/systemui/shared/recents/view/ |
| D | AppTransitionAnimationSpecsFuture.java | 25 import java.util.concurrent.Callable;
36 new Callable<List<AppTransitionAnimationSpecCompat>>() {
|
| /frameworks/base/packages/SettingsLib/src/com/android/settingslib/utils/ |
| D | ThreadUtils.java | 27 import java.util.concurrent.Callable;
84 public static <T> ListenableFuture<T> postOnBackgroundThread(@NonNull Callable<T> callable) { in postOnBackgroundThread()
|
| /frameworks/base/packages/SettingsLib/AvatarPicker/src/ |
| D | ThreadUtils.java | 28 import java.util.concurrent.Callable;
86 public static <T> ListenableFuture<T> postOnBackgroundThread(@NonNull Callable<T> callable) { in postOnBackgroundThread()
|
| /frameworks/base/services/core/java/com/android/server/timezonedetector/location/ |
| D | ThreadingDomain.java | 24 import java.util.concurrent.Callable;
107 @NonNull Callable<V> callable, @DurationMillisLong long durationMillis) in postAndWait()
|
| D | HandlerThreadingDomain.java | 24 import java.util.concurrent.Callable;
65 <V> V postAndWait(@NonNull Callable<V> callable, @DurationMillisLong long durationMillis) in postAndWait()
|
| /frameworks/base/core/tests/coretests/testdoubles/src/com/android/internal/util/ |
| D | FakeLatencyTracker.java | 38 import java.util.concurrent.Callable;
52 private final AtomicReference<Callable<Boolean>> mShouldClosePropertiesUpdatedCallable =
136 Callable<Boolean> shouldClosePropertiesUpdated = in onDeviceConfigPropertiesUpdated()
244 public void waitForPropertiesCondition(Callable<Boolean> shouldClosePropertiesUpdatedCallable) in waitForPropertiesCondition()
|
| /frameworks/base/services/tests/wmtests/src/com/android/server/wm/ |
| D | SystemServiceTestsBase.java | 31 import java.util.concurrent.Callable;
76 <T> T awaitInWmLock(Callable<T> callable) { in awaitInWmLock()
|
| D | WindowManagerGlobalLockRule.java | 32 import java.util.concurrent.Callable;
80 <T> T waitForLocked(Callable<T> callable) { in waitForLocked()
|
| /frameworks/base/services/tests/timetests/src/com/android/server/timezonedetector/location/ |
| D | TestThreadingDomain.java | 29 import java.util.concurrent.Callable;
83 <V> V postAndWait(Callable<V> callable, long durationMillis) { in postAndWait()
|
| /frameworks/base/core/java/android/view/ |
| D | InputEventSender.java | 29 import java.util.concurrent.Callable;
153 final RunnableFuture<Boolean> task = new FutureTask<>(new Callable<Boolean>() { in sendInputEvent()
|
| /frameworks/base/services/robotests/backup/src/com/android/server/backup/remote/ |
| D | RemoteCallTest.java | 43 import java.util.concurrent.Callable;
252 private static <T> Future<T> runInWorkerThreadAsync(Callable<T> supplier) { in runInWorkerThreadAsync()
258 private static <T> T runInWorkerThread(Callable<T> supplier) throws Exception { in runInWorkerThread()
|
| /frameworks/base/core/tests/coretests/src/android/graphics/ |
| D | PaintNativeInstanceTest.kt | 26 import java.util.concurrent.Callable in <lambda>()
121 class PaintTask(private val mPaint: Paint) : Callable<Bitmap> { in <lambda>()
|
| /frameworks/base/services/robotests/backup/src/com/android/server/backup/testing/ |
| D | TestUtils.java | 37 import java.util.concurrent.Callable;
172 public static <T> T uncheck(Callable<T> callable) { in uncheck()
|
| /frameworks/base/services/tests/timetests/src/com/android/server/timedetector/ |
| D | ArrayMapWithHistoryTest.java | 34 import java.util.concurrent.Callable;
164 String description, Callable<?> callable) throws Exception { in assertThrowsArrayIndexOutOfBoundsException()
|
| /frameworks/base/services/tests/InputMethodSystemServerTests/src/com/android/server/inputmethod/ |
| D | InputMethodBindingControllerTest.java | 49 import java.util.concurrent.Callable;
220 private static <V> V callOnMainSync(Callable<V> callable) { in callOnMainSync()
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/am/ |
| D | AnrHelperTest.java | 52 import java.util.concurrent.Callable;
101 doReturn(mEarlyDumpFuture).when(earlyDumpExecutorService).submit(any(Callable.class)); in setUp()
|