Searched refs:executor (Results 76 - 100 of 235) sorted by relevance

12345678910

/external/deqp/framework/randomshaders/
H A DrsgTest.cpp68 rsg::ProgramExecutor executor(surface.getAccess(), 3, 5);
70 executor.execute(vertexShader, fragmentShader, uniformValues);
/external/libcxx/utils/libcxx/android/
H A Dexecutors.py3 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 DCancelCall.java28 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 DExecutorDelivery.java47 * @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 DSimpleTimeLimiter.java50 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 DAbstractFutureTest.java109 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 DAbstractExecutionThreadServiceTest.java158 @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 DHtmlSanitizerFuzzerTest.java73 // 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 Dprocess.py244 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 Dthread.py70 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 Dlocal_client.cc219 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 Dplatform_util.cc71 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 Dservice.cc71 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 DCacheLoaderTest.java88 QueuingExecutor executor = new QueuingExecutor();
90 CacheLoader.asyncReloading(baseLoader, executor);
99 executor.runNext();
/external/jmdns/src/javax/jmdns/impl/
H A DJmmDNSImpl.java88 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 DSkExecutor.cpp46 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 DSkTaskGroup2D.h29 // 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 DSkExecutor.cpp46 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 DSkTaskGroup2D.h24 // 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 Drun_internal_tests.py46 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 DMockServerSocketTest.java84 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 Dthread.py79 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 DTimeoutAndAbortRunRule.java37 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 DSocksProxy.java56 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 DPeerConnectionClient.java92 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...]

Completed in 1051 milliseconds

12345678910