(self)
| 19 | """A thread-safe future implementation. Used only as one-to-one pipe.""" |
| 20 | |
| 21 | def __init__(self): |
| 22 | self._result = None |
| 23 | self._lock = threading.Lock() |
| 24 | self._cond = threading.Condition(self._lock) |
| 25 | |
| 26 | def put(self, result): |
| 27 | with self._lock: |
nothing calls this directly
no outgoing calls
no test coverage detected