Searched refs:executor (Results 176 - 200 of 235) sorted by relevance

12345678910

/external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/
H A DSSLEngineTest.java890 ExecutorService executor = Executors.newFixedThreadPool(2);
891 Future<Void> client = executor.submit(new Callable<Void>() {
904 Future<Void> server = executor.submit(new Callable<Void>() {
917 executor.shutdown();
H A DSSLSocketTest.java143 private ExecutorService executor; field in class:SSLSocketTest
149 executor = Executors.newCachedThreadPool(new ThreadFactory() {
159 executor.shutdownNow();
160 executor.awaitTermination(5, TimeUnit.SECONDS);
426 ExecutorService executor = Executors.newSingleThreadExecutor();
427 Future<Void> future = executor.submit(new Callable<Void>() {
433 executor.shutdown();
458 ExecutorService executor = Executors.newSingleThreadExecutor();
459 Future<Void> future = executor.submit(new Callable<Void>() {
465 executor
[all...]
/external/deqp/execserver/tools/
H A DxsTest.cpp909 TestExecutor executor(testCtx);
910 executor.runCase(*casePos);
924 TestExecutor executor(testCtx);
925 executor.runCases(testCases);
/external/skia/src/core/
H A DSkThreadedBMPDevice.h18 // When executor = nullptr, we manages the thread pool. Otherwise, the caller manages it.
20 SkExecutor* executor = nullptr);
/external/tensorflow/tensorflow/core/common_runtime/
H A Ddirect_session.cc25 #include "tensorflow/core/common_runtime/executor.h"
229 // the local rendezvous before we start the executor, so the
467 // Check if we already have an executor for these arguments.
606 item.executor->RunAsync(args, barrier->Get());
728 // Check if we already have an executor for these arguments.
785 item.executor->RunAsync(args, barrier->Get());
1148 // The executor_lock_ is intentionally released while executor is
1249 item->executor = nullptr;
1251 Executor* executor; local
1253 NewLocalExecutor(params, std::move(partition_graph), &executor));
[all...]
H A Ddirect_session.h30 #include "tensorflow/core/common_runtime/executor.h"
111 // We create one executor and its dependent library runtime for
117 std::unique_ptr<Executor> executor; member in struct:tensorflow::DirectSession::PerPartitionExecutorsAndLib
124 // the case of partial runs. Each item in 'items' is the executor for
147 // executor) should be destroyed first, followed by the resources in the
H A Dexecutor.cc16 #include "tensorflow/core/common_runtime/executor.h"
425 // the overhead of constructing it for each executor instance.
936 : executor(impl),
968 // The executor the frame is in.
969 const ExecutorImpl* executor = nullptr; member in struct:tensorflow::__anon26154::ExecutorState::FrameState
1029 auto it_frame_info = executor->frame_info_.find(enter_name);
1030 DCHECK(it_frame_info != executor->frame_info_.end());
1267 // Provide debugging output about an outstanding node in the executor.
1272 // Provide debugging output about an outstanding iteration in the executor.
1275 // Provide debugging output of the state of the executor
2608 NewLocalExecutor(const LocalExecutorParams& params, std::unique_ptr<const Graph> graph, Executor** executor) argument
[all...]
/external/python/cpython3/Lib/test/test_asyncio/
H A Dtest_base_events.py225 executor = mock.Mock()
226 self.loop.set_default_executor(executor)
227 self.assertIs(executor, self.loop._default_executor)
361 executor = mock.Mock()
362 executor.submit.return_value = f
364 self.loop.set_default_executor(executor)
369 executor = mock.Mock()
370 executor.submit.return_value = f
371 res = self.loop.run_in_executor(executor, cb)
373 self.assertTrue(executor
[all...]
/external/deqp/external/vulkancts/modules/vulkan/shaderexecutor/
H A DvktAtomicOperationTests.cpp492 UniquePtr<ShaderExecutor> executor(createExecutor(m_context, m_shaderType, m_shaderSpec, *extraResourcesLayout));
493 executor->execute(NUM_ELEMENTS, DE_NULL, &outputPtr[0], *extraResourcesSet);
H A DvktOpaqueTypeIndexingTests.cpp937 UniquePtr<ShaderExecutor> executor (createExecutor(m_context, m_shaderType, m_shaderSpec, *extraResourcesLayout));
957 executor->execute(numInvocations, &inputs[0], &outputs[0], *extraResourcesSet);
1415 UniquePtr<ShaderExecutor> executor (createExecutor(m_context, m_shaderType, m_shaderSpec, *extraResourcesLayout));
1417 executor->execute(numInvocations, inputs.empty() ? DE_NULL : &inputs[0], &outputs[0], *extraResourcesSet);
1778 UniquePtr<ShaderExecutor> executor (createExecutor(m_context, m_shaderType, m_shaderSpec, *extraResourcesLayout));
1780 executor->execute(numInvocations, inputs.empty() ? DE_NULL : &inputs[0], &outputs[0], *extraResourcesSet);
/external/deqp/external/vulkancts/modules/vulkan/ycbcr/
H A DvktYCbCrFormatTests.cpp411 UniquePtr<ShaderExecutor> executor (createExecutor(context, params.shaderType, getShaderSpec(params), *descLayout));
415 executor->execute((int)texCoord.size(), inputs, outputs, *descSet);
H A DvktYCbCrViewTests.cpp635 UniquePtr<ShaderExecutor> executor (createExecutor(context, params.shaderType, getShaderSpec(params), *descLayout));
639 executor->execute((int)numValues, inputs, outputs, *descSet);
/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DServiceManagerTest.java454 @Override public final void addListener(Listener listener, Executor executor) {
456 delegate.addListener(listener, executor);
H A DFuturesTest.java285 ExecutorService executor = newDirectExecutorService();
287 Futures.transform(input, Functions.toStringFunction(), executor);
288 executor.shutdown();
1320 ExecutorService executor = newSingleThreadExecutor();
1321 Future<V> waiter = executor.submit(new Callable<V>() {
1338 executor.shutdownNow();
1339 assertTrue(executor.awaitTermination(10, SECONDS));
/external/python/cpython3/Lib/distutils/command/
H A Dbuild_ext.py463 with ThreadPoolExecutor(max_workers=workers) as executor:
464 futures = [executor.submit(self.build_extension, ext)
/external/tensorflow/tensorflow/python/estimator/
H A Dtraining.py415 executor = _TrainingExecutor(
425 executor.run()
445 """The executor to run `Estimator` training and evaluation.
515 # For task type foo, call executor.run_foo.
/external/tensorflow/tensorflow/python/keras/_impl/keras/utils/
H A Ddata_utils.py553 """Submits request to the executor and queue the `Future` objects."""
560 with closing(self.executor_fn()) as executor:
565 executor.apply_async(get_index, (self.uid, i)), block=True)
/external/lisa/tests/eas/
H A Dgeneric.py216 nrg_model = self.executor.te.nrg_model
/external/tensorflow/tensorflow/compiler/xla/tests/
H A Dlocal_client_execute_test.cc682 se::StreamExecutor* executor = local
684 se::Stream stream(executor);
744 se::StreamExecutor* executor = local
748 se::Stream stream(executor);
/external/tensorflow/tensorflow/core/kernels/
H A Dremote_fused_graph_execute_utils.h70 std::unique_ptr<IRemoteFusedGraphExecutor>* executor)>;
H A Dremote_fused_graph_execute_utils.cc1095 return errors::InvalidArgument("Unknown executor name: " + executor_name);
1097 std::unique_ptr<IRemoteFusedGraphExecutor> executor; local
1098 TF_RETURN_IF_ERROR((*build_func)(&executor));
1099 CHECK_NOTNULL(executor.get());
1100 if (!executor->IsEnabled()) {
1101 // As this executor is not enabled, just return original graph as is.
1105 return executor->FuseRemoteGraph(input_graph_def, inputs, outputs,
/external/conscrypt/platform/src/test/java/org/conscrypt/
H A DTrustedCertificateStoreTest.java740 ExecutorService executor = Executors.newSingleThreadExecutor();
741 Future<List<X509Certificate>> future = executor
748 executor.shutdown();
/external/subsampling-scale-image-view/library/src/main/java/com/davemorrissey/labs/subscaleview/
H A DSubsamplingScaleImageView.java177 // An executor service for loading of images
178 private Executor executor = AsyncTask.THREAD_POOL_EXECUTOR; field in class:SubsamplingScaleImageView
1875 asyncTask.executeOnExecutor(executor);
2782 * strongly recommended to use a single executor instance for the life of your application, not
2786 * supply an executor with more than one thread, you must make sure your implementation supports
2791 * @param executor an {@link Executor} for image loading.
2793 public void setExecutor(Executor executor) { argument
2794 if (executor == null) {
2797 this.executor = executor;
[all...]
/external/libcxx/utils/libcxx/test/
H A Dconfig.py22 from libcxx.test.executor import *
182 self.executor,
186 exec_str = self.get_lit_conf('executor', "None")
189 self.lit_config.note("Using executor: %r" % exec_str)
196 " executor.")
201 self.executor = te
/external/testng/src/main/java/org/testng/
H A DTestRunner.java737 * graph executor to run them.
752 GraphThreadPoolExecutor<ITestNGMethod> executor =
756 executor.run();
759 Utils.log("TestRunner", 2, "Starting executor for test " + m_xmlTest.getName()
761 executor.awaitTermination(timeOut, TimeUnit.MILLISECONDS);
762 executor.shutdownNow();

Completed in 1967 milliseconds

12345678910