|
@@ -53,7 +53,6 @@ class MPFuture(base.Future, Generic[ResultType]):
|
|
|
:param use_lock: if True, operations with MPFuture use a global lock to prevent concurrent writes to the same pipe;
|
|
:param use_lock: if True, operations with MPFuture use a global lock to prevent concurrent writes to the same pipe;
|
|
|
If set to False, writing to this future ignores global lock, slightly improving performance, but making user
|
|
If set to False, writing to this future ignores global lock, slightly improving performance, but making user
|
|
|
responsible for avoiding concurrent set_result / set_exception calls to futures with the same process of origin.
|
|
responsible for avoiding concurrent set_result / set_exception calls to futures with the same process of origin.
|
|
|
- :param loop: if specified, overrides default asyncio event loop for the purpose of awaiting MPFuture
|
|
|
|
|
|
|
|
|
|
:note: This is an internal primitive that is not guaranteed to work outside of hivemind applications.
|
|
:note: This is an internal primitive that is not guaranteed to work outside of hivemind applications.
|
|
|
More specifically, there are two known limitations:
|
|
More specifically, there are two known limitations:
|
justheuristic