Home
last modified time | relevance | path

Searched refs:executor (Results 1 - 25 of 67) sorted by relevance

123

/third_party/python/Lib/test/
H A Dtest_concurrent_futures.py126 self.executor = self.executor_type(
131 self.executor = self.executor_type(
136 self.executor.shutdown(wait=True)
137 self.executor = None
225 futures = [self.executor.submit(get_init_status)
253 future = self.executor.submit(get_init_status)
255 # Perhaps the executor is already broken
260 # At some point, the executor should break
262 while not self.executor._broken:
264 self.fail("executor no
[all...]
/third_party/vk-gl-cts/executor/
H A DxeBatchExecutor.cpp21 * \brief Test batch executor.
352 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueStateChanged() local
353 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchStateChanged); in enqueueStateChanged()
355 writer << executor in enqueueStateChanged()
364 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueTestLogData() local
365 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchTestLogData); in enqueueTestLogData()
367 writer << executor in enqueueTestLogData()
376 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueInfoLogData() local
377 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchInfoLogData); in enqueueInfoLogData()
379 writer << executor in enqueueInfoLogData()
388 BatchExecutor* executor = DE_NULL; dispatchStateChanged() local
401 BatchExecutor* executor = DE_NULL; dispatchTestLogData() local
412 BatchExecutor* executor = DE_NULL; dispatchInfoLogData() local
[all...]
/third_party/python/Lib/concurrent/futures/
H A Dthread.py75 executor = executor_reference()
76 if executor is not None:
77 executor._initializer_failed()
88 executor = executor_reference()
89 if executor is not None:
90 executor._idle_semaphore.release()
91 del executor
94 executor = executor_reference()
97 # - The executor that owns the worker has been collected OR
98 # - The executor tha
[all...]
H A Dprocess.py280 executor: A reference to the ProcessPoolExecutor that owns
283 the executor.
286 def __init__(self, executor):
287 # Store references to necessary internals of the executor.
291 self.thread_wakeup = executor._executor_manager_thread_wakeup
292 self.shutdown_lock = executor._shutdown_lock
297 # When the executor gets garbage collected, the weakref callback
308 self.executor_reference = weakref.ref(executor, weakref_cb)
311 self.processes = executor._processes
315 self.call_queue = executor
[all...]
/third_party/vk-gl-cts/external/openglcts/modules/common/
H A DglcShaderMacroTests.cpp65 de::SharedPtr<ShaderExecutor> executor(createExecutor(m_context.getRenderContext(), m_shaderType, m_shaderSpec)); in iterate()
67 DE_ASSERT(executor.get()); in iterate()
69 executor->log(m_context.getTestContext().getLog()); in iterate()
71 if (!executor->isOk()) in iterate()
74 executor->useProgram(); in iterate()
78 executor->execute(1, DE_NULL, &outputs); in iterate()
H A DglcShaderConstExprTests.cpp82 void validateOutput(de::SharedPtr<ShaderExecutor> executor);
105 void ExecutorTestCase<float>::validateOutput(de::SharedPtr<ShaderExecutor> executor) in validateOutput() argument
109 executor->execute(1, DE_NULL, &outputs); in validateOutput()
128 void ExecutorTestCase<int>::validateOutput(de::SharedPtr<ShaderExecutor> executor) in validateOutput() argument
132 executor->execute(1, DE_NULL, &outputs); in validateOutput()
148 de::SharedPtr<ShaderExecutor> executor(createExecutor(m_context.getRenderContext(), m_shaderType, m_shaderSpec)); in iterate()
150 DE_ASSERT(executor.get()); in iterate()
152 executor->log(m_context.getTestContext().getLog()); in iterate()
156 if (!executor->isOk()) in iterate()
159 executor in iterate()
[all...]
/third_party/skia/src/gpu/vk/
H A DGrVkMemoryReclaimer.cpp24 static std::unique_ptr<SkExecutor> executor = ({ in getThreadPool() local
25 auto executor = SkExecutor::MakeFIFOThreadPool(1, false); in getThreadPool()
26 executor->add([]() { in getThreadPool()
32 std::move(executor); in getThreadPool()
34 return *executor; in getThreadPool()
/third_party/vk-gl-cts/modules/glshared/
H A DglsShaderExecUtil.hpp69 //! Base class for shader executor.
75 //! Check if executor can be used.
78 //! Log executor details (program etc.).
99 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor* executor) { executor->log(log); return log; } in operator <<() argument
100 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor& executor) { executor.log(log); return log; } in operator <<() argument
/third_party/skia/src/core/
H A DSkExecutor.cpp40 static auto* executor = new SkTrivialExecutor(); in trivial_executor() local
41 return *executor; in trivial_executor()
53 void SkExecutor::SetDefault(SkExecutor* executor) { in SetDefault() argument
54 gDefaultExecutor = executor; in SetDefault()
69 // An SkThreadPool is an executor that runs work on a fixed pool of OS threads.
H A DSkTaskGroup.cpp11 SkTaskGroup::SkTaskGroup(SkExecutor& executor) : fPending(0), fExecutor(executor) {} in SkTaskGroup() argument
37 // Actively help the executor do work until our task group is done. in wait()
H A DSkTaskGroup.h19 // Tasks added to this SkTaskGroup will run on its executor.
20 explicit SkTaskGroup(SkExecutor& executor = SkExecutor::GetDefault());
/third_party/vk-gl-cts/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...]
/third_party/jerryscript/tests/jerry/es2015/
H A Dregression-test-issue-2107.js19 function executor(resolve) { function
23 new Promise(executor);
/third_party/node/tools/gyp/pylib/gyp/
H A Dflock_tool.py17 executor = FlockTool()
18 executor.Dispatch(args)
/third_party/node/deps/npm/node_modules/node-gyp/gyp/pylib/gyp/
H A Dflock_tool.py17 executor = FlockTool()
18 executor.Dispatch(args)
/third_party/jerryscript/jerry-core/ecma/operations/
H A Decma-promise-object.c382 ecma_call_builtin_executor (ecma_object_t *executor_p, /**< the executor object */ in ecma_call_builtin_executor()
514 ecma_op_create_promise_object (ecma_value_t executor, /**< the executor function or object */ in ecma_op_create_promise_object() argument
515 ecma_promise_executor_type_t type) /**< indicates the type of executor */ in ecma_op_create_promise_object()
565 JERRY_ASSERT (ecma_op_is_callable (executor)); in ecma_op_create_promise_object()
568 completion = ecma_op_function_call (ecma_get_object_from_value (executor), in ecma_op_create_promise_object()
575 JERRY_ASSERT (ecma_is_value_object (executor)); in ecma_op_create_promise_object()
577 completion = ecma_call_builtin_executor (ecma_get_object_from_value (executor), in ecma_op_create_promise_object()
584 JERRY_UNUSED (executor); in ecma_op_create_promise_object()
705 ecma_value_t executor in ecma_promise_new_capability() local
[all...]
/third_party/node/test/async-hooks/
H A Dtest-promise.js16 const p = new Promise(common.mustCall(executor));
26 function executor(resolve) { function
30 checkInvocations(a, { init: 1 }, 'while in promise executor');
/third_party/vk-gl-cts/external/vulkancts/modules/vulkan/
H A DvktBuildPrograms.cpp413 TaskExecutor executor (numThreads); in buildPrograms()
463 executor.submit(&buildGlslTasks.back()); in buildPrograms()
478 executor.submit(&buildHlslTasks.back()); in buildPrograms()
493 executor.submit(&buildSpirvAsmTasks.back()); in buildPrograms()
501 executor.waitForComplete(); in buildPrograms()
514 executor.submit(&validationTasks.back()); in buildPrograms()
518 executor.waitForComplete(); in buildPrograms()
/third_party/vk-gl-cts/executor/tools/
H A DxeCommandLineExecutor.cpp21 * \brief Command line test executor.
520 void setupSignalHandler (xe::BatchExecutor* executor) in setupSignalHandler() argument
522 s_executor = executor; in setupSignalHandler()
554 void setupSignalHandler (xe::BatchExecutor* executor) in setupSignalHandler() argument
556 s_executor = executor; in setupSignalHandler()
610 xe::BatchExecutor executor(cmdLine.targetCfg, commLink.get(), &root, testSet, &batchResult, &infoLog); in runExecutor()
614 setupSignalHandler(&executor); in runExecutor()
615 executor.run(); in runExecutor()
/third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/
H A DvktBuildPrograms.cpp402 TaskExecutor executor (numThreads); in buildPrograms()
458 executor.submit(&buildGlslTasks.back()); in buildPrograms()
473 executor.submit(&buildHlslTasks.back()); in buildPrograms()
488 executor.submit(&buildSpirvAsmTasks.back()); in buildPrograms()
497 executor.waitForComplete(); in buildPrograms()
511 executor.submit(&validationTasks.back()); in buildPrograms()
515 executor.waitForComplete(); in buildPrograms()
/third_party/skia/tests/
H A DSkScalerCacheTest.cpp56 // Make our own executor so the --threads parameter doesn't mess things up. in DEF_TEST()
57 auto executor = SkExecutor::MakeFIFOThreadPool(kThreadCount); in DEF_TEST() local
80 SkTaskGroup(*executor).batch(kThreadCount, perThread); in DEF_TEST()
/third_party/vk-gl-cts/framework/randomshaders/
H A DrsgTest.cpp68 rsg::ProgramExecutor executor(surface.getAccess(), 3, 5); in runTest()
70 executor.execute(vertexShader, fragmentShader, uniformValues); in runTest()
/third_party/typescript/tests/baselines/reference/
H A DcallWithMissingVoid.js29 constructor(executor: (resolve: (value: X) => void) => void) {
106 function MyPromise(executor) {
/third_party/skia/tools/skqp/
H A Djitter_gms.cpp121 auto executor = SkExecutor::MakeFIFOThreadPool(); in main() local
124 executor->add([factory, &mutex, &goodResults, &badResults, in main()
/third_party/python/Lib/asyncio/
H A Dbase_events.py565 """Schedule the shutdown of the default executor."""
666 This clears the queues and shuts down the executor,
667 but does not wait for the executor to finish.
681 executor = self._default_executor
682 if executor is not None:
684 executor.shutdown(wait=False)
815 def run_in_executor(self, executor, func, *args):
819 if executor is None:
820 executor = self._default_executor
821 # Only check when the default executor i
[all...]

Completed in 14 milliseconds

123