Home
last modified time | relevance | path

Searched refs:Callable (Results 1 – 25 of 94) sorted by relevance

1234

/packages/services/Telephony/tests/src/com/android/
DTestExecutorService.java22 import java.util.concurrent.Callable;
40 private final Callable<T> mTask;
45 CompletedFuture(Callable<T> task) { in CompletedFuture()
50 CompletedFuture(Callable<T> task, long delayMs) { in CompletedFuture()
160 public <T> Future<T> submit(Callable<T> task) { in submit()
182 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll()
187 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, in invokeAll()
193 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) { in invokeAny()
198 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAny()
214 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule()
/packages/modules/AdServices/shared/libraries/device-side/java/com/android/adservices/shared/testing/common/
DBlockingCallableWrapper.java22 import java.util.concurrent.Callable;
36 public final class BlockingCallableWrapper<T> implements Callable<T> {
37 private final Callable<T> mDelegate;
46 public static <T> BlockingCallableWrapper<T> createNonBlockableInstance(Callable<T> delegate) { in createNonBlockableInstance()
54 public static <T> BlockingCallableWrapper<T> createBlockableInstance(Callable<T> delegate) { in createBlockableInstance()
58 private BlockingCallableWrapper(boolean waitBeforeStartingWork, Callable<T> delegate) { in BlockingCallableWrapper()
/packages/apps/Launcher3/tests/src/com/android/launcher3/util/
DItemInflaterTest.kt53 import java.util.concurrent.Callable in <lambda>()
118 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
131 Callable { underTest.inflateItem(itemInfo, modelWriter) } in <lambda>()
147 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
164 Callable { underTest.inflateItem(itemInfo, modelWriter) } in <lambda>()
180 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
197 Callable { underTest.inflateItem(itemInfo, modelWriter) } in <lambda>()
210 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
223 Callable { underTest.inflateItem(itemInfo, modelWriter) } in <lambda>()
236 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
[all …]
/packages/services/Telecomm/tests/src/com/android/server/telecom/tests/
DTestScheduledExecutorService.java28 import java.util.concurrent.Callable;
46 private final Callable<T> mTask;
50 CompletedFuture(Callable<T> task) { in CompletedFuture()
56 CompletedFuture(Callable<T> task, long delayMs) { in CompletedFuture()
63 mTask = (Callable<T>) Executors.callable(task); in CompletedFuture()
150 public <T> Future<T> submit(Callable<T> task) { in submit()
166 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll()
171 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, in invokeAll()
177 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) { in invokeAny()
182 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAny()
[all …]
/packages/modules/Bluetooth/system/blueberry/utils/ui_pages/
Dutils.py2 from typing import Any, Callable, Dict
5 def dr_wakeup_before_op(op: Callable[..., Any]) -> Callable[..., Any]: argument
14 def _wrapper(*args: Any, **kargs: Dict[str, Any]) -> Callable[..., Any]:
/packages/modules/DeviceLock/service/java/com/android/server/devicelock/
DDeviceLockControllerConnectorImpl.java40 import java.util.concurrent.Callable;
83 private <Result> void callControllerApi(Callable<Void> body, in callControllerApi()
306 callControllerApi(new Callable<Void>() {
326 callControllerApi(new Callable<Void>() {
348 callControllerApi(new Callable<Void>() {
375 callControllerApi(new Callable<Void>() {
395 callControllerApi(new Callable<Void>() {
415 callControllerApi(new Callable<Void>() {
435 callControllerApi(new Callable<Void>() {
455 callControllerApi(new Callable<Void>() {
[all …]
/packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/
DTestScheduledExecutorService.java30 import java.util.concurrent.Callable;
76 public <T> Future<T> submit(Callable<T> task) { in submit()
91 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
97 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, in invokeAll()
103 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
109 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
127 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule()
/packages/services/Car/service/src/com/android/car/oem/
DCarOemProxyServiceHelper.java35 import java.util.concurrent.Callable;
118 private Callable<String> mOemStackTracer;
163 public <T> T doBinderTimedCallWithDefaultValue(String callerTag, Callable<T> callable, in doBinderTimedCallWithDefaultValue()
203 public <T> T doBinderTimedCallWithTimeout(String callerTag, Callable<T> callable, in doBinderTimedCallWithTimeout()
259 Callable<T> callable, long defaultTimeoutMs, in doBinderCallWithDefaultValueAndDelayedWaitAndCrash()
381 public <T> Optional<T> doBinderCallWithTimeoutCrash(String callerTag, Callable<T> callable) { in doBinderCallWithTimeoutCrash()
450 Callable<String> oemStackTracer = null; in crashCarService()
521 public void updateOemStackCall(Callable<String> oemStackTracer) { in updateOemStackCall()
/packages/apps/Contacts/src/com/android/contacts/compat/
DCallableCompat.java20 import android.provider.ContactsContract.CommonDataKinds.Callable;
28 Uri.withAppendedPath(Callable.CONTENT_URI, "filter_enterprise");
34 return Callable.CONTENT_FILTER_URI; in getContentFilterUri()
/packages/apps/Contacts/tests/src/com/android/contacts/test/
DIntegrationTestUtils.java33 import java.util.concurrent.Callable;
58 runOnUiThreadAndGetTheResult(new Callable<Void>() { in clickButton()
73 return runOnUiThreadAndGetTheResult(new Callable<CharSequence>() { in getText()
89 public <T> T runOnUiThreadAndGetTheResult(Callable<T> callable) throws Throwable {
148 return runOnUiThreadAndGetTheResult(new Callable<List<TextView>>() {
/packages/modules/AppSearch/service/java/com/android/server/appsearch/util/
DRateLimitedExecutor.java31 import java.util.concurrent.Callable;
231 public <T> Future<T> submit(Callable<T> task) { in submit()
246 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
253 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
259 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
265 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
/packages/modules/AdServices/shared/libraries/side-less/java/com/android/adservices/shared/testing/
DSupportedByConditionRule.java25 import java.util.concurrent.Callable;
36 private final Callable<Boolean> mCondition;
41 public SupportedByConditionRule(String message, Callable<Boolean> condition) { in SupportedByConditionRule()
/packages/apps/Contacts/src/com/android/contacts/util/concurrent/
DContactsExecutors.java17 import java.util.concurrent.Callable;
120 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { in schedule()
175 private final Callable<T> mTask;
180 private HandlerFuture(Handler handler, long delay, TimeUnit timeUnit, Callable<T> task) { in HandlerFuture()
233 return new HandlerFuture<>(handler, delay, unit, new Callable<Void>() { in fromRunnable()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/common/
DRetryStrategyImpl.java28 import java.util.concurrent.Callable;
44 @NonNull Callable<ListenableFuture<T>> listenableFutureToRetry, in call()
57 Callable<ListenableFuture<T>> listenableFutureToRetry, in retry()
DRetryStrategy.java24 import java.util.concurrent.Callable;
35 Callable<ListenableFuture<T>> listenableFutureToRetry, in call()
DNoOpRetryStrategyImpl.java26 import java.util.concurrent.Callable;
32 Callable<ListenableFuture<T>> listenableFutureToRetry, in call()
/packages/modules/AdServices/adservices/tests/test-util/java/com/android/adservices/common/
DDeviceSideDeviceConfigHelper.java34 import java.util.concurrent.Callable;
84 private <T> T callWithDeviceConfigPermissions(Callable<T> c) { in callWithDeviceConfigPermissions()
88 static <T> T callWithDeviceConfigPermissions(boolean withPermissions, Callable<T> c) { in callWithDeviceConfigPermissions()
/packages/apps/Messaging/src/android/support/v7/mms/
DDownloadRequest.java32 import java.util.concurrent.Callable;
84 final Callable<Boolean> copyDownloadedPduToOutput = new Callable<Boolean>() { in writePduToContentUri()
DSendRequest.java33 import java.util.concurrent.Callable;
103 final Callable<byte[]> copyPduToArray = new Callable<byte[]>() { in readPduFromContentUri()
/packages/apps/Dialer/java/com/android/dialer/common/concurrent/
DUiThreadExecutor.java22 import java.util.concurrent.Callable;
62 public <V> ListenableFuture<V> submit(final Callable<V> task) { in submit()
DDialerFutureSerializer.java27 import java.util.concurrent.Callable;
42 public <T> ListenableFuture<T> submit(final Callable<T> callable, Executor executor) { in submit()
/packages/apps/TvSettings/SettingsAPI/java/com/android/tv/settings/library/util/
DThreadUtils.java22 import java.util.concurrent.Callable;
77 public static Future postOnBackgroundThread(Callable callable) { in postOnBackgroundThread()
/packages/apps/SettingsIntelligence/src/com/android/settings/intelligence/search/query/
DSearchQueryTask.java27 import java.util.concurrent.Callable;
43 public static abstract class QueryWorker implements Callable<List<? extends SearchResult>> {
/packages/apps/Settings/src/com/android/settings/network/helper/
DQuerySimSlotIndex.java24 import java.util.concurrent.Callable;
31 public class QuerySimSlotIndex implements Callable<AtomicIntegerArray> {
/packages/apps/Gallery2/src/com/android/gallery3d/app/
DAlbumDataLoader.java33 import java.util.concurrent.Callable;
222 private <T> T executeAndWait(Callable<T> callable) { in executeAndWait()
244 private class GetUpdateInfo implements Callable<UpdateInfo> {
274 private class UpdateContent implements Callable<Void> {

1234