Did I find the right examples for you? yes no

All Samples(15)  |  Call(3)  |  Derive(0)  |  Import(12)
:class:`ThreadingFuture` implements :class:`Future` for use with
:class:`ThreadingActor <pykka.ThreadingActor>`.

The future is implemented using a :class:`Queue.Queue`.

The future does *not* make a copy of the object which is :meth:`set()
<pykka.Future.set>` on it. It is the setters responsibility to only pass
immutable objects or make a copy of the object before setting it on the
future.
(more...)

src/p/y/Pykka-1.2.0/pykka/__init__.py   Pykka(Download)
# flake8: noqa
from pykka.actor import Actor, ActorRef, ThreadingActor
from pykka.exceptions import ActorDeadError, Timeout
from pykka.future import Future, get_all, ThreadingFuture
from pykka.proxy import ActorProxy

src/p/y/pykka-HEAD/pykka/__init__.py   pykka(Download)
# flake8: noqa
from pykka.actor import Actor, ActorRef, ThreadingActor
from pykka.exceptions import ActorDeadError, Timeout
from pykka.future import Future, get_all, ThreadingFuture
from pykka.proxy import ActorProxy

src/x/b/xbmc-addon-watchdog-HEAD/lib/pykka/__init__.py   xbmc-addon-watchdog(Download)
# flake8: noqa
from pykka.actor import Actor, ActorRef, ThreadingActor
from pykka.exceptions import ActorDeadError, Timeout
from pykka.future import Future, get_all, ThreadingFuture
from pykka.proxy import ActorProxy

src/p/y/Pykka-1.2.0/pykka/actor.py   Pykka(Download)
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
from pykka.future import ThreadingFuture as _ThreadingFuture
from pykka.proxy import ActorProxy as _ActorProxy
from pykka.registry import ActorRegistry as _ActorRegistry
    def _create_future():
        return _ThreadingFuture()
 
    def _start_actor_loop(self):
        thread = _threading.Thread(target=self._actor_loop)

src/p/y/pykka-HEAD/pykka/actor.py   pykka(Download)
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
from pykka.future import ThreadingFuture as _ThreadingFuture
from pykka.proxy import ActorProxy as _ActorProxy
from pykka.registry import ActorRegistry as _ActorRegistry
    def _create_future():
        return _ThreadingFuture()
 
    def _start_actor_loop(self):
        thread = _threading.Thread(target=self._actor_loop)

src/x/b/xbmc-addon-watchdog-HEAD/lib/pykka/actor.py   xbmc-addon-watchdog(Download)
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
from pykka.future import ThreadingFuture as _ThreadingFuture
from pykka.proxy import ActorProxy as _ActorProxy
from pykka.registry import ActorRegistry as _ActorRegistry
    def _create_future():
        return _ThreadingFuture()
 
    def _start_actor_loop(self):
        thread = _threading.Thread(target=self._actor_loop)

src/p/y/pykka-HEAD/tests/ref_test.py   pykka(Download)
from pykka import ActorDeadError, Timeout
from pykka.actor import ThreadingActor
from pykka.future import ThreadingFuture
 
 

src/p/y/pykka-HEAD/tests/namespace_test.py   pykka(Download)
    def test_threading_future_import(self):
        from pykka import ThreadingFuture as ThreadingFuture1
        from pykka.future import ThreadingFuture as ThreadingFuture2
        self.assertEqual(ThreadingFuture1, ThreadingFuture2)
 

src/p/y/pykka-HEAD/tests/future_test.py   pykka(Download)
 
from pykka import Timeout
from pykka.future import Future, ThreadingFuture, get_all
 
 

src/p/y/Pykka-1.2.0/tests/ref_test.py   Pykka(Download)
from pykka import ActorDeadError, Timeout
from pykka.actor import ThreadingActor
from pykka.future import ThreadingFuture
 
 

  1 | 2  Next