Searched refs:executor (Results 126 - 150 of 235) sorted by relevance

12345678910

/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/badexecutor/
H A DBadExecutorTest.java17 /** This test verifies behavior when the executor throws {@link RejectedExecutionException}. */
34 .executor(executorService)
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/
H A DEngineRunnable.java6 import com.bumptech.glide.load.engine.executor.Prioritized;
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
H A DMockSpdyPeer.java51 private final ExecutorService executor = Executors.newSingleThreadExecutor( field in class:MockSpdyPeer
122 executor.execute(new Runnable() {
140 if (executor.isShutdown()) {
194 executor.shutdown();
/external/skia/src/core/
H A DSkThreadedBMPDevice.cpp46 SkExecutor* executor)
52 if (executor == nullptr) {
54 executor = fInternalExecutor.get();
56 fExecutor = executor;
43 SkThreadedBMPDevice(const SkBitmap& bitmap, int tiles, int threads, SkExecutor* executor) argument
/external/skqp/src/core/
H A DSkThreadedBMPDevice.cpp39 SkExecutor* executor)
45 if (executor == nullptr) {
47 executor = fInternalExecutor.get();
49 fExecutor = executor;
36 SkThreadedBMPDevice(const SkBitmap& bitmap, int tiles, int threads, SkExecutor* executor) argument
H A DSkThreadedBMPDevice.h18 // When executor = nullptr, we manages the thread pool. Otherwise, the caller manages it.
20 SkExecutor* executor = nullptr);
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
H A Dgpu_executable.cc277 se::StreamExecutor* executor = run_options->stream()->parent(); local
280 buffer_allocations_builder.Build(*assignment_, executor->device_ordinal(),
290 auto device_ordinal = executor->device_ordinal();
292 root->shape(), root->shape(), executor->platform(), device_ordinal);
/external/smali/smali/src/main/java/org/jf/smali/
H A DSmali.java96 ExecutorService executor = Executors.newFixedThreadPool(options.jobs);
100 tasks.add(executor.submit(new Callable<Boolean>() {
124 executor.shutdown();
/external/tensorflow/tensorflow/compiler/xla/service/
H A Dservice.h290 perftools::gputools::StreamExecutor* executor,
308 perftools::gputools::StreamExecutor* executor, ExecutionProfile* profile,
318 Backend* backend, perftools::gputools::StreamExecutor* executor,
H A Dexecutable.h88 // Populates `hlo_execution_profile` from `executor`. This is implicit in any
94 perftools::gputools::StreamExecutor* executor) {
92 PopulateExecutionProfile( HloExecutionProfile* hlo_execution_profile, perftools::gputools::StreamExecutor* executor) argument
/external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/
H A DSSLSessionTest.java246 ExecutorService executor = Executors.newFixedThreadPool(2);
247 Future<Void> s = executor.submit(new Callable<Void>() {
254 Future<Void> c = executor.submit(new Callable<Void>() {
261 executor.shutdown();
454 ExecutorService executor = Executors.newSingleThreadExecutor();
455 Future<Void> future = executor.submit(new Callable<Void>() {
462 executor.shutdown();
/external/deqp/executor/tools/
H A DxeCommandLineExecutor.cpp21 * \brief Command line test executor.
520 void setupSignalHandler (xe::BatchExecutor* executor) argument
522 s_executor = executor;
554 void setupSignalHandler (xe::BatchExecutor* executor) argument
556 s_executor = executor;
610 xe::BatchExecutor executor(cmdLine.targetCfg, commLink.get(), &root, testSet, &batchResult, &infoLog);
614 setupSignalHandler(&executor);
615 executor.run();
/external/deqp/external/vulkancts/modules/vulkan/
H A DvktBuildPrograms.cpp383 TaskExecutor executor (numThreads);
436 executor.submit(&buildGlslTasks.back());
449 executor.submit(&buildHlslTasks.back());
462 executor.submit(&buildSpirvAsmTasks.back());
471 executor.waitForComplete();
485 executor.submit(&validationTasks.back());
489 executor.waitForComplete();
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/
H A DDiskLruCache.java167 private final Executor executor; field in class:DiskLruCache
188 Executor executor) {
197 this.executor = executor;
255 Executor executor = new ThreadPoolExecutor(0, 1, 60L, TimeUnit.SECONDS,
258 return new DiskLruCache(fileSystem, directory, appVersion, valueCount, maxSize, executor);
435 executor.execute(cleanupRunnable);
500 executor.execute(cleanupRunnable);
570 executor.execute(cleanupRunnable);
617 executor
187 DiskLruCache(FileSystem fileSystem, File directory, int appVersion, int valueCount, long maxSize, Executor executor) argument
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/
H A DDiskLruCacheTest.java60 private final TestExecutor executor = new TestExecutor(); field in class:DiskLruCacheTest
70 cache = new DiskLruCache(fileSystem, cacheDir, appVersion, 2, maxSize, executor);
509 assertEquals(1, executor.jobs.size());
660 while (executor.jobs.isEmpty()) {
667 while (executor.jobs.isEmpty()) {
671 executor.jobs.removeFirst().run();
682 while (executor.jobs.isEmpty()) {
692 while (executor.jobs.isEmpty()) {
1064 cache = new DiskLruCache(fileSystem, cacheDir, appVersion, 2, Integer.MAX_VALUE, executor);
1086 cache = new DiskLruCache(fileSystem, cacheDir, appVersion, 2, Integer.MAX_VALUE, executor);
[all...]
/external/guava/guava/src/com/google/common/util/concurrent/
H A DAbstractService.java408 public final void addListener(Listener listener, Executor executor) { argument
410 checkNotNull(executor, "executor");
414 listeners.add(new ListenerCallQueue<Listener>(listener, executor));
/external/python/cpython3/Lib/asyncio/
H A Dbase_events.py479 This clears the queues and shuts down the executor,
480 but does not wait for the executor to finish.
493 executor = self._default_executor
494 if executor is not None:
496 executor.shutdown(wait=False)
628 def run_in_executor(self, executor, func, *args):
632 if executor is None:
633 executor = self._default_executor
634 if executor is None:
635 executor
[all...]
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/
H A DFifoPriorityThreadPoolExecutor.java1 package com.bumptech.glide.load.engine.executor;
22 * {@link com.bumptech.glide.load.engine.executor.FifoPriorityThreadPoolExecutor.DefaultThreadFactory}.
/external/javassist/src/main/javassist/bytecode/analysis/
H A DAnalyzer.java138 Executor executor = new Executor(clazz.getClassPool(), method.getConstPool());
143 analyzeNextEntry(method, iter, queue, executor);
168 IntQueue queue, Executor executor) throws BadBytecode {
177 executor.execute(method, pos, iter, frame, subroutine);
167 analyzeNextEntry(MethodInfo method, CodeIterator iter, IntQueue queue, Executor executor) argument
/external/tensorflow/tensorflow/compiler/xla/tests/
H A Dxla_hlo_profile_test.cc126 se::StreamExecutor* executor = backend->default_stream_executor(); local
135 executor, *Literal::CreateFromShape(lhs_arg_shape), *lhs_arg));
142 executor, *Literal::CreateFromShape(rhs_arg_shape), *rhs_arg));
172 hlo_execution_profile.ToString(executor->GetDeviceDescription());
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/monitoring/
H A DMonitoringTest.java70 .executor(MoreExecutors.directExecutor())
110 .executor(MoreExecutors.directExecutor())
/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DAbstractIdleServiceTest.java176 // Create a service whose executor will never run its commands
178 @Override protected Executor executor() {
211 @Override protected Executor executor() { method in class:AbstractIdleServiceTest.TestService
H A DFutureCallbackTest.java216 public void addListener(Runnable listener, Executor executor) { argument
217 executor.execute(listener);
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DConnectionPool.java81 * thread running per connection pool. We use a thread pool executor because it can shrink to
84 private final Executor executor = new ThreadPoolExecutor( field in class:ConnectionPool
189 executor.execute(cleanupRunnable);
/external/conscrypt/openjdk/src/test/java/org/conscrypt/
H A DConscryptSocketTest.java216 private ExecutorService executor; field in class:ConscryptSocketTest
229 executor = Executors.newCachedThreadPool();
234 executor.shutdown();
235 executor.awaitTermination(5, TimeUnit.SECONDS);
394 return executor.submit(new Callable<AbstractConscryptSocket>() {

Completed in 664 milliseconds

12345678910