/external/deqp/framework/randomshaders/ |
H A D | rsgTest.cpp | 68 rsg::ProgramExecutor executor(surface.getAccess(), 3, 5); 70 executor.execute(vertexShader, fragmentShader, uniformValues);
|
/external/libcxx/utils/libcxx/android/ |
H A D | executors.py | 3 import libcxx.test.executor namespace 9 class AdbExecutor(libcxx.test.executor.RemoteExecutor):
|
/external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
H A D | CancelCall.java | 28 private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1); field in class:CancelCall 40 executor.schedule(new Runnable() {
|
/external/volley/src/main/java/com/android/volley/ |
H A D | ExecutorDelivery.java | 47 * @param executor For running delivery tasks 49 public ExecutorDelivery(Executor executor) { argument 50 mResponsePoster = executor;
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
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);
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | AbstractFutureTest.java | 109 ExecutorService executor = Executors.newFixedThreadPool(10); 113 executor.execute(new Runnable() { 122 executor.execute(new Runnable() { 131 executor.execute(new Runnable() { 148 executor.shutdown();
|
H A D | AbstractExecutionThreadServiceTest.java | 158 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.WaitOnRunService 193 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.ThrowOnStartUpService 247 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.ThrowOnRunService 279 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.ThrowOnShutDown 296 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.TimeoutOnStartUp 344 private final ExecutorService executor = Executors.newSingleThreadExecutor(); field in class:AbstractExecutionThreadServiceTest.FakeService 375 @Override protected Executor executor() { method in class:AbstractExecutionThreadServiceTest.FakeService 376 return executor; 380 executor.shutdown();
|
/external/owasp/sanitizer/src/tests/org/owasp/html/ |
H A D | HtmlSanitizerFuzzerTest.java | 73 // Use an executor so that any infinite loops do not cause the test runner 75 ThreadPoolExecutor executor = new ThreadPoolExecutor( 128 executor.execute(new Runnable() { 141 executor.shutdown(); 142 executor.awaitTermination(runCount * 4, TimeUnit.SECONDS); 143 assertTrue("seed=" + seed, executor.isTerminated());
|
/external/python/cpython3/Lib/concurrent/futures/ |
H A D | process.py | 244 executor = None 247 return _shutdown or executor is None or executor._shutdown_thread 275 executor = executor_reference() 276 if executor is not None: 277 executor._broken = True 278 executor._shutdown_thread = True 279 executor = None 299 # (avoids marking the executor broken) 317 executor [all...] |
H A D | thread.py | 70 executor = executor_reference() 73 # - The executor that owns the worker has been collected OR 74 # - The executor that owns the worker has been shutdown. 75 if _shutdown or executor is None or executor._shutdown: 79 del executor 120 # When the executor gets lost, the weakref callback will wake up
|
/external/tensorflow/tensorflow/compiler/xla/client/ |
H A D | local_client.cc | 219 se::StreamExecutor * executor, 221 return backend_->transfer_manager()->TransferLiteralFromDevice(executor, 277 TF_ASSIGN_OR_RETURN(se::StreamExecutor * executor, 280 executor, literal, *scoped_buffer)); 287 se::StreamExecutor * executor, 289 return backend().transfer_manager()->TransferLiteralFromDevice(executor, 295 TF_ASSIGN_OR_RETURN(se::StreamExecutor * executor, 297 return backend().transfer_manager()->TransferLiteralToInfeed(executor, 303 TF_ASSIGN_OR_RETURN(se::StreamExecutor * executor, 307 executor, shap [all...] |
/external/tensorflow/tensorflow/compiler/xla/service/ |
H A D | platform_util.cc | 71 LOG(WARNING) << "no executor platforms available: platform map is empty"; 185 static bool IsDeviceSupported(se::StreamExecutor* executor) { argument 186 const auto& description = executor->GetDeviceDescription(); 187 if (executor->platform()->id() == se::cuda::kCudaPlatformId) { 195 << executor->device_ordinal() << ") is of " 232 se::StreamExecutor* executor = executor_status.ValueOrDie(); 233 if (IsDeviceSupported(executor)) { 234 stream_executors[i] = executor;
|
H A D | service.cc | 71 se::StreamExecutor* executor, TransferManager* transfer_manager, 77 transfer_manager->TransferLiteralFromDevice(executor, *argument)); 85 se::StreamExecutor* executor, 91 transfer_manager->TransferLiteralFromDevice(executor, result)); 164 se::StreamExecutor* executor = local 166 const auto& description = executor->GetDeviceDescription(); 403 se::StreamExecutor* executor, DeviceMemoryAllocator* device_allocator) { 436 module, backend->compiler()->RunHloPasses(std::move(module), executor, 441 std::move(module), executor, device_allocator)); 453 perftools::gputools::StreamExecutor* executor, ExecutionProfil 69 RecordArguments( const tensorflow::gtl::ArraySlice<const ShapedBuffer*> arguments, se::StreamExecutor* executor, TransferManager* transfer_manager, SessionModule* module) argument 84 RecordResult(const ShapedBuffer& result, se::StreamExecutor* executor, TransferManager* transfer_manager, SessionModule* module) argument 400 BuildExecutable( const VersionedComputationHandle& versioned_handle, std::unique_ptr<HloModuleConfig> module_config, Backend* backend, se::StreamExecutor* executor, DeviceMemoryAllocator* device_allocator) argument 450 BuildAndCacheExecutable( const VersionedComputationHandle& versioned_handle, std::unique_ptr<HloModuleConfig> module_config, Backend* backend, perftools::gputools::StreamExecutor* executor, ExecutionProfile* profile, DeviceMemoryAllocator* device_allocator) argument 628 ExecuteAndRegisterResult( Executable* executable, const tensorflow::gtl::ArraySlice<const ShapedBuffer*> arguments, Backend* backend, perftools::gputools::StreamExecutor* executor, const string& result_tag, ExecutionProfile* profile) argument 725 se::StreamExecutor* executor = replicas[0]; local 1124 se::StreamExecutor* executor; local 1153 se::StreamExecutor* executor; local [all...] |
/external/guava/guava-tests/test/com/google/common/cache/ |
H A D | CacheLoaderTest.java | 88 QueuingExecutor executor = new QueuingExecutor(); 90 CacheLoader.asyncReloading(baseLoader, executor); 99 executor.runNext();
|
/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/skia/src/core/ |
H A D | SkExecutor.cpp | 46 void SkExecutor::SetDefault(SkExecutor* executor) { argument 47 gDefaultExecutor = executor ? executor : &gTrivial; 62 // An SkThreadPool is an executor that runs work on a fixed pool of OS threads.
|
H A D | SkTaskGroup2D.h | 29 // A 2D grid (height rows x width columns) of tasks to be executed on a given executor with 50 SkTaskGroup2D(SkWorkKernel2D* kernel, int height, SkExecutor* executor, int threadCnt) argument 52 , fWidth(0), fThreadsGroup(new SkTaskGroup(*executor)) {}
|
/external/skqp/src/core/ |
H A D | SkExecutor.cpp | 46 void SkExecutor::SetDefault(SkExecutor* executor) { argument 47 gDefaultExecutor = executor ? executor : &gTrivial; 62 // An SkThreadPool is an executor that runs work on a fixed pool of OS threads.
|
H A D | SkTaskGroup2D.h | 24 // The tasks will eventually be executed on the executor with threadCnt number of hardware threads. 29 SkTaskGroup2D(Work2D&& work, int height, SkExecutor* executor, int threadCnt) argument 31 , fThreadsGroup(new SkTaskGroup(*executor)) {}
|
/external/deqp/scripts/ |
H A D | run_internal_tests.py | 46 def __init__ (self, name, srcPath, buildPath, genParams, buildParams, testBinaryName, executor = 'executor', execserver = 'execserver', junitTool = 'testlog-to-junit'): 53 self.executor = executor 85 junitToolPath = os.path.join(config.buildPath, 'executor', config.junitTool) 97 # Run test binary using executor 99 os.path.join(config.buildPath, 'executor', config.executor), 126 'Debug\\executor.exe', 137 'Release\\executor [all...] |
/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
H A D | MockServerSocketTest.java | 84 final Future<Socket> f = executor.submit(new Callable<Socket>() { 100 final Future<Socket> f = executor.submit(new Callable<Socket>() { 121 final Future<Socket> f = executor.submit(new Callable<Socket>() { 137 final Future<Void> f = executor.submit(new Callable<Void>() {
|
/external/python/futures/concurrent/futures/ |
H A D | thread.py | 79 executor = executor_reference() 82 # - The executor that owns the worker has been collected OR 83 # - The executor that owns the worker has been shutdown. 84 if _shutdown or executor is None or executor._shutdown: 88 del executor 135 # When the executor gets lost, the weakref callback will wake up
|
/external/vogar/src/vogar/target/junit/ |
H A D | TimeoutAndAbortRunRule.java | 37 private final ExecutorService executor = Executors.newCachedThreadPool( field in class:TimeoutAndAbortRunRule 68 Future<Throwable> result = executor.submit(new Callable<Throwable>() {
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
H A D | SocksProxy.java | 56 private final ExecutorService executor = Executors.newCachedThreadPool( field in class:SocksProxy 64 executor.execute(new NamedRunnable("SocksProxy %s", serverSocket.getLocalPort()) { 92 executor.shutdown(); 93 if (!executor.awaitTermination(5, TimeUnit.SECONDS)) { 94 throw new IOException("Gave up waiting for executor to shut down"); 99 executor.execute(new NamedRunnable("SocksProxy %s", from.getRemoteSocketAddress()) { 206 executor.execute(new NamedRunnable("SocksProxy %s to %s", fromAddress, toAddress) {
|
/external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/ |
H A D | PeerConnectionClient.java | 92 private final LooperExecutor executor; field in class:PeerConnectionClient 215 executor = new LooperExecutor(); 219 executor.requestStart(); 252 executor.execute(new Runnable() { 272 executor.execute(new Runnable() { 282 executor.execute(new Runnable() { 587 executor.execute(new Runnable() { 604 executor.execute(new Runnable() { 619 executor.execute(new Runnable() { 632 executor [all...] |