Asynchronous version of `apply()` method.
(self, func, args=(), kwds={}, callback=None,
error_callback=None)
| 451 | return (item for chunk in result for item in chunk) |
| 452 | |
| 453 | def apply_async(self, func, args=(), kwds={}, callback=None, |
| 454 | error_callback=None): |
| 455 | ''' |
| 456 | Asynchronous version of `apply()` method. |
| 457 | ''' |
| 458 | self._check_running() |
| 459 | result = ApplyResult(self, callback, error_callback) |
| 460 | self._taskqueue.put(([(result._job, 0, func, args, kwds)], None)) |
| 461 | return result |
| 462 | |
| 463 | def map_async(self, func, iterable, chunksize=None, callback=None, |
| 464 | error_callback=None): |