Home
last modified time | relevance | path

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

12345

/aosp12/system/libbase/include/android-base/
H A Dfunction_ref.h90 template <class Callable, class = std::enable_if_t<
91 std::is_invocable_r<Ret, Callable, Args...>::value &&
92 !std::is_same_v<function_ref, std::remove_reference_t<Callable>>>>
93 function_ref(Callable&& c) noexcept in function_ref()
97 return (*reinterpret_cast<std::remove_reference_t<Callable>*>(self->mCallable))( in function_ref()
102 template <class Callable, class = std::enable_if_t<
103 std::is_invocable_r<Ret, Callable, Args...>::value &&
104 !std::is_same_v<function_ref, std::remove_reference_t<Callable>>>>
105 function_ref& operator=(Callable&& c) noexcept {
109 return (*reinterpret_cast<std::remove_reference_t<Callable>*>(self->mCallable))(
/aosp12/hardware/interfaces/biometrics/fingerprint/aidl/default/tests/
H A DWorkerThreadTest.cpp28 using aidl::android::hardware::biometrics::fingerprint::Callable;
38 ASSERT_TRUE(worker.schedule(Callable::from([promise = std::move(promise)]() mutable { in TEST()
54 ASSERT_TRUE(worker.schedule(Callable::from([promise = std::move(promise)]() mutable { in TEST()
66 ASSERT_TRUE(worker.schedule(Callable::from([] {}))); in TEST()
67 ASSERT_TRUE(worker.schedule(Callable::from([] {}))); in TEST()
69 EXPECT_FALSE(worker.schedule(Callable::from([] {}))); in TEST()
82 worker.schedule(Callable::from([&mut, &results, i] { in TEST()
91 worker.schedule(Callable::from([&mut, &cv, &finished] { in TEST()
114 ASSERT_TRUE(worker.schedule(Callable::from([promise = std::move(promise1)]() mutable { in TEST()
124 worker.schedule(Callable::from([promise = std::move(promise2), &value]() mutable { in TEST()
/aosp12/hardware/interfaces/biometrics/fingerprint/aidl/default/include/
H A DCallable.h23 class Callable {
26 virtual ~Callable() = default;
30 static std::unique_ptr<Callable> from(T func);
39 class Callable::AnyFuncWrapper : public Callable {
50 std::unique_ptr<Callable> Callable::from(T func) { in from()
H A DWorkerThread.h55 bool schedule(std::unique_ptr<Callable> task);
71 std::deque<std::unique_ptr<Callable>> mQueue;
/aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/people/data/
H A DMockScheduledExecutorService.java26 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 …]
/aosp12/packages/services/Telephony/tests/src/com/android/
H A 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()
/aosp12/frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/
H A DTestExecutorService.java28 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 …]
/aosp12/hardware/interfaces/biometrics/fingerprint/aidl/default/
H A DSession.cpp69 mWorker->schedule(Callable::from([this] { in generateChallenge()
82 mWorker->schedule(Callable::from([this, challenge] { in revokeChallenge()
99 mWorker->schedule(Callable::from([this, hat, cancFuture = std::move(cancFuture)] { in enroll()
121 mWorker->schedule(Callable::from([this, operationId, cancFuture = std::move(cancFuture)] { in authenticate()
142 mWorker->schedule(Callable::from([this, cancFuture = std::move(cancFuture)] { in detectInteraction()
160 mWorker->schedule(Callable::from([this] { in enumerateEnrollments()
173 mWorker->schedule(Callable::from([this, enrollmentIds] { in removeEnrollments()
186 mWorker->schedule(Callable::from([this] { in getAuthenticatorId()
199 mWorker->schedule(Callable::from([this] { in invalidateAuthenticatorId()
212 mWorker->schedule(Callable::from([this, hat] { in resetLockout()
H A DWorkerThread.cpp39 bool WorkerThread::schedule(std::unique_ptr<Callable> task) { in schedule()
61 std::unique_ptr<Callable> task = std::move(mQueue.front()); in threadFunc()
/aosp12/packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/
H A 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()
/aosp12/system/update_engine/common/
H A Dscoped_task_id.h93 template <typename Callable>
95 Callable&& callback, in PostTask()
110 template <typename Callable>
111 void ExecuteTask(Callable&& callback) { in ExecuteTask()
113 if constexpr (std::is_same_v<Callable&&, base::OnceClosure&&>) { in ExecuteTask()
/aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/apphibernation/
H A DHibernationStateDiskStoreTest.java42 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()
/aosp12/packages/apps/Contacts/src/com/android/contacts/compat/
H A DCallableCompat.java20 import android.provider.ContactsContract.CommonDataKinds.Callable;
28 Uri.withAppendedPath(Callable.CONTENT_URI, "filter_enterprise");
34 return Callable.CONTENT_FILTER_URI; in getContentFilterUri()
/aosp12/packages/apps/Contacts/tests/src/com/android/contacts/test/
H A 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>>() {
/aosp12/packages/apps/Contacts/src/com/android/contacts/util/concurrent/
H A 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()
/aosp12/frameworks/base/startop/scripts/app_startup/lib/
H A Dargs_utils.py4 from typing import Any, Callable, Dict, Iterable, List, NamedTuple, Tuple, \
13 NamedTupleMeta = Callable[
15 FilterFuncType = Callable[[NamedTuple], bool]
/aosp12/packages/apps/Messaging/src/android/support/v7/mms/
H A DDownloadRequest.java32 import java.util.concurrent.Callable;
84 final Callable<Boolean> copyDownloadedPduToOutput = new Callable<Boolean>() { in writePduToContentUri()
H A DSendRequest.java33 import java.util.concurrent.Callable;
103 final Callable<byte[]> copyPduToArray = new Callable<byte[]>() { in readPduFromContentUri()
/aosp12/packages/apps/Settings/src/com/android/settings/network/helper/
H A DQueryEsimCardId.java23 import java.util.concurrent.Callable;
29 public class QueryEsimCardId implements Callable<AtomicIntegerArray> {
/aosp12/packages/apps/Launcher3/tests/src/com/android/launcher3/util/rule/
H A DLauncherActivityRule.java26 import java.util.concurrent.Callable;
50 public Callable<Boolean> itemExists(final ItemOperator op) {
/aosp12/frameworks/base/tests/testables/src/android/testing/
H A DPollingCheck.java20 import java.util.concurrent.Callable;
62 public static void check(CharSequence message, long timeout, Callable<Boolean> condition) in check()
/aosp12/frameworks/base/packages/SettingsLib/src/com/android/settingslib/utils/
H A DThreadUtils.java21 import java.util.concurrent.Callable;
76 public static Future postOnBackgroundThread(Callable callable) { in postOnBackgroundThread()
/aosp12/art/test/708-jit-cache-churn/src/
H A DJitCacheChurnTest.java22 import java.util.concurrent.Callable;
71 private void runTasks(Callable<Integer> task) { in runTasks()
77 ArrayList<Callable<Integer>> tasks = new ArrayList<>(CONCURRENCY); in runTasks()
92 private static abstract class BaseTask implements Callable<Integer> {
/aosp12/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/tests/src/androidx/media/filterfw/
H A DMffTestCase.java24 import java.util.concurrent.Callable;
43 FutureTask<MffContext> task = new FutureTask<MffContext>(new Callable<MffContext>() { in setUp()
/aosp12/packages/apps/Dialer/java/com/android/dialer/common/concurrent/
H A DUiThreadExecutor.java22 import java.util.concurrent.Callable;
62 public <V> ListenableFuture<V> submit(final Callable<V> task) { in submit()

12345