/external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/ |
H A D | SSLEngineTest.java | 890 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 D | SSLSocketTest.java | 143 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 D | xsTest.cpp | 909 TestExecutor executor(testCtx); 910 executor.runCase(*casePos); 924 TestExecutor executor(testCtx); 925 executor.runCases(testCases);
|
/external/skia/src/core/ |
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/core/common_runtime/ |
H A D | direct_session.cc | 25 #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 D | direct_session.h | 30 #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 D | executor.cc | 16 #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 D | test_base_events.py | 225 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 D | vktAtomicOperationTests.cpp | 492 UniquePtr<ShaderExecutor> executor(createExecutor(m_context, m_shaderType, m_shaderSpec, *extraResourcesLayout)); 493 executor->execute(NUM_ELEMENTS, DE_NULL, &outputPtr[0], *extraResourcesSet);
|
H A D | vktOpaqueTypeIndexingTests.cpp | 937 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 D | vktYCbCrFormatTests.cpp | 411 UniquePtr<ShaderExecutor> executor (createExecutor(context, params.shaderType, getShaderSpec(params), *descLayout)); 415 executor->execute((int)texCoord.size(), inputs, outputs, *descSet);
|
H A D | vktYCbCrViewTests.cpp | 635 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 D | ServiceManagerTest.java | 454 @Override public final void addListener(Listener listener, Executor executor) { 456 delegate.addListener(listener, executor);
|
H A D | FuturesTest.java | 285 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 D | build_ext.py | 463 with ThreadPoolExecutor(max_workers=workers) as executor: 464 futures = [executor.submit(self.build_extension, ext)
|
/external/tensorflow/tensorflow/python/estimator/ |
H A D | training.py | 415 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 D | data_utils.py | 553 """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 D | generic.py | 216 nrg_model = self.executor.te.nrg_model
|
/external/tensorflow/tensorflow/compiler/xla/tests/ |
H A D | local_client_execute_test.cc | 682 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 D | remote_fused_graph_execute_utils.h | 70 std::unique_ptr<IRemoteFusedGraphExecutor>* executor)>;
|
H A D | remote_fused_graph_execute_utils.cc | 1095 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 D | TrustedCertificateStoreTest.java | 740 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 D | SubsamplingScaleImageView.java | 177 // 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 D | config.py | 22 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 D | TestRunner.java | 737 * 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();
|