Did I find the right examples for you? yes no

All Samples(15)  |  Call(15)  |  Derive(0)  |  Import(0)
Stop all running actors.

``block`` and ``timeout`` works as for
:meth:`ActorRef.stop() <pykka.ActorRef.stop>`.

If ``block`` is :class:`True`, the actors are guaranteed to be stopped
in the reverse of the order they were started in. This is helpful if
you have simple dependencies in between your actors, where it is
sufficient to shut down actors in a LIFO manner: last started, first
stopped.(more...)

src/m/o/Mopidy-0.18.3/mopidy/utils/process.py   Mopidy(Download)
            ', '.join([t.name for t in threading.enumerate()]))
        logger.debug('Stopping %d actor(s)...', num_actors)
        ActorRegistry.stop_all()
        num_actors = len(ActorRegistry.get_all())
    logger.debug('All actors stopped.')

src/m/o/mopidy-HEAD/mopidy/utils/process.py   mopidy(Download)
            ', '.join([t.name for t in threading.enumerate()]))
        logger.debug('Stopping %d actor(s)...', num_actors)
        ActorRegistry.stop_all()
        num_actors = len(ActorRegistry.get_all())
    logger.debug('All actors stopped.')

src/p/y/Pykka-1.2.0/pykka/actor.py   Pykka(Download)
                    (repr(exception_value), self))
                self._stop()
                _ActorRegistry.stop_all()
 
        while not self.actor_inbox.empty():

src/p/y/pykka-HEAD/pykka/actor.py   pykka(Download)
                    (repr(exception_value), self))
                self._stop()
                _ActorRegistry.stop_all()
 
        while not self.actor_inbox.empty():

src/x/b/xbmc-addon-watchdog-HEAD/lib/pykka/actor.py   xbmc-addon-watchdog(Download)
                    (repr(exception_value), self))
                self._stop()
                _ActorRegistry.stop_all()
 
    def on_start(self):

src/p/y/Pykka-1.2.0/tests/registry_test.py   Pykka(Download)
    def tearDown(self):
        ActorRegistry.stop_all()
 
    def test_actor_is_registered_when_started(self):
        self.assert_(self.ref in ActorRegistry.get_all())
    def test_all_actors_can_be_stopped_through_registry(self):
        self.assertEquals(9, len(ActorRegistry.get_all()))
        ActorRegistry.stop_all(block=True)
        self.assertEquals(0, len(ActorRegistry.get_all()))
 
        ActorRegistry.get_all.return_value = started_actors
 
        ActorRegistry.stop_all(block=True)
 
        self.assertEqual(stopped_actors[0], started_actors[2])

src/p/y/pykka-HEAD/tests/registry_test.py   pykka(Download)
    def tearDown(self):
        ActorRegistry.stop_all()
 
    def test_actor_is_registered_when_started(self):
        self.assert_(self.ref in ActorRegistry.get_all())
    def test_all_actors_can_be_stopped_through_registry(self):
        self.assertEquals(9, len(ActorRegistry.get_all()))
        ActorRegistry.stop_all(block=True)
        self.assertEquals(0, len(ActorRegistry.get_all()))
 
        ActorRegistry.get_all.return_value = started_actors
 
        ActorRegistry.stop_all(block=True)
 
        self.assertEqual(stopped_actors[0], started_actors[2])

src/p/y/pykka-HEAD/tests/performance.py   pykka(Download)
        time_it(test_traversible_callable_attribute_access)
    finally:
        ActorRegistry.stop_all()
 

src/p/y/pykka-HEAD/tests/logging_test.py   pykka(Download)
    def tearDown(self):
        self.log_handler.close()
        ActorRegistry.stop_all()
 
    def test_unexpected_messages_are_logged(self):

src/p/y/Pykka-1.2.0/tests/performance.py   Pykka(Download)
        time_it(test_traversible_callable_attribute_access)
    finally:
        ActorRegistry.stop_all()
 

  1 | 2  Next