| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 120 self.executor = self.executor_type(
125 self.executor = self.executor_type(
131 self.executor.shutdown(wait=True)
132 self.executor = None
147 futures = [self.executor.submit(time.sleep, 0.1)
228 futures = [self.executor.submit(get_init_status)
256 future = self.executor.submit(get_init_status)
265 while not self.executor._broken:
271 self.executor.submit(get_init_status)
300 self.executor.shutdown()
[all …]
|
| /third_party/vk-gl-cts/executor/ |
| D | xeBatchExecutor.cpp | 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; in dispatchStateChanged() local
[all …]
|
| /third_party/python/Lib/concurrent/futures/ |
| D | thread.py | 75 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()
99 if _shutdown or executor is None or executor._shutdown:
102 if executor is not None:
[all …]
|
| D | process.py | 268 def __init__(self, executor): argument
273 self.thread_wakeup = executor._executor_manager_thread_wakeup
274 self.shutdown_lock = executor._shutdown_lock
290 self.executor_reference = weakref.ref(executor, weakref_cb)
293 self.processes = executor._processes
297 self.call_queue = executor._call_queue
300 self.result_queue = executor._result_queue
303 self.work_ids_queue = executor._work_ids
307 self.pending_work_items = executor._pending_work_items
329 executor = self.executor_reference()
[all …]
|
| /third_party/vk-gl-cts/external/openglcts/modules/common/ |
| D | glcShaderMacroTests.cpp | 65 …de::SharedPtr<ShaderExecutor> executor(createExecutor(m_context.getRenderContext(), m_shaderType, … in iterate() local
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()
|
| D | glcShaderConstExprTests.cpp | 82 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, … in iterate() local
150 DE_ASSERT(executor.get()); in iterate()
152 executor->log(m_context.getTestContext().getLog()); in iterate()
156 if (!executor->isOk()) in iterate()
159 executor->useProgram(); in iterate()
[all …]
|
| /third_party/mesa3d/.gitlab-ci/container/ |
| D | build-deqp.sh | 73 mkdir /deqp/executor.save
74 cp /deqp/executor/testlog-to-* /deqp/executor.save
75 rm -rf /deqp/executor
76 mv /deqp/executor.save /deqp/executor
|
| /third_party/vk-gl-cts/modules/glshared/ |
| D | glsShaderExecUtil.hpp | 99 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor* executor) { executor->log… in operator <<() argument
100 inline tcu::TestLog& operator<< (tcu::TestLog& log, const ShaderExecutor& executor) { executor.log(… in operator <<() argument
|
| /third_party/skia/src/core/ |
| D | SkExecutor.cpp | 40 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()
|
| D | SkTaskGroup.cpp | 11 SkTaskGroup::SkTaskGroup(SkExecutor& executor) : fPending(0), fExecutor(executor) {} in SkTaskGroup() argument
|
| /third_party/ejdb/src/bindings/ejdb2_react_native/binding/android/src/main/java/com/softmotions/ejdb2/ |
| D | EJDB2Package.java | 20 private static final Executor executor = new ThreadPoolExecutor(0, 5, 60L, TimeUnit.SECONDS, field in EJDB2Package
25 …tiveModule>asList(new EJDB2DBModule(reactContext, executor), new EJDB2JQLModule(reactContext, exec… in createNativeModules()
|
| D | EJDB2DBModule.java | 22 private final Executor executor; field in EJDB2DBModule
24 public EJDB2DBModule(ReactApplicationContext reactContext, Executor executor) { in EJDB2DBModule() argument
26 this.executor = executor; in EJDB2DBModule()
36 executor.execute(() -> openImpl(path, opts, promise)); in open()
240 executor.execute(() -> immediate(handle, promise, fn)); in thread()
|
| D | EJDB2JQLModule.java | 28 private final Executor executor; field in EJDB2JQLModule
30 public EJDB2JQLModule(ReactApplicationContext reactContext, Executor executor) { in EJDB2JQLModule() argument
32 this.executor = executor; in EJDB2JQLModule()
275 executor.execute(() -> immediate(jqlid, promise, fn)); in thread()
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 37 with ThreadPoolExecutor(max_workers=1) as executor:
38 future = executor.submit(pow, 323, 1235)
72 Signal the executor that it should free any resources that it is using
79 executor have been freed. If *wait* is ``False`` then this method will
80 return immediately and the resources associated with the executor will be
86 futures that the executor has not started running. Any futures that
91 executor has started running will be completed prior to this method
131 executor = ThreadPoolExecutor(max_workers=2)
132 a = executor.submit(wait_on_b)
133 b = executor.submit(wait_on_a)
[all …]
|
| /third_party/rust/crates/tracing/tracing-futures/src/executor/ |
| D | futures_01.rs | 48 executor::{Executor, SpawnError, TypedExecutor},
129 pub fn executor(&self) -> Instrumented<TaskExecutor> { in executor() method
130 self.inner.executor().instrument(self.span.clone()) in executor()
276 pub fn executor(&self) -> WithDispatch<TaskExecutor> { in executor() method
277 self.with_dispatch(self.inner.executor()) in executor()
|
| /third_party/vk-gl-cts/scripts/ |
| D | run_internal_tests.py | 46 …def __init__ (self, name, srcPath, buildPath, genParams, buildParams, testBinaryName, executor = '… argument
53 self.executor = executor
99 os.path.join(config.buildPath, 'executor', config.executor),
|
| /third_party/node/deps/npm/node_modules/bluebird/js/release/ |
| D | promise.js | 60 function check(self, executor) { argument
64 if (typeof executor !== "function") {
65 throw new TypeError("expecting a function but got " + util.classString(executor));
70 function Promise(executor) { argument
71 if (executor !== INTERNAL) {
72 check(this, executor);
79 this._resolveFromExecutor(executor);
482 Promise.prototype._resolveFromExecutor = function (executor) { argument
483 if (executor === INTERNAL) return;
488 var r = this._execute(executor, function(value) {
|
| /third_party/jerryscript/tests/jerry/es2015/ |
| D | regression-test-issue-2107.js | 19 function executor(resolve) { function
23 new Promise(executor);
|
| /third_party/jerryscript/jerry-core/ecma/operations/ |
| D | ecma-promise-object.c | 514 ecma_op_create_promise_object (ecma_value_t executor, /**< the executor function or object */ in ecma_op_create_promise_object() argument
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 = ecma_make_object_value (executor_p); in ecma_promise_new_capability() local
715 &executor, in ecma_promise_new_capability()
|
| /third_party/flutter/skia/src/core/ |
| D | SkExecutor.cpp | 52 void SkExecutor::SetDefault(SkExecutor* executor) { in SetDefault() argument
53 if (executor) { in SetDefault()
54 gDefaultExecutor = executor; in SetDefault()
|
| D | SkTaskGroup.cpp | 11 SkTaskGroup::SkTaskGroup(SkExecutor& executor) : fPending(0), fExecutor(executor) {} in SkTaskGroup() argument
|
| /third_party/vk-gl-cts/executor/tools/ |
| D | xeCommandLineExecutor.cpp | 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, &infoL… in runExecutor() local
614 setupSignalHandler(&executor); in runExecutor()
615 executor.run(); in runExecutor()
|
| /third_party/node/tools/gyp/pylib/gyp/ |
| D | flock_tool.py | 17 executor = FlockTool()
18 executor.Dispatch(args)
|
| /third_party/node/deps/npm/node_modules/node-gyp/gyp/pylib/gyp/ |
| D | flock_tool.py | 17 executor = FlockTool()
18 executor.Dispatch(args)
|
| /third_party/vk-gl-cts/external/vulkancts/modules/vulkan/ |
| D | vktBuildPrograms.cpp | 402 TaskExecutor executor (numThreads); in buildPrograms() local
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()
|