Kaydet (Commit) a28c55a2 authored tarafından Raymond Hettinger's avatar Raymond Hettinger

merge

...@@ -20,7 +20,7 @@ try: ...@@ -20,7 +20,7 @@ try:
from _thread import RLock from _thread import RLock
except: except:
class RLock: class RLock:
'Dummy reentrant lock' 'Dummy reentrant lock for builds without threads'
def __enter__(self): pass def __enter__(self): pass
def __exit__(self, exctype, excinst, exctb): pass def __exit__(self, exctype, excinst, exctb): pass
...@@ -172,6 +172,12 @@ except ImportError: ...@@ -172,6 +172,12 @@ except ImportError:
_CacheInfo = namedtuple("CacheInfo", ["hits", "misses", "maxsize", "currsize"]) _CacheInfo = namedtuple("CacheInfo", ["hits", "misses", "maxsize", "currsize"])
class _HashedSeq(list): class _HashedSeq(list):
""" This class guarantees that hash() will be called no more than once
per element. This is important because the lru_cache() will hash
the key multiple times on a cache miss.
"""
__slots__ = 'hashvalue' __slots__ = 'hashvalue'
def __init__(self, tup, hash=hash): def __init__(self, tup, hash=hash):
...@@ -185,7 +191,16 @@ def _make_key(args, kwds, typed, ...@@ -185,7 +191,16 @@ def _make_key(args, kwds, typed,
kwd_mark = (object(),), kwd_mark = (object(),),
fasttypes = {int, str, frozenset, type(None)}, fasttypes = {int, str, frozenset, type(None)},
sorted=sorted, tuple=tuple, type=type, len=len): sorted=sorted, tuple=tuple, type=type, len=len):
'Make a cache key from optionally typed positional and keyword arguments' """Make a cache key from optionally typed positional and keyword arguments
The key is constructed in a way that is flat as possible rather than
as a nested structure that would take more memory.
If there is only a single argument and its data type is known to cache
its hash value, then that argument is returned without a wrapper. This
saves space and improves lookup speed.
"""
key = args key = args
if kwds: if kwds:
sorted_items = sorted(kwds.items()) sorted_items = sorted(kwds.items())
...@@ -242,7 +257,7 @@ def lru_cache(maxsize=128, typed=False): ...@@ -242,7 +257,7 @@ def lru_cache(maxsize=128, typed=False):
if maxsize == 0: if maxsize == 0:
def wrapper(*args, **kwds): def wrapper(*args, **kwds):
# no caching, just a statistics update after a successful call # No caching -- just a statistics update after a successful call
nonlocal misses nonlocal misses
result = user_function(*args, **kwds) result = user_function(*args, **kwds)
misses += 1 misses += 1
...@@ -272,8 +287,8 @@ def lru_cache(maxsize=128, typed=False): ...@@ -272,8 +287,8 @@ def lru_cache(maxsize=128, typed=False):
with lock: with lock:
link = cache_get(key) link = cache_get(key)
if link is not None: if link is not None:
# move the link to the front of the circular queue # Move the link to the front of the circular queue
link_prev, link_next, key, result = link link_prev, link_next, _key, result = link
link_prev[NEXT] = link_next link_prev[NEXT] = link_next
link_next[PREV] = link_prev link_next[PREV] = link_prev
last = root[PREV] last = root[PREV]
...@@ -285,26 +300,34 @@ def lru_cache(maxsize=128, typed=False): ...@@ -285,26 +300,34 @@ def lru_cache(maxsize=128, typed=False):
result = user_function(*args, **kwds) result = user_function(*args, **kwds)
with lock: with lock:
if key in cache: if key in cache:
# getting here means that this same key was added to the # Getting here means that this same key was added to the
# cache while the lock was released. since the link # cache while the lock was released. Since the link
# update is already done, we need only return the # update is already done, we need only return the
# computed result and update the count of misses. # computed result and update the count of misses.
pass pass
elif full: elif full:
# use the old root to store the new key and result # Use the old root to store the new key and result.
oldroot = root oldroot = root
oldroot[KEY] = key oldroot[KEY] = key
oldroot[RESULT] = result oldroot[RESULT] = result
# empty the oldest link and make it the new root # Empty the oldest link and make it the new root.
# Keep a reference to the old key and old result to
# prevent their ref counts from going to zero during the
# update. That will prevent potentially arbitrary object
# clean-up code (i.e. __del__) from running while we're
# still adjusting the links.
root = oldroot[NEXT] root = oldroot[NEXT]
oldkey = root[KEY] oldkey = root[KEY]
oldvalue = root[RESULT] oldresult = root[RESULT]
root[KEY] = root[RESULT] = None root[KEY] = root[RESULT] = None
# now update the cache dictionary for the new links # Now update the cache dictionary.
del cache[oldkey] del cache[oldkey]
# Save the potentially reentrant cache[key] assignment
# for last, after the root and links have been put in
# a consistent state.
cache[key] = oldroot cache[key] = oldroot
else: else:
# put result in a new link at the front of the queue # Put result in a new link at the front of the queue.
last = root[PREV] last = root[PREV]
link = [last, root, key, result] link = [last, root, key, result]
last[NEXT] = root[PREV] = cache[key] = link last[NEXT] = root[PREV] = cache[key] = link
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment