pypy-postgresql / pypy / module / thread /

import weakref
from pypy.rlib import jit
from pypy.interpreter.baseobjspace import Wrappable, W_Root
from pypy.interpreter.executioncontext import ExecutionContext
from pypy.interpreter.typedef import (TypeDef, interp2app, GetSetProperty,
from pypy.rlib.rshrinklist import AbstractShrinkList

class WRefShrinkList(AbstractShrinkList):
    def must_keep(self, wref):
        return wref() is not None

ExecutionContext._thread_local_objs = None

class Local(Wrappable):
    """Thread-local data"""

    def __init__(self, space, initargs):
        self.initargs = initargs
        self.dicts = {}   # mapping ExecutionContexts to the wraped dict
        # The app-level __init__() will be called by the general
        # instance-creation logic.  It causes getdict() to be
        # immediately called.  If we don't prepare and set a w_dict
        # for the current thread, then this would in cause getdict()
        # to call __init__() a second time.
        ec = space.getexecutioncontext()
        w_dict = space.newdict(instance=True)
        self.dicts[ec] = w_dict

    def _register_in_ec(self, ec):
        if not
            return    # without weakrefs, works but 'dicts' is never cleared
        if ec._thread_local_objs is None:
            ec._thread_local_objs = WRefShrinkList()

    def create_new_dict(self, ec):
        # create a new dict for this thread
        space =
        w_dict = space.newdict(instance=True)
        self.dicts[ec] = w_dict
        # call __init__
            w_self = space.wrap(self)
            w_type = space.type(w_self)
            w_init = space.getattr(w_type, space.wrap("__init__"))
            space.call_obj_args(w_init, w_self, self.initargs)
            # failed, forget w_dict and propagate the exception
            del self.dicts[ec]
        # ready
        return w_dict

    def getdict(self, space):
        ec = space.getexecutioncontext()
            w_dict = self.dicts[ec]
        except KeyError:
            w_dict = self.create_new_dict(ec)
        return w_dict

    def descr_local__new__(space, w_subtype, __args__):
        local = space.allocate_instance(Local, w_subtype)
        Local.__init__(local, space, __args__)
        return space.wrap(local)

    def descr_local__init__(self, space):
        # No arguments allowed

Local.typedef = TypeDef("thread._local",
                        __doc__ = "Thread-local data",
                        __new__ = interp2app(Local.descr_local__new__.im_func),
                        __init__ = interp2app(Local.descr_local__init__),
                        __dict__ = GetSetProperty(descr_get_dict, cls=Local),

def thread_is_stopping(ec):
    tlobjs = ec._thread_local_objs
    if tlobjs is None:
    ec._thread_local_objs = None
    for wref in tlobjs.items():
        local = wref()
        if local is not None:
            del local.dicts[ec]