| /external/python/cpython2/Doc/includes/ |
| D | mp_pool.py | 68 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/ |
| D | mp_pool.py | 53 results = [pool.apply_async(calculate, t) for t in TASKS]
126 res = pool.apply_async(calculate, TASKS[0])
|
| /external/webrtc/webrtc/tools/barcode_tools/ |
| D | helper_functions.py | 93 future = process_pool.apply_async(action, args=(file_name,), kwds=kwargs)
|
| /external/toolchain-utils/bestflags/ |
| D | pipeline_process.py | 113 work_pool.apply_async(
|
| /external/autotest/client/site_tests/power_CameraSuspend/ |
| D | power_CameraSuspend.py | 50 result = pool.apply_async(async_suspend)
|
| /external/skqp/tools/ |
| D | check-headers-self-sufficient | 155 pool.apply_async(compile_header, args=(path, ), callback=print_and_exit_if)
|
| /external/skia/tools/ |
| D | check-headers-self-sufficient | 154 pool.apply_async(compile_header, args=(path, ), callback=print_and_exit_if)
|
| /external/skia/tools/skqp/ |
| D | download_model | 65 pool.apply_async(download, record, callback=lambda x: sys.stderr.write('.'))
|
| /external/skqp/tools/skqp/ |
| D | download_model | 65 pool.apply_async(download, record, callback=lambda x: sys.stderr.write('.'))
|
| /external/autotest/client/site_tests/power_HotCPUSuspend/ |
| D | power_HotCPUSuspend.py | 79 results = [pool.apply_async(cpu_stress) for _ in xrange(workers)]
|
| /external/tensorflow/tensorflow/python/keras/utils/ |
| D | data_utils.py | 624 executor.apply_async(get_index, (self.uid, i)), block=True)
729 executor.apply_async(next_sample, (self.uid,)), block=True)
|
| /external/swiftshader/third_party/llvm-7.0/llvm/utils/lit/lit/ |
| D | run.py | 85 async_results = [pool.apply_async(worker_run_one_test,
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | pool.py | 246 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/ |
| D | pool.py | 261 return self.apply_async(func, args, kwds).get()
356 def apply_async(self, func, args=(), kwds={}, callback=None, member in Pool
|
| /external/python/cpython2/Lib/test/ |
| D | test_multiprocessing.py | 1218 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/ |
| D | multiprocessing.rst | 282 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/ |
| D | multiprocessing.rst | 393 res = pool.apply_async(f, (20,)) # runs in *only* one process
397 res = pool.apply_async(os.getpid, ()) # runs in *only* one process
401 multiple_results = [pool.apply_async(os.getpid, ()) for i in range(4)]
405 res = pool.apply_async(time.sleep, (10,))
2122 until the result is ready. Given this blocks, :meth:`apply_async` is
2126 .. method:: apply_async(func[, args[, kwds[, callback[, error_callback]]]])
2233 The class of the result returned by :meth:`Pool.apply_async` and
2266 result = pool.apply_async(f, (10,)) # evaluate "f(10)" asynchronously in a single process
2276 result = pool.apply_async(time.sleep, (10,))
|
| /external/python/cpython3/Lib/test/ |
| D | _test_multiprocessing.py | 2330 res = self.pool.apply_async(sqr, (7, TIMEOUT1,))
2336 res = self.pool.apply_async(sqr, (6, TIMEOUT2 + 1.0))
2575 res = p.apply_async(raising, error_callback=errback)
2594 res = p.apply_async(unpickleable_result, error_callback=errback)
2615 results.append(p.apply_async(sqr, (i, )))
2643 results.append(p.apply_async(sqr, (i, 0.3)))
|
| /external/python/cpython2/Doc/whatsnew/ |
| D | 2.6.rst | 623 by calling :meth:`apply` or :meth:`apply_async` to add a single request,
679 p.apply_async(factorial, (N, d))
|
| /external/python/cpython3/Doc/whatsnew/ |
| D | 2.6.rst | 627 by calling :meth:`apply` or :meth:`apply_async` to add a single request,
683 p.apply_async(factorial, (N, d))
|
| /external/python/cpython3/Misc/ |
| D | HISTORY | 11582 - Issue #9244: The ``apply_async()`` and ``map_async()`` methods of
|