/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/badexecutor/ |
H A D | BadExecutorTest.java | 17 /** 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 D | EngineRunnable.java | 6 import com.bumptech.glide.load.engine.executor.Prioritized;
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
H A D | 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/skia/src/core/ |
H A D | SkThreadedBMPDevice.cpp | 46 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 D | SkThreadedBMPDevice.cpp | 39 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 D | SkThreadedBMPDevice.h | 18 // 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 D | gpu_executable.cc | 277 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 D | Smali.java | 96 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 D | service.h | 290 perftools::gputools::StreamExecutor* executor, 308 perftools::gputools::StreamExecutor* executor, ExecutionProfile* profile, 318 Backend* backend, perftools::gputools::StreamExecutor* executor,
|
H A D | executable.h | 88 // 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 D | SSLSessionTest.java | 246 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 D | xeCommandLineExecutor.cpp | 21 * \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 D | vktBuildPrograms.cpp | 383 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 D | DiskLruCache.java | 167 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 D | DiskLruCacheTest.java | 60 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 D | AbstractService.java | 408 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 D | base_events.py | 479 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 D | FifoPriorityThreadPoolExecutor.java | 1 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 D | Analyzer.java | 138 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 D | xla_hlo_profile_test.cc | 126 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 D | MonitoringTest.java | 70 .executor(MoreExecutors.directExecutor()) 110 .executor(MoreExecutors.directExecutor())
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | AbstractIdleServiceTest.java | 176 // 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 D | FutureCallbackTest.java | 216 public void addListener(Runnable listener, Executor executor) { argument 217 executor.execute(listener);
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | ConnectionPool.java | 81 * 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 D | ConscryptSocketTest.java | 216 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>() {
|