futured
A partial function which returns futures.
Usage
futured()Classes
| Name | Description |
|---|---|
| tasks | A set of futures which tracks completion. |
tasks
A set of futures which tracks completion.
Usage
tasks(fs=(), *, timeout=None)The context manager waits for all tasks.
Methods
| Name | Description |
|---|---|
| pop() | Remove and return next completed task. |
pop()
Remove and return next completed task.
Usage
pop()Methods
| Name | Description |
|---|---|
| items() | Generate key, result pairs as completed from futures. |
| map() | Asynchronously map function. |
| mapzip() | Generate arg, result pairs as completed. |
| results() | Generate results concurrently from futures, by default in order. |
| starmap() | Asynchronously starmap function. |
items()
Generate key, result pairs as completed from futures.
Usage
items(pairs, **kwargs)Parameters
| Name | Type | Description | Default |
|---|---|---|---|
| pairs | key, future pairs **kwargs: as completed options, e.g., timeout | - |
map()
Asynchronously map function.
Usage
map(*iterables, **kwargs)**kwargs: keyword options for [results][futured.futured.results]
mapzip()
Generate arg, result pairs as completed.
Usage
mapzip(iterable, **kwargs)**kwargs: keyword options for [items][futured.futured.items]
results()
Generate results concurrently from futures, by default in order.
Usage
results(fs, *, as_completed=False, **kwargs)Parameters
| Name | Type | Description | Default |
|---|---|---|---|
| fs | iterable of futures as_completed kwargs: generate results as completed with options, e.g., timeout | - |
starmap()
Asynchronously starmap function.
Usage
starmap(iterable, **kwargs)**kwargs: keyword options for [results][futured.futured.results]