| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ExecutionList.java | 22 import java.util.concurrent.Executor;
30 * <p>A list of listeners, each with an associated {@code Executor}, that
37 * <p>Exceptions thrown by a listener will be propagated up to the executor.
38 * Any exception thrown during {@code Executor.execute} (e.g., a {@code
52 * The runnable, executor pairs to execute. This acts as a stack threaded through the
64 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of
81 public void add(Runnable runnable, Executor executor) {
83 // Executor states that it throws NPE on null listener, so we propagate
86 Preconditions.checkNotNull(executor, "Executor was null.")
168 final Executor executor; field in class:ExecutionList.RunnableExecutorPair
[all...] |
| SerializingExecutor.java | 23 import java.util.concurrent.Executor;
30 * Executor ensuring that all Runnables submitted are executed in order,
31 * using the provided Executor, and serially such that no two will ever
34 * TODO(user): The tasks are given to the underlying executor as a single
35 * task, which means the semantics of the executor may be changed, e.g. the
36 * executor may have an afterExecute method that runs after every task
46 final class SerializingExecutor implements Executor {
50 /** Underlying executor that all submitted Runnable objects are run on. */
51 private final Executor executor; field in class:SerializingExecutor
[all...] |
| 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/jmdns/src/javax/jmdns/impl/ |
| JmmDNSImpl.java | 88 ExecutorService executor = Executors.newCachedThreadPool(); local
90 executor.submit(new Runnable() {
104 executor.shutdown();
106 executor.awaitTermination(DNSConstants.CLOSE_TIMEOUT, TimeUnit.MILLISECONDS);
201 ExecutorService executor = Executors.newCachedThreadPool(); local
203 executor.submit(new Runnable() {
213 executor.shutdown();
215 executor.awaitTermination(timeout, TimeUnit.MILLISECONDS);
404 ExecutorService executor = Executors.newCachedThreadPool(); local
406 executor.submit(new Runnable()
[all...] |
| /frameworks/base/core/tests/coretests/src/android/net/ |
| NetworkRecommendationProviderTest.java | 22 import java.util.concurrent.Executor;
41 Executor executor = Executors.newSingleThreadExecutor(); local
43 mRecProvider = new NetworkRecProvider(mContext, executor, mScoreRequestLatch);
94 NetworkRecProvider(Context context, Executor executor, CountDownLatch networkRequestLatch) {
95 super(context, executor);
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| ThreadPool.java | 43 private final ExecutorService executor; field in class:ThreadPool
52 private ThreadPool(ExecutorService executor,
56 this.executor = executor;
61 ExecutorService executor() { method in class:ThreadPool
62 return executor;
113 ExecutorService executor = Executors.newCachedThreadPool(threadFactory); local
114 return new ThreadPool(executor, false, initialSize);
121 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); local
122 return new ThreadPool(executor, true, nThreads)
[all...] |
| AsynchronousFileChannelImpl.java | 54 // associated Executor
55 protected final ExecutorService executor; field in class:AsynchronousFileChannelImpl
60 ExecutorService executor)
65 this.executor = executor;
68 final ExecutorService executor() { method in class:AsynchronousFileChannelImpl
69 return executor;
|
| SimpleAsynchronousFileChannelImpl.java | 47 ThreadPool.createDefault().executor();
60 ExecutorService executor)
62 super(fdObj, reading, writing, executor);
70 // Executor is either default or based on pool parameters
71 ExecutorService executor = (pool == null) ? local
72 DefaultExecutorHolder.defaultExecutor : pool.executor();
73 return new SimpleAsynchronousFileChannelImpl(fdo, reading, writing, executor);
190 Invoker.invokeIndirectly(handler, attachment, null, exc, executor);
231 executor.execute(task);
305 Invoker.invokeIndirectly(handler, attachment, 0, exc, executor);
[all...] |
| /prebuilts/tools/common/m2/repository/io/netty/netty-resolver/4.1.0.CR3/ |
| netty-resolver-4.1.0.CR3.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-resolver/4.1.3.Final/ |
| netty-resolver-4.1.3.Final.jar | |
| /cts/libs/vogar-expect/src/vogar/commands/ |
| Command.java | 188 ExecutorService executor = Threads.fixedThreadsExecutor("command", 1); local
189 Future<List<String>> result = executor.submit(new Callable<List<String>>() {
195 executor.shutdown();
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| ContinuingRequestIntegrationTest.java | 101 private ExecutorService executor; field in class:ContinuingRequestIntegrationTest
110 executor = Executors.newSingleThreadExecutor();
116 bind(ExecutorService.class).toInstance(executor);
143 executor.shutdown();
144 executor.awaitTermination(10, TimeUnit.SECONDS);
152 executor = sameThreadExecutor;
157 bind(ExecutorService.class).toInstance(executor);
185 executor.shutdown();
186 executor.awaitTermination(10, TimeUnit.SECONDS);
|
| ScopeRequestIntegrationTest.java | 56 ExecutorService executor = Executors.newSingleThreadExecutor(); local
69 executor.submit(ServletScopes.scopeRequest(offRequestCallable,
80 executor.submit(ServletScopes.scopeRequest(offRequestCallable,
88 executor.shutdown();
89 executor.awaitTermination(2, TimeUnit.SECONDS);
|
| /libcore/luni/src/test/java/libcore/java/util/zip/ |
| DeflaterOutputStreamTest.java | 76 ExecutorService executor = Executors.newSingleThreadExecutor(); local
80 executor.submit(new Callable<Void>() {
97 executor.shutdown();
|
| /libcore/luni/src/test/java/libcore/net/ |
| NetworkSecurityPolicyTest.java | 240 private final ExecutorService executor; field in class:NetworkSecurityPolicyTest.CapturingServerSocket
278 executor = Executors.newSingleThreadExecutor();
279 mFirstChunkReceivedFuture = executor.submit(callable);
293 executor.shutdown();
|
| /packages/apps/Dialer/java/com/android/voicemail/impl/fetch/ |
| FetchVoicemailReceiver.java | 44 import java.util.concurrent.Executor;
200 Executor executor = Executors.newCachedThreadPool(); local
201 executor.execute(
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| MoreExecutorsTest.java | 65 import java.util.concurrent.Executor;
91 final ListeningExecutorService executor = newDirectExecutorService(); local
113 Future<?> future = executor.submit(incrementTask);
124 ListenableFuture<?> future = executor.submit(incrementTask);
137 final ExecutorService executor = newDirectExecutorService(); local
155 executor.invokeAll(Collections.nCopies(10, incrementTask));
168 final ExecutorService executor = newDirectExecutorService(); local
180 Future<?> future = executor.submit(new Callable<Void>() {
188 assertTrue(executor.isShutdown());
189 assertFalse(executor.isTerminated())
247 ExecutorService executor = newDirectExecutorService(); local
253 ExecutorService executor = newDirectExecutorService(); local
263 ListeningExecutorService executor = newDirectExecutorService(); local
534 ThreadPoolExecutor executor = new ThreadPoolExecutor( local
542 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); local
551 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); local
561 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); local
568 ScheduledThreadPoolExecutor executor = mock(ScheduledThreadPoolExecutor.class); local
578 ScheduledThreadPoolExecutor executor = mock(ScheduledThreadPoolExecutor.class); local
[all...] |
| AbstractIdleServiceTest.java | 27 import java.util.concurrent.Executor;
176 // Create a service whose executor will never run its commands
178 @Override protected Executor executor() {
179 return new Executor() {
211 @Override protected Executor executor() { method in class:AbstractIdleServiceTest.TestService
|
| /art/tools/dexfuzz/src/dexfuzz/fuzzers/ |
| Fuzzer.java | 28 import dexfuzz.executors.Executor;
59 private List<Executor> executors;
63 * This is the executor that we use to test for self-divergent programs.
65 private Executor goldenExecutor;
84 executors = new ArrayList<Executor>();
108 * Make sure this is called to correctly shutdown each Executor's StreamConsumers.
112 for (Executor executor : executors) {
113 executor.shutdown();
118 private void addExecutorsForArchitecture(Device device, Class<? extends Executor> optimizing
347 executor.getResult().getFlattenedOutputWithNewlines(), executor); local
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| MockSpdyPeer.java | 51 private final ExecutorService executor = Executors.newSingleThreadExecutor( field in class:MockSpdyPeer
122 executor.execute(new Runnable() {
140 if (executor.isShutdown()) {
194 executor.shutdown();
|
| /external/smali/smali/src/main/java/org/jf/smali/ |
| main.java | 121 ExecutorService executor = Executors.newFixedThreadPool(options.jobs); local
125 tasks.add(executor.submit(new Callable<Boolean>() {
149 executor.shutdown();
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| MoreExecutorsDirectExecutorBenchmark.java | 31 import java.util.concurrent.Executor;
42 @Override Executor executor() { method
46 EXECUTOR {
47 @Override Executor executor() { method
51 abstract Executor executor(); method in class:MoreExecutorsDirectExecutorBenchmark.Impl
55 Executor executor; field in class:MoreExecutorsDirectExecutorBenchmark
96 final Executor executor = this.executor; local
105 final Executor executor = this.executor; local
[all...] |
| /external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
| ExecutorFactory.java | 20 import java.util.concurrent.Executor;
35 * Implementation of the executor which uses a pair of {@link MessagePipeHandle} for signaling.
36 * The executor will wait asynchronously on one end of a {@link MessagePipeHandle} on the thread
38 * executor will queue the {@link Runnable} and write a message on the other end of the handle.
39 * This will wake up the executor which is waiting on the handle, which will then dequeue the
42 private static class PipedExecutor implements Executor, Callback {
82 * executor thread.
110 * Close the handles. Should only be called on the executor thread.
150 * Execute the given |command| in the executor thread. This can be called on any thread.
152 * @see Executor#execute(Runnable
178 Executor executor = EXECUTORS.get(); local
[all...] |
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| MockWebServer.java | 123 private ExecutorService executor; field in class:MockWebServer
178 if (executor != null) {
349 executor = Executors.newCachedThreadPool(Util.threadFactory("MockWebServer", false));
357 executor.execute(new NamedRunnable("MockWebServer %s", port) {
376 executor.shutdown();
410 if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
411 throw new IOException("Gave up waiting for executor to shut down");
419 executor.execute(new NamedRunnable("MockWebServer %s", raw.getRemoteSocketAddress()) {
[all...] |
| /frameworks/base/core/tests/coretests/src/android/widget/ |
| AppWidgetHostViewTest.java | 37 import java.util.concurrent.Executor;
85 RunnableList executor = new RunnableList(); local
86 mHostView.setExecutor(executor);
92 assertEquals(1, executor.size());
95 executor.get(0).run();
102 RunnableList executor = new RunnableList(); local
103 mHostView.setExecutor(executor);
110 assertEquals(2, executor.size());
112 assertTrue(((Future) executor.get(0)).isCancelled());
115 executor.get(0).run()
[all...] |
