threading.local

All Samples(604) | Call(230) | Derive(196) | Import(178)

Thread-local data

src/n/o/notmm-0.4.1/examples/contrib/threaded_multihost/threadlocals.py notmm(Download)

log = logging.getLogger('ThreadLocalMiddleware')
 
try:
    from threading import local
except ImportError:
    log.warn('getting threadlocal support from django')
    from django.utils._threading_local import local

src/d/r/dramatis-0.1.1/lib/dramatis/runtime/scheduler.py dramatis(Download)

 
_checkio = False
 
_local = threading.local()
_local.dramatis_actor = None
 
# threading._VERBOSE = True

src/c/o/cocktail-0.3.1/cocktail/modeling.py cocktail(Download)

"""
import types
from copy import copy, deepcopy
from threading import local, Lock, RLock
from cocktail.typemapping import TypeMapping
 
_thread_data = local()

    def __init__(self):
        self.__local = local()
 
    @getter
    def _items(self):
        items = getattr(self.__local, "items", None)

src/i/r/ironruby-HEAD/External.LCA_RESTRICTED/Languages/IronPython/27/Lib/multiprocessing/util.py ironruby(Download)

class ForkAwareLocal(threading.local):
    def __init__(self):
        register_after_fork(self, lambda obj : obj.__dict__.clear())
    def __reduce__(self):
        return type(self), ()

src/i/r/ironruby-HEAD/External.LCA_RESTRICTED/Languages/CPython/27/Lib/multiprocessing/util.py ironruby(Download)

class ForkAwareLocal(threading.local):
    def __init__(self):
        register_after_fork(self, lambda obj : obj.__dict__.clear())
    def __reduce__(self):
        return type(self), ()

src/v/o/votv-HEAD/trunk/portable/readwritelock.py votv(Download)

    def __init__ (self):
        self.lock = threading.RLock()
        self.write_cond = threading.Condition(self.lock)
        self.read_cond = threading.Condition(self.lock)
        self.write_waiting = 0
        self.read_locked = 0
        self.local = threading.local()

src/g/o/google_appengine-HEAD/google/appengine/tools/bulkloader.py google_appengine(Download)

                                      self.input_generator_factory,
                                      progress_generator_factory))
 
    thread_local = threading.local()
    thread_local.shut_down = False
 
    def Interrupt(unused_signum, unused_frame):

src/v/o/votv-HEAD/portable/readwritelock.py votv(Download)

    def __init__ (self):
        self.lock = threading.RLock()
        self.write_cond = threading.Condition(self.lock)
        self.read_cond = threading.Condition(self.lock)
        self.write_waiting = 0
        self.read_locked = 0
        self.local = threading.local()

src/s/p/Spark-HEAD/src/spark/core/process.py Spark(Download)

class Process(object):
    """ A process can execute callables and communicate using messages. """
    _lock = threading.RLock()
    _processes = {}
    _nextID = 1
    _current = threading.local()

src/p/u/pushy-0.3/pushy/protocol/baseconnection.py pushy(Download)

        }
 
        # Attributes required to track responses.
        self.__thread_local      = threading.local()
        self.__response_handlers = {}
 
        # Attributes required to track number of threads processing requests.

1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 Next