Did I find the right examples for you? yes no

All Samples(25)  |  Call(0)  |  Derive(6)  |  Import(19)
:class:`ThreadingActor` implements :class:`Actor` using regular Python
threads.

This implementation is slower than :class:`GeventActor
<pykka.gevent.GeventActor>`, but can be used in a process with other
threads that are not Pykka actors.

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-HEAD/tests/registry_test.py   pykka(Download)
import mock
import unittest
 
from pykka.actor import ThreadingActor
from pykka.registry import ActorRegistry

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

src/p/y/pykka-HEAD/tests/proxy_test.py   pykka(Download)
import unittest
 
from pykka import ActorDeadError
from pykka.actor import ThreadingActor
from pykka.proxy import ActorProxy

src/p/y/pykka-HEAD/tests/performance.py   pykka(Download)
import time
 
from pykka.actor import ThreadingActor
from pykka.registry import ActorRegistry
 
class AnActor(ThreadingActor):
    bar = SomeObject()
    bar.pykka_traversable = True
 
    foo = 'foo'

src/p/y/pykka-HEAD/tests/namespace_test.py   pykka(Download)
    def test_threading_actor_import(self):
        from pykka import ThreadingActor as ThreadingActor1
        from pykka.actor import ThreadingActor as ThreadingActor2
        self.assertEqual(ThreadingActor1, ThreadingActor2)
 

src/p/y/pykka-HEAD/tests/method_call_test.py   pykka(Download)
import unittest
 
from pykka.actor import ThreadingActor
 
 
    class ActorWithMethods(ActorWithMethods, ThreadingActor):
        pass
 
 
class ThreadingDynamicMethodCallTest(DynamicMethodCallTest, unittest.TestCase):
    class ActorExtendableAtRuntime(ActorExtendableAtRuntime, ThreadingActor):

src/p/y/pykka-HEAD/tests/logging_test.py   pykka(Download)
import logging
import threading
import unittest
 
from pykka.actor import ThreadingActor

  1 | 2  Next