/external/chromium_org/components/cronet/android/java/src/org/chromium/net/ |
H A D | CronetUrlRequestFactory.java | 15 Executor executor) { 14 createRequest(String url, UrlRequestListener listener, Executor executor) argument
|
H A D | UrlRequestFactory.java | 21 * @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 D | Prioritized.java | 1 package com.bumptech.glide.load.engine.executor;
|
H A D | FifoPriorityThreadPoolExecutor.java | 1 package com.bumptech.glide.load.engine.executor;
|
/external/guava/guava/src/com/google/common/cache/ |
H A D | RemovalListeners.java | 36 * 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 D | ListenableFuture.java | 27 * 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 D | ExecutionList.java | 35 * <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 D | AbstractIdleService.java | 28 * 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 D | JdkFutureAdapters.java | 68 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 D | AbstractExecutionThreadService.java | 43 executor().execute(new Runnable() { 115 * priority. The returned executor's {@link Executor#execute(Runnable) 122 protected Executor executor() { method in class:AbstractExecutionThreadService
|
H A D | 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) { 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 D | MoreExecutors.java | 60 * @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 D | file_task_executor_unittest.cc | 95 // |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 D | AsyncEventBus.java | 32 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 D | AsyncEventBusTest.java | 32 /** 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 D | SynchronousHttpClient.java | 27 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 D | deferred_sequenced_task_runner_unittest.cc | 27 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 D | JsDocValidator.java | 22 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 D | AbstractIdleServiceTest.java | 36 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 D | AbstractExecutionThreadServiceTest.java | 43 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 D | SimpleTimeLimiterTest.java | 39 private static final ExecutorService executor field in class:SimpleTimeLimiterTest 55 service = new SimpleTimeLimiter(executor);
|
/external/deqp/modules/glshared/ |
H A D | glsShaderExecUtil.hpp | 69 //! 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 D | execute_code_function.cc | 122 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 D | Runner.java | 96 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 D | Runner.java | 101 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
|