Add gists.

Author: tkem

MANIFEST.in

@@ -7,5 +7,6 @@ exclude .readthedocs.yaml
 
 recursive-include docs *
 prune docs/_build
+prune gists
 
 recursive-include tests *.py

gists/stampede-cached.py

@@ -0,0 +1,39 @@
+import threading
+from time import sleep
+
+import cachetools
+
+NUM_THREADS = 1000
+CACHE_TTL_SECONDS = 3600  # one hour
+INFO = True
+
+
+@cachetools.cached(
+    cache=cachetools.TTLCache(maxsize=1, ttl=CACHE_TTL_SECONDS),
+    condition=threading.Condition(),
+    info=INFO,
+)
+def get_value():
+    print("get_value")
+    sleep(1)
+    return 42
+
+
+class MyThread(threading.Thread):
+    def __init__(self, id):
+        threading.Thread.__init__(self)
+        self.thread_name = str(id)
+        self.thread_ID = id
+
+    def run(self):
+        get_value()
+
+
+threads = []
+for i in range(0, NUM_THREADS):
+    t = MyThread(i)
+    threads.append(t)
+    t.start()
+for t in threads:
+    t.join()
+print(get_value.cache_info())

gists/stampede-cachedmethod.py

@@ -0,0 +1,43 @@
+# https://github.com/tkem/cachetools/issues/294
+import threading
+from time import sleep
+
+import cachetools
+
+NUM_THREADS = 1000
+CACHE_TTL_SECONDS = 3600  # one hour
+# INFO = True
+
+
+class Cached:
+
+    def __init__(self):
+        self.cache = cachetools.TTLCache(maxsize=1, ttl=CACHE_TTL_SECONDS)
+        self.cond = threading.Condition()
+
+    @cachetools.cachedmethod(lambda self: self.cache, condition=lambda self: self.cond)
+    def get_value(self):
+        print("get_value")
+        sleep(1)
+        return 42
+
+
+class MyThread(threading.Thread):
+    def __init__(self, id, cached):
+        threading.Thread.__init__(self)
+        self.thread_name = str(id)
+        self.thread_ID = id
+        self.cached = cached
+
+    def run(self):
+        self.cached.get_value()
+
+
+cached = Cached()
+threads = []
+for i in range(0, NUM_THREADS):
+    t = MyThread(i, cached)
+    threads.append(t)
+    t.start()
+for t in threads:
+    t.join()

gists/stampede.py

@@ -0,0 +1,35 @@
+# https://github.com/tkem/cachetools/issues/294
+import threading
+from time import sleep
+
+import cachetools.func
+
+NUM_THREADS = 1000
+CACHE_TTL_SECONDS = 3600  # one hour
+
+
+@cachetools.func.ttl_cache(maxsize=1, ttl=CACHE_TTL_SECONDS)
+def get_value():
+    print("get_value")
+    sleep(1)
+    return 42
+
+
+class MyThread(threading.Thread):
+    def __init__(self, id):
+        threading.Thread.__init__(self)
+        self.thread_name = str(id)
+        self.thread_ID = id
+
+    def run(self):
+        get_value()
+
+
+threads = []
+for i in range(0, NUM_THREADS):
+    t = MyThread(i)
+    threads.append(t)
+    t.start()
+for t in threads:
+    t.join()
+print(get_value.cache_info())