/external/chromium_org/chrome/test/pyautolib/chromeos/ |
H A D | file_browser.py | 13 executor = pyauto.PyUITest.JavascriptExecutorInTab(self) 14 file_browser = chromeos.file_browser.FileBrowser(self, executor) 22 def __init__(self, ui_test, executor): 27 executor: derived from pyauto.PyUITest.JavascriptExecutor. 30 self.executor = executor 44 return self.executor.Execute(script) 55 list = json.loads(self.executor.Execute(script)) 67 self.executor.Execute(script) 74 self.executor [all...] |
/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/src/com/google/common/util/concurrent/ |
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 | AbstractScheduledService.java | 39 * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run 120 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, 122 return executor.scheduleWithFixedDelay(task, initialDelay, delay, unit); 139 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, 141 return executor.scheduleAtFixedRate(task, initialDelay, period, unit); 146 /** Schedules the task to run on the provided executor on behalf of the service. */ 147 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor, argument 186 executorService = executor(); 253 * {@link #runOneIteration} and {@link #shutDown} methods. The executor will not be 260 protected ScheduledExecutorService executor() { method in class:AbstractScheduledService 314 private final ScheduledExecutorService executor; field in class:AbstractScheduledService.CustomScheduler.ReschedulableCallable 333 ReschedulableCallable(AbstractService service, ScheduledExecutorService executor, Runnable runnable) argument 393 schedule(AbstractService service, ScheduledExecutorService executor, Runnable runnable) argument [all...] |
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 | 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 | 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...] |
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 | 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
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | MoreExecutorsTest.java | 49 final ListeningExecutorService executor = 72 Future<?> future = executor.submit(incrementTask); 83 ListenableFuture<?> future = executor.submit(incrementTask); 96 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); 114 executor.invokeAll(Collections.nCopies(10, incrementTask)); 127 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); 139 Future<?> future = executor.submit(new Callable<Void>() { 147 assertTrue(executor.isShutdown()); 148 assertFalse(executor.isTerminated()); 156 assertTrue(executor [all...] |
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 | AbstractFutureTest.java | 94 ExecutorService executor = Executors.newFixedThreadPool(10); 98 executor.execute(new Runnable() { 107 executor.execute(new Runnable() { 116 executor.execute(new Runnable() { 133 executor.shutdown();
|
/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/chromium/net/proxy/ |
H A D | multi_threaded_proxy_resolver.cc | 36 // An "executor" is a job-runner for PAC requests. It encapsulates a worker 43 // signal when the executor is ready to receive work by calling 51 // Submit a job to this executor. 54 // Callback for when a job has completed running on the executor's thread. 57 // Cleanup the executor. Cancels all outstanding work, and frees the thread 77 // The currently active job for this executor (either a SetPacScript or 110 void set_executor(Executor* executor) { argument 111 executor_ = executor; 114 // The "executor" is the job runner that is scheduling this job. If 115 // this job has not been submitted to an executor ye 117 Executor* executor() { function in class:net::MultiThreadedProxyResolver::Job 416 Executor* executor = FindIdleExecutor(); local 477 Executor* executor = *it; local 500 Executor* executor = AddNewExecutor(); local 511 const Executor* executor = *it; local 527 Executor* executor = *it; local 538 Executor* executor = *it; local 552 Executor* executor = new Executor( local 558 OnExecutorReady(Executor* executor) argument [all...] |
/external/chromium_org/net/proxy/ |
H A D | multi_threaded_proxy_resolver.cc | 25 // An "executor" is a job-runner for PAC requests. It encapsulates a worker 32 // signal when the executor is ready to receive work by calling 40 // Submit a job to this executor. 43 // Callback for when a job has completed running on the executor's thread. 46 // Cleanup the executor. Cancels all outstanding work, and frees the thread 66 // The currently active job for this executor (either a SetPacScript or 99 void set_executor(Executor* executor) { argument 100 executor_ = executor; 103 // The "executor" is the job runner that is scheduling this job. If 104 // this job has not been submitted to an executor ye 106 Executor* executor() { function in class:net::MultiThreadedProxyResolver::Job 423 Executor* executor = FindIdleExecutor(); local 490 Executor* executor = it->get(); local 513 Executor* executor = AddNewExecutor(); local 524 const Executor* executor = it->get(); local 540 Executor* executor = it->get(); local 551 Executor* executor = it->get(); local 565 Executor* executor = new Executor( local 571 OnExecutorReady(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/chromium_org/chrome/test/webdriver/test/ |
H A D | chromedriver_factory.py | 12 def __init__(self, executor, capabilities): 13 super(WebDriverWrapper, self).__init__(executor, capabilities)
|
/external/chromium_org/tools/gyp/pylib/gyp/ |
H A D | sun_tool.py | 17 executor = SunTool() 18 executor.Dispatch(args)
|
/external/jmonkeyengine/engine/src/bullet-common/com/jme3/bullet/ |
H A D | BulletAppState.java | 26 protected ScheduledThreadPoolExecutor executor; field in class:BulletAppState 71 if (executor != null) { 72 executor.shutdown(); 74 executor = new ScheduledThreadPoolExecutor(1); 86 return executor.submit(call).get(); 110 executor.schedule(detachedPhysicsUpdate, Math.round(getPhysicsSpace().getAccuracy() * 1000000.0f) - (update * 1000), TimeUnit.MICROSECONDS); 129 // executor.submit(detachedPhysicsUpdate); 183 physicsFuture = executor.submit(parallelPhysicsUpdate); 204 if (executor != null) { 205 executor [all...] |
/external/chromium_org/chrome/test/functional/ |
H A D | doc_viewing.py | 38 executor = pyauto.PyUITest.JavascriptExecutorInTab(self) 39 file_browser = chromeos.file_browser.FileBrowser(self, executor)
|
/external/jmdns/src/javax/jmdns/impl/ |
H A D | JmmDNSImpl.java | 88 ExecutorService executor = Executors.newCachedThreadPool(); 90 executor.submit(new Runnable() { 104 executor.shutdown(); 106 executor.awaitTermination(DNSConstants.CLOSE_TIMEOUT, TimeUnit.MILLISECONDS); 201 ExecutorService executor = Executors.newCachedThreadPool(); 203 executor.submit(new Runnable() { 213 executor.shutdown(); 215 executor.awaitTermination(timeout, TimeUnit.MILLISECONDS); 404 ExecutorService executor = Executors.newCachedThreadPool(); 406 executor [all...] |
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/io/ |
H A D | OutputStreamTesterTest.java | 115 private ExecutorService executor; field in class:OutputStreamTesterTest.PipedOutputStreamSinkTester 122 executor = Executors.newSingleThreadExecutor(); 123 future = executor.submit(new Callable<byte[]>() { 139 executor.shutdown();
|
H A D | WriterTesterTest.java | 104 private ExecutorService executor; field in class:WriterTesterTest.PipedWriterCharSinkTester 111 executor = Executors.newSingleThreadExecutor(); 112 future = executor.submit(new Callable<char[]>() { 128 executor.shutdown();
|
/external/jmonkeyengine/engine/src/core/com/jme3/asset/ |
H A D | ThreadingManager.java | 48 protected final ExecutorService executor = field in class:ThreadingManager 91 // return executor.submit(new MultiLoadingTask(names)); 95 // return executor.submit(new LoadingTask(name));
|