Home
last modified time | relevance | path

Searched refs:apply_async (Results 1 – 25 of 27) sorted by relevance

12

/external/python/cpython2/Doc/includes/
Dmp_pool.py68 results = [pool.apply_async(calculate, t) for t in TASKS]
190 res = pool.apply_async(calculate, TASKS[0])
223 r = pool.apply_async(mul, (7, 8), callback=A.append)
249 result = pool.apply_async(time.sleep, [0.5])
269 results = [pool.apply_async(time.sleep, [DELTA]) for i in range(100)]
288 results = [pool.apply_async(time.sleep, [DELTA]) for i in range(100)]
/external/python/cpython3/Doc/includes/
Dmp_pool.py53 results = [pool.apply_async(calculate, t) for t in TASKS]
126 res = pool.apply_async(calculate, TASKS[0])
/external/toolchain-utils/toolchain_utils_githooks/
Dcheck-presubmit211 thread_pool.apply_async(check_yapf,
214 thread_pool.apply_async(check_python_file_headers, (python_files,))),
272 tasks.append(('pylint', thread_pool.apply_async(run_pylint)))
292 tasks.append(('golint', thread_pool.apply_async(run_golint)))
Dcheck-presubmit.py211 thread_pool.apply_async(check_yapf,
214 thread_pool.apply_async(check_python_file_headers, (python_files,))),
272 tasks.append(('pylint', thread_pool.apply_async(run_pylint)))
292 tasks.append(('golint', thread_pool.apply_async(run_golint)))
/external/webrtc/webrtc/tools/barcode_tools/
Dhelper_functions.py93 future = process_pool.apply_async(action, args=(file_name,), kwds=kwargs)
/external/toolchain-utils/bestflags/
Dpipeline_process.py113 work_pool.apply_async(
/external/autotest/client/site_tests/power_CameraSuspend/
Dpower_CameraSuspend.py50 result = pool.apply_async(async_suspend)
/external/skqp/tools/
Dcheck-headers-self-sufficient155 pool.apply_async(compile_header, args=(path, ), callback=print_and_exit_if)
/external/skia/tools/skqp/
Ddownload_model.py63 pool.apply_async(download, record, callback=lambda x: sys.stderr.write('.'))
/external/skqp/tools/skqp/
Ddownload_model65 pool.apply_async(download, record, callback=lambda x: sys.stderr.write('.'))
/external/skia/tools/
Dcheck-headers-self-sufficient94 pool.apply_async(compile_header, args=(path, ), callback=print_and_exit_if)
/external/autotest/client/site_tests/power_HotCPUSuspend/
Dpower_HotCPUSuspend.py79 results = [pool.apply_async(cpu_stress) for _ in xrange(workers)]
/external/swiftshader/third_party/llvm-7.0/llvm/utils/lit/lit/
Drun.py85 async_results = [pool.apply_async(worker_run_one_test,
/external/tensorflow/tensorflow/python/keras/engine/
Dtraining_utils_test.py264 def apply_async(self, func, *args, **kwargs): member in MonitoredPool
268 return super(MonitoredPool, self).apply_async(func, *args, **kwargs)
Dtraining_utils.py283 self._pool.apply_async(
/external/tensorflow/tensorflow/python/keras/utils/
Ddata_utils.py849 executor.apply_async(get_index, (self.uid, i)), block=True)
975 executor.apply_async(next_sample, (self.uid,)), block=True)
/external/toolchain-utils/
Drun_tests_for.py131 results = [pool.apply_async(_run_test, (test,)) for test in all_tests]
/external/python/cpython2/Lib/multiprocessing/
Dpool.py246 return self.apply_async(func, args, kwds).get()
291 def apply_async(self, func, args=(), kwds={}, callback=None): member in Pool
/external/python/cpython3/Lib/multiprocessing/
Dpool.py357 return self.apply_async(func, args, kwds).get()
450 def apply_async(self, func, args=(), kwds={}, callback=None, member in Pool
/external/python/cpython2/Lib/test/
Dtest_multiprocessing.py1218 res = self.pool.apply_async(sqr, (7, TIMEOUT1,))
1224 res = self.pool.apply_async(sqr, (6, TIMEOUT2 + 1.0))
1352 res = p.apply_async(unpickleable_result)
1368 results.append(p.apply_async(sqr, (i, )))
1396 results.append(p.apply_async(sqr, (i, 0.3)))
/external/python/cpython2/Doc/library/
Dmultiprocessing.rst282 res = pool.apply_async(f, (20,)) # runs in *only* one process
286 res = pool.apply_async(os.getpid, ()) # runs in *only* one process
290 multiple_results = [pool.apply_async(os.getpid, ()) for i in range(4)]
294 res = pool.apply_async(time.sleep, (10,))
1824 result is ready, so :meth:`apply_async` is better suited for performing
1828 .. method:: apply_async(func[, args[, kwds[, callback]]])
1894 The class of the result returned by :meth:`Pool.apply_async` and
1928 result = pool.apply_async(f, (10,)) # evaluate "f(10)" asynchronously in a single process
1938 result = pool.apply_async(time.sleep, (10,))
/external/python/cpython3/Doc/library/
Dmultiprocessing.rst403 res = pool.apply_async(f, (20,)) # runs in *only* one process
407 res = pool.apply_async(os.getpid, ()) # runs in *only* one process
411 multiple_results = [pool.apply_async(os.getpid, ()) for i in range(4)]
415 res = pool.apply_async(time.sleep, (10,))
2149 until the result is ready. Given this blocks, :meth:`apply_async` is
2153 .. method:: apply_async(func[, args[, kwds[, callback[, error_callback]]]])
2261 The class of the result returned by :meth:`Pool.apply_async` and
2298 result = pool.apply_async(f, (10,)) # evaluate "f(10)" asynchronously in a single process
2308 result = pool.apply_async(time.sleep, (10,))
/external/selinux/python/sepolicy/
Dsepolicy.py351 p.apply_async(manpage_work, [domain, path, args.root, args.source_files, args.web])
/external/python/cpython3/Lib/test/
D_test_multiprocessing.py2430 res = self.pool.apply_async(sqr, (7, TIMEOUT1,))
2436 res = self.pool.apply_async(sqr, (6, TIMEOUT2 + 1.0))
2706 res = p.apply_async(raising, error_callback=errback)
2725 res = p.apply_async(unpickleable_result, error_callback=errback)
2746 results.append(p.apply_async(sqr, (i, )))
2774 results.append(p.apply_async(sqr, (i, 0.3)))
/external/python/cpython2/Doc/whatsnew/
D2.6.rst623 by calling :meth:`apply` or :meth:`apply_async` to add a single request,
679 p.apply_async(factorial, (N, d))

12