| /packages/services/Car/service/src/com/android/car/oem/ |
| D | CarOemProxyServiceHelper.java | 163 public <T> T doBinderTimedCallWithDefaultValue(String callerTag, Callable<T> callable, in doBinderTimedCallWithDefaultValue() argument
171 Future<T> result = mThreadPool.submit(callable); in doBinderTimedCallWithDefaultValue()
203 public <T> T doBinderTimedCallWithTimeout(String callerTag, Callable<T> callable, in doBinderTimedCallWithTimeout() argument
211 Future<T> result = mThreadPool.submit(callable); in doBinderTimedCallWithTimeout()
259 Callable<T> callable, long defaultTimeoutMs, in doBinderCallWithDefaultValueAndDelayedWaitAndCrash() argument
267 Future<T> result = mThreadPool.submit(callable); in doBinderCallWithDefaultValueAndDelayedWaitAndCrash()
381 public <T> Optional<T> doBinderCallWithTimeoutCrash(String callerTag, Callable<T> callable) { in doBinderCallWithTimeoutCrash() argument
388 Future<T> result = mThreadPool.submit(callable); in doBinderCallWithTimeoutCrash()
|
| /packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| D | DialerFutureSerializer.java | 42 public <T> ListenableFuture<T> submit(final Callable<T> callable, Executor executor) { in submit() argument
43 return submitAsync(() -> immediateFuture(callable.call()), executor); in submit()
53 public <T> ListenableFuture<T> submitAsync(final AsyncCallable<T> callable, Executor executor) { in submitAsync() argument
60 return callable.call(); in submitAsync()
|
| /packages/services/Car/tests/carservice_unit_test/src/com/android/car/oem/ |
| D | CarOemProxyServiceHelperTest.java | 173 Callable<Integer> callable = () -> { in testCircularCallSingleCaller() local
186 mCarOemProxyServiceHelper.doBinderTimedCallWithTimeout(CALLER_TAG, callable, in testCircularCallSingleCaller()
198 mCarOemProxyServiceHelper.doBinderTimedCallWithTimeout(CALLER_TAG, callable, in testCircularCallSingleCaller()
214 Callable<Integer> callable = () -> { in testCircularCallMultipleCaller() local
230 callable, in testCircularCallMultipleCaller()
241 mCarOemProxyServiceHelper.doBinderTimedCallWithTimeout(CALLER_TAG, callable, in testCircularCallMultipleCaller()
|
| /packages/apps/TvSettings/SettingsAPI/java/com/android/tv/settings/library/util/ |
| D | ThreadUtils.java | 77 public static Future postOnBackgroundThread(Callable callable) { in postOnBackgroundThread() argument
78 return getThreadExecutor().submit(callable); in postOnBackgroundThread()
|
| /packages/modules/OnDevicePersonalization/tests/servicetests/src/com/android/ondevicepersonalization/services/download/ |
| D | OnDevicePersonalizationDataProcessingAsyncCallableTests.java | 185 OnDevicePersonalizationDataProcessingAsyncCallable callable = in testRun() local
189 callable.call(); in testRun()
245 OnDevicePersonalizationDataProcessingAsyncCallable callable = in testRunOldDataDownloaded() local
249 callable.call(); in testRunOldDataDownloaded()
|
| /packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/storage/ |
| D | DlcClient.java | 143 protected <T> ListenableFuture<T> call(Callable<T> callable) { in call() argument
154 return callable.call(); in call()
|
| /packages/apps/Contacts/tests/src/com/android/contacts/test/ |
| D | IntegrationTestUtils.java | 89 public <T> T runOnUiThreadAndGetTheResult(Callable<T> callable) throws Throwable {
90 FutureTask<T> future = new FutureTask<T>(callable);
|
| /packages/modules/AdServices/adservices/tests/perf/src/android/adservices/test/scenario/adservices/fledge/ |
| D | ServerAuctionE2ETestBase.java | 133 Callable<T> callable, in retryOnCondition() argument
144 return callable.call(); in retryOnCondition()
|
| /packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/examplestore/ |
| D | FederatedExampleIteratorTest.java | 312 private <T> T runInBackgroundAndWait(Callable<T> callable) throws Exception { in runInBackgroundAndWait() argument
313 return waitOnFuture(runInBackground(callable)); in runInBackgroundAndWait()
339 private static <T> Future<T> runInBackground(Callable<T> callable) throws Exception { in runInBackground() argument
347 return callable.call(); in runInBackground()
|
| /packages/modules/OnDevicePersonalization/tests/manualtests/src/com/android/ondevicepersonalization/services/download/ |
| D | OnDevicePersonalizationDataProcessingAsyncCallableManualTests.java | 92 OnDevicePersonalizationDataProcessingAsyncCallable callable = in testRun() local
94 callable.call().get(); in testRun()
|
| /packages/apps/Settings/tests/robotests/src/com/android/settings/fuelgauge/ |
| D | AdvancedPowerUsageDetailTest.java | 211 Answer<Void> callable = in setUp() local
217 doAnswer(callable) in setUp()
220 doAnswer(callable).when(mActivity).startActivity(captor.capture()); in setUp()
221 doAnswer(callable).when(mContext).startActivity(captor.capture()); in setUp()
|
| D | PowerBackgroundUsageDetailTest.java | 184 Answer<Void> callable = in setUp() local
190 doAnswer(callable) in setUp()
193 doAnswer(callable).when(mActivity).startActivity(captor.capture()); in setUp()
|
| /packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
| D | ContactsExecutors.java | 120 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule() argument
121 final HandlerFuture<V> future = new HandlerFuture<>(mHandler, delay, unit, callable); in schedule()
|
| /packages/services/Telephony/tests/src/com/android/ |
| D | TestExecutorService.java | 214 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule() argument
216 CompletedFuture<V> f = new CompletedFuture<>(callable, millisDelay); in schedule()
|
| /packages/services/Car/car-builtin-lib/src/android/car/builtin/app/ |
| D | ActivityManagerHelper.java | 171 private static <T> T runRemotely(Callable<T> callable, String format, Object...args) { in runRemotely() argument
173 return callable.call(); in runRemotely()
|
| /packages/services/Telecomm/tests/src/com/android/server/telecom/tests/ |
| D | TestScheduledExecutorService.java | 63 mTask = (Callable<T>) Executors.callable(task); in CompletedFuture()
199 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule() argument
|
| /packages/apps/Gallery2/src/com/android/gallery3d/app/ |
| D | AlbumDataLoader.java | 222 private <T> T executeAndWait(Callable<T> callable) { in executeAndWait() argument
223 FutureTask<T> task = new FutureTask<T>(callable); in executeAndWait()
|
| D | AlbumSetDataLoader.java | 313 private <T> T executeAndWait(Callable<T> callable) { in executeAndWait() argument
314 FutureTask<T> task = new FutureTask<T>(callable); in executeAndWait()
|
| /packages/modules/Bluetooth/system/blueberry/tests/gd_sl4a/lib/ |
| D | gd_sl4a_base_test.py | 131 if not callable(attr) or not GdSl4aBaseTestClass.__is_entry_function(name):
|
| /packages/services/Car/service/src/com/android/car/ |
| D | ICarImpl.java | 1060 Class<T> cls, T serviceFromBuilder, Callable<T> callable, in getFromBuilderOrConstruct() argument
1067 return constructWithTrace(t, cls, callable, allServices); in getFromBuilderOrConstruct()
1071 Class<T> cls, Callable<T> callable, List<CarSystemService> allServices) { in constructWithTrace() argument
1075 constructed = callable.call(); in constructWithTrace()
|
| /packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
| D | TestScheduledExecutorService.java | 127 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule() argument
|
| /packages/services/Car/libs/car-test-lib/src/android/car/test/mocks/ |
| D | AndroidMockitoHelper.java | 542 public static <T> T syncCallOnMainThread(long timeoutMs, Callable<T> callable) in syncCallOnMainThread() argument
562 result = callable.call(); in syncCallOnMainThread()
|
| /packages/modules/Connectivity/tests/cts/net/src/android/net/cts/ |
| D | ConnectivityDiagnosticsManagerTest.java | 188 private <T> T callWithShellPermissionIdentity(Callable<T> callable, String... permissions) in callWithShellPermissionIdentity() argument
191 return SystemUtil.callWithShellPermissionIdentity(callable, permissions); in callWithShellPermissionIdentity()
|
| /packages/modules/Bluetooth/system/blueberry/tests/sl4a_sl4a/lib/ |
| D | sl4a_sl4a_base_test.py | 172 if not callable(attr) or not Sl4aSl4aBaseTestClass.__is_entry_function(name):
|
| /packages/modules/Virtualization/tests/hostside/java/com/android/microdroid/test/ |
| D | MicrodroidHostTests.java | 216 long timeoutMillis, Callable<T> callable, org.hamcrest.Matcher<T> matcher) in assertThatEventually() argument
220 && !matcher.matches(callable.call())) { in assertThatEventually()
223 assertThat(callable.call(), matcher); in assertThatEventually()
|