Searched defs:executor (Results 1 - 25 of 54) sorted by relevance

123

/external/chromium_org/components/cronet/android/java/src/org/chromium/net/
H A DCronetUrlRequestFactory.java15 Executor executor) {
14 createRequest(String url, UrlRequestListener listener, Executor executor) argument
H A DUrlRequestFactory.java21 * @param executor Executor on which all callbacks will be called.
25 UrlRequestListener listener, Executor executor);
24 createRequest(String url, UrlRequestListener listener, Executor executor) argument
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/
H A DPrioritized.java1 package com.bumptech.glide.load.engine.executor;
H A DFifoPriorityThreadPoolExecutor.java1 package com.bumptech.glide.load.engine.executor;
/external/guava/guava/src/com/google/common/cache/
H A DRemovalListeners.java36 * notifications using {@code executor}.
39 * @param executor the executor with which removal notifications are
43 final RemovalListener<K, V> listener, final Executor executor) {
47 executor.execute(new Runnable() {
42 asynchronous( final RemovalListener<K, V> listener, final Executor executor) argument
/external/guava/guava/src/com/google/common/util/concurrent/
H A DListenableFuture.java27 * associated executor, and it is invoked using this executor once the future's
54 * }, executor);}</pre>
85 * the given executor. The listener will run when the {@code Future}'s
93 * <p>Exceptions thrown by a listener will be propagated up to the executor.
117 * @param executor the executor to run the listener in
118 * @throws NullPointerException if the executor or listener was null
120 * immediately but the executor rejected it.
122 void addListener(Runnable listener, Executor executor); argument
[all...]
H A DExecutionList.java35 * <p>Exceptions thrown by a listener will be propagated up to the executor.
51 // The runnable,executor pairs to execute.
80 public void add(Runnable runnable, Executor executor) { argument
85 Preconditions.checkNotNull(executor, "Executor was null.");
94 runnables.add(new RunnableExecutorPair(runnable, executor));
105 new RunnableExecutorPair(runnable, executor).execute();
140 final Executor executor; field in class:ExecutionList.RunnableExecutorPair
142 RunnableExecutorPair(Runnable runnable, Executor executor) { argument
144 this.executor = executor;
[all...]
H A DAbstractIdleService.java28 * which run in a executor which by default uses a separate thread
40 executor(State.STARTING).execute(new Runnable() {
54 executor(State.STOPPING).execute(new Runnable() {
78 * priority. The returned executor's {@link Executor#execute(Runnable)
86 protected Executor executor(final State state) { method in class:AbstractIdleService
H A DJdkFutureAdapters.java68 Future<V> future, Executor executor) {
69 checkNotNull(executor);
73 return new ListenableFutureAdapter<V>(future, executor);
67 listenInPoolThread( Future<V> future, Executor executor) argument
H A DAbstractExecutionThreadService.java43 executor().execute(new Runnable() {
115 * priority. The returned executor's {@link Executor#execute(Runnable)
122 protected Executor executor() { method in class:AbstractExecutionThreadService
H A DSimpleTimeLimiter.java50 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) { argument
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);
H A DMoreExecutors.java60 * @param executor the executor to modify to make sure it exits when the
62 * @param terminationTimeout how long to wait for the executor to
69 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) {
70 executor.setThreadFactory(new ThreadFactoryBuilder()
72 .setThreadFactory(executor.getThreadFactory())
75 ExecutorService service = Executors.unconfigurableExecutorService(executor);
91 * @param executor the executor to modify to make sure it exits when the
93 * @param terminationTimeout how long to wait for the executor t
68 getExitingExecutorService( ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) argument
99 getExitingScheduledExecutorService( ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) argument
164 getExitingExecutorService( ThreadPoolExecutor executor) argument
185 getExitingScheduledExecutorService( ScheduledThreadPoolExecutor executor) argument
[all...]
/external/chromium_org/chrome/browser/chromeos/drive/
H A Dfile_task_executor_unittest.cc95 // |delegate_ptr| will be owned by |executor|.
98 // |executor| deletes itself after Execute() is finished.
99 FileTaskExecutor* const executor = new FileTaskExecutor( local
114 executor->Execute(urls,
129 // |delegate_ptr| will be owned by |executor|.
132 // |executor| deletes itself after Execute() is finished.
133 FileTaskExecutor* const executor = new FileTaskExecutor( local
144 executor->Execute(urls,
/external/guava/guava/src/com/google/common/eventbus/
H A DAsyncEventBus.java32 private final Executor executor; field in class:AsyncEventBus
39 * Creates a new AsyncEventBus that will use {@code executor} to dispatch
43 * @param executor Executor to use to dispatch events. It is the caller's
44 * responsibility to shut down the executor after the last event has
47 public AsyncEventBus(String identifier, Executor executor) { argument
49 this.executor = executor;
53 * Creates a new AsyncEventBus that will use {@code executor} to dispatch
56 * @param executor Executor to use to dispatch events. It is the caller's
57 * responsibility to shut down the executor afte
60 AsyncEventBus(Executor executor) argument
[all...]
/external/guava/guava-tests/test/com/google/common/eventbus/
H A DAsyncEventBusTest.java32 /** The executor we use to fake asynchronicity. */
33 private FakeExecutor executor; field in class:AsyncEventBusTest
38 executor = new FakeExecutor();
39 bus = new AsyncEventBus(executor);
54 List<Runnable> tasks = executor.getTasks();
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
H A DSynchronousHttpClient.java27 ThreadPoolExecutor executor; field in class:SynchronousHttpClient
32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel,
37 executor.execute(request(url));
41 return executor.getQueue().size() < targetBacklog;
/external/chromium_org/base/
H A Ddeferred_sequenced_task_runner_unittest.cc27 DeferredSequencedTaskRunnerTest* executor,
29 : executor_(executor),
26 ExecuteTaskOnDestructor( DeferredSequencedTaskRunnerTest* executor, int task_id) argument
/external/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/
H A DJsDocValidator.java22 ExecutorService executor = Executors.newFixedThreadPool(threadCount);
24 runWithExecutor(args, executor);
26 executor.shutdown();
30 private void runWithExecutor(String[] args, ExecutorService executor) { argument
34 Future<ValidatorContext> future = executor.submit(new FileCheckerCallable(fileName));
/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DAbstractIdleServiceTest.java36 private final Executor executor = new Executor() { field in class:AbstractIdleServiceTest
76 // Create a service whose executor will never run its commands
78 @Override protected Executor executor(Service.State state) {
113 @Override protected Executor executor(Service.State state) { method in class:AbstractIdleServiceTest.NullService
117 return executor;
121 return executor;
H A DAbstractExecutionThreadServiceTest.java43 private final Executor executor = new Executor() { field in class:AbstractExecutionThreadServiceTest
163 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.WaitOnRunService
164 return executor;
198 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.ThrowOnStartUpService
199 return executor;
241 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.ThrowOnRunService
242 return executor;
273 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.ThrowOnShutDown
274 return executor;
290 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.TimeoutOnStartUp
[all...]
H A DSimpleTimeLimiterTest.java39 private static final ExecutorService executor field in class:SimpleTimeLimiterTest
55 service = new SimpleTimeLimiter(executor);
/external/deqp/modules/glshared/
H A DglsShaderExecUtil.hpp69 //! Base class for shader executor.
75 //! Check if executor can be used.
78 //! Log executor details (program etc.).
99 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor* executor) { executor->log(log); return log; } argument
100 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor& executor) { executor.log(log); return log; } argument
/external/chromium_org/extensions/browser/api/
H A Dexecute_code_function.cc122 ScriptExecutor* executor = GetScriptExecutor(); local
123 if (!executor)
158 executor->ExecuteScript(
/external/chromium_org/third_party/WebKit/Source/devtools/scripts/compiler-runner/src/org/chromium/devtools/compiler/
H A DRunner.java96 ExecutorService executor = Executors.newFixedThreadPool(
99 runWithExecutor(descriptors, executor);
101 executor.shutdown();
106 List<CompilerInstanceDescriptor> descriptors, ExecutorService executor) {
110 futures.add(executor.submit(task));
105 runWithExecutor( List<CompilerInstanceDescriptor> descriptors, ExecutorService executor) argument
/external/chromium_org/third_party/closure_compiler/runner/src/org/chromium/closure/compiler/
H A DRunner.java101 ExecutorService executor = Executors.newFixedThreadPool(
104 runWithExecutor(descriptors, executor);
106 executor.shutdown();
111 List<CompilerInstanceDescriptor> descriptors, ExecutorService executor) {
115 futures.add(executor.submit(task));
110 runWithExecutor( List<CompilerInstanceDescriptor> descriptors, ExecutorService executor) argument

Completed in 3208 milliseconds

123