X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=smart_future.py;h=7aac8ebb68eb3bb3af6da50b127cfb344ff925e3;hb=532df2c5b57c7517dfb3dddd8c1358fbadf8baf3;hp=1f6e6f0aedcf05966e536ec8f10f570c2175a3e4;hpb=a4bf4d05230474ad14243d67ac7f8c938f670e58;p=python_utils.git diff --git a/smart_future.py b/smart_future.py index 1f6e6f0..7aac8eb 100644 --- a/smart_future.py +++ b/smart_future.py @@ -1,18 +1,27 @@ #!/usr/bin/env python3 +# © Copyright 2021-2022, Scott Gasch + +"""A future that can be treated like the result that it contains and +will not block until it is used. At that point, if the underlying +value is not yet available, it will block until it becomes +available. + +""" + from __future__ import annotations import concurrent import concurrent.futures as fut import logging -import traceback from typing import Callable, List, Set, TypeVar from overrides import overrides +import id_generator + # This module is commonly used by others in here and should avoid # taking any unnecessary dependencies back on them. from deferred_operand import DeferredOperand -import id_generator logger = logging.getLogger(__name__) @@ -29,7 +38,7 @@ def wait_any( smart_future_by_real_future = {} completed_futures: Set[fut.Future] = set() for x in futures: - assert type(x) == SmartFuture + assert isinstance(x, SmartFuture) real_futures.append(x.wrapped_future) smart_future_by_real_future[x.wrapped_future] = x @@ -42,15 +51,12 @@ def wait_any( if log_exceptions and not f.cancelled(): exception = f.exception() if exception is not None: - logger.warning( - f'Future {id(f)} raised an unhandled exception and exited.' - ) + logger.warning('Future 0x%x raised an unhandled exception and exited.', id(f)) logger.exception(exception) raise exception yield smart_future_by_real_future[f] if callback is not None: callback() - return def wait_all( @@ -60,7 +66,7 @@ def wait_all( ) -> None: real_futures = [] for x in futures: - assert type(x) == SmartFuture + assert isinstance(x, SmartFuture) real_futures.append(x.wrapped_future) (done, not_done) = concurrent.futures.wait( @@ -71,9 +77,7 @@ def wait_all( if not f.cancelled(): exception = f.exception() if exception is not None: - logger.warning( - f'Future {id(f)} raised an unhandled exception and exited.' - ) + logger.warning('Future 0x%x raised an unhandled exception and exited.', id(f)) logger.exception(exception) raise exception assert len(done) == len(real_futures) @@ -89,7 +93,7 @@ class SmartFuture(DeferredOperand): """ def __init__(self, wrapped_future: fut.Future) -> None: - assert type(wrapped_future) == fut.Future + assert isinstance(wrapped_future, fut.Future) self.wrapped_future = wrapped_future self.id = id_generator.get("smart_future_id") @@ -102,5 +106,5 @@ class SmartFuture(DeferredOperand): # You shouldn't have to call this; instead, have a look at defining a # method on DeferredOperand base class. @overrides - def _resolve(self, *, timeout=None) -> T: + def _resolve(self, timeout=None) -> T: return self.wrapped_future.result(timeout)