| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| CancelCall.java | 28 private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1); field in class:CancelCall
40 executor.schedule(new Runnable() {
|
| /external/skia/src/core/ |
| SkTaskGroup2D.h | 29 // A 2D grid (height rows x width columns) of tasks to be executed on a given executor with
50 SkTaskGroup2D(SkWorkKernel2D* kernel, int height, SkExecutor* executor, int threadCnt)
52 , fWidth(0), fThreadsGroup(new SkTaskGroup(*executor)) {}
|
| /external/skqp/src/core/ |
| SkTaskGroup2D.h | 24 // The tasks will eventually be executed on the executor with threadCnt number of hardware threads.
29 SkTaskGroup2D(Work2D&& work, int height, SkExecutor* executor, int threadCnt)
31 , fThreadsGroup(new SkTaskGroup(*executor)) {}
|
| /external/volley/src/main/java/com/android/volley/ |
| ExecutorDelivery.java | 21 import java.util.concurrent.Executor;
28 private final Executor mResponsePoster;
35 // Make an Executor that just wraps the handler.
36 mResponsePoster = new Executor() {
47 * @param executor For running delivery tasks
49 public ExecutorDelivery(Executor executor) {
50 mResponsePoster = executor;
|
| /frameworks/base/core/java/android/hardware/biometrics/ |
| BiometricAuthenticator.java | 24 import java.util.concurrent.Executor;
40 * CancellationSignal, Executor, AuthenticationCallback)} and
41 * {@link BiometricAuthenticator#authenticate(CryptoObject, CancellationSignal, Executor,
71 * CryptoObject, CancellationSignal, Executor, AuthenticationCallback)}
98 * Executor, AuthenticationCallback)} or {@link BiometricAuthenticator#authenticate(
99 * CryptoObject, CancellationSignal, Executor, AuthenticationCallback)}. Users must provide
145 * {@link BiometricAuthenticator#authenticate(CryptoObject, CancellationSignal, Executor,
155 * @param executor An executor to handle callback events
160 @NonNull @CallbackExecutor Executor executor
[all...] |
| /frameworks/base/telephony/java/android/telephony/mbms/ |
| InternalDownloadSessionCallback.java | 22 import java.util.concurrent.Executor;
27 private final Executor mExecutor;
32 Executor executor) {
34 mExecutor = executor;
|
| InternalStreamingSessionCallback.java | 23 import java.util.concurrent.Executor;
27 private final Executor mExecutor;
32 Executor executor) {
34 mExecutor = executor;
|
| /frameworks/support/app-toolkit/core-testing/src/test/java/androidx/arch/core/executor/testing/ |
| InstantTaskExecutorRuleTest.java | 17 package androidx.arch.core.executor.testing;
21 import androidx.arch.core.executor.ArchTaskExecutor;
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| AsynchronousChannelGroupImpl.java | 47 extends AsynchronousChannelGroup implements Executor
60 // associated Executor for timeouts
91 final ExecutorService executor() { method in class:AsynchronousChannelGroupImpl
92 return pool.executor();
140 pool.executor().execute(task);
161 pool.executor().execute(bindToGroup(task));
188 pool.executor().execute(bindToGroup(task));
219 return pool.executor().isTerminated();
251 pool.executor().shutdown();
309 return pool.executor().awaitTermination(timeout, unit)
[all...] |
| LinuxAsynchronousChannelProvider.java | 61 public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initialSize)
64 return new EPollPort(this, ThreadPool.wrap(executor, initialSize)).start();
|
| /packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
| FuturesUtil.java | 39 TimeUnit unit, ScheduledExecutorService executor) {
41 executor.schedule(new Runnable() {
|
| /packages/apps/Launcher3/tests/src/com/android/launcher3/util/ |
| Condition.java | 19 final MainThreadExecutor executor = new MainThreadExecutor(); local
26 executor.execute(new Runnable() {
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
| QueryTask.java | 79 NamedTaskExecutor executor, Handler handler,
84 executor.execute(task);
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| BatchingNamedTaskExecutor.java | 42 * @param executor A SourceTaskExecutor for actually executing the tasks.
44 public BatchingNamedTaskExecutor(NamedTaskExecutor executor) {
45 mExecutor = executor;
61 * Instructs the executor to submit the next batch of results.
80 * Cancel any unstarted tasks running in this executor. This instance
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/ |
| PackageIconLoaderTest.java | 54 NamedTaskExecutor executor = new SingleThreadNamedTaskExecutor( local
57 executor);
|
| /prebuilts/tools/common/m2/repository/io/netty/netty-resolver/4.1.6.Final/ |
| netty-resolver-4.1.6.Final.jar | |
| /tools/apkzlib/src/main/java/com/android/tools/build/apkzlib/zip/compress/ |
| DeflateExecutionCompressor.java | 24 import java.util.concurrent.Executor;
30 * Compressor that uses deflate with an executor.
49 * @param executor the executor to run deflation tasks
54 @Nonnull Executor executor,
57 super(executor);
|
| /cts/tests/sensor/src/android/hardware/cts/helpers/sensoroperations/ |
| ParallelSensorOperation.java | 86 ThreadPoolExecutor executor = new ThreadPoolExecutor( local
92 executor.allowCoreThreadTimeOut(true);
93 executor.prestartAllCoreThreads();
98 Future<SensorOperation> future = executor.submit(new Callable<SensorOperation>() {
135 executor.shutdownNow();
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| SimpleTimeLimiter.java | 50 private final ExecutorService executor; field in class:SimpleTimeLimiter
53 * Constructs a TimeLimiter instance using the given executor service to
56 * <b>Warning:</b> using a bounded executor
62 * @param executor the ExecutorService that will execute the method calls on
66 public SimpleTimeLimiter(ExecutorService executor) {
67 this.executor = checkNotNull(executor);
74 * <p><b>Warning:</b> using a bounded executor may be counterproductive! If
126 Future<T> future = executor.submit(callable);
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractFutureTest.java | 109 ExecutorService executor = Executors.newFixedThreadPool(10); local
113 executor.execute(new Runnable() {
122 executor.execute(new Runnable() {
131 executor.execute(new Runnable() {
148 executor.shutdown();
|
| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| HtmlSanitizerFuzzerTest.java | 73 // Use an executor so that any infinite loops do not cause the test runner
75 ThreadPoolExecutor executor = new ThreadPoolExecutor( local
128 executor.execute(new Runnable() {
141 executor.shutdown();
142 executor.awaitTermination(runCount * 4, TimeUnit.SECONDS);
143 assertTrue("seed=" + seed, executor.isTerminated());
|
| /frameworks/base/core/java/android/security/ |
| ConfirmationPrompt.java | 28 import java.util.concurrent.Executor;
91 private Executor mExecutor;
130 Executor executor = mExecutor;
133 if (executor == null) {
136 executor.execute(new Runnable() {
259 * @param executor the executor identifying the thread that will receive the callback.
265 public void presentPrompt(@NonNull Executor executor, @NonNull ConfirmationCallback callback
[all...] |
| /external/tensorflow/tensorflow/compiler/xla/client/ |
| local_client.cc | 219 se::StreamExecutor * executor,
221 return backend_->transfer_manager()->TransferLiteralFromDevice(executor,
277 TF_ASSIGN_OR_RETURN(se::StreamExecutor * executor,
280 executor, literal, *scoped_buffer));
287 se::StreamExecutor * executor,
289 return backend().transfer_manager()->TransferLiteralFromDevice(executor,
295 TF_ASSIGN_OR_RETURN(se::StreamExecutor * executor,
297 return backend().transfer_manager()->TransferLiteralToInfeed(executor,
303 TF_ASSIGN_OR_RETURN(se::StreamExecutor * executor,
307 executor, shape, literal.get()))
[all...] |
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| CompletableFuture.java | 66 * <li>All <em>async</em> methods without an explicit Executor
399 * Default executor -- ForkJoinPool.commonPool() unless it cannot
402 private static final Executor ASYNC_POOL = USE_COMMON_POOL ?
406 static final class ThreadPerTaskExecutor implements Executor {
411 * Null-checks user executor argument, and translates uses of
414 static Executor screenExecutor(Executor e) {
513 /** A Completion with a source, dependent, and executor. */
516 Executor executor; // executor to use (null if none field in class:CompletableFuture.UniCompletion
2679 final Executor executor; field in class:CompletableFuture.DelayedExecutor
2690 final Executor executor; field in class:CompletableFuture.TaskSubmitter
[all...] |
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| platform_util.cc | 71 LOG(WARNING) << "no executor platforms available: platform map is empty";
185 static bool IsDeviceSupported(se::StreamExecutor* executor) {
186 const auto& description = executor->GetDeviceDescription();
187 if (executor->platform()->id() == se::cuda::kCudaPlatformId) {
195 << executor->device_ordinal() << ") is of "
232 se::StreamExecutor* executor = executor_status.ValueOrDie();
233 if (IsDeviceSupported(executor)) {
234 stream_executors[i] = executor;
|
