consistency in freethreading builds...

Author: mikeshardmind

src/async_utils/__init__.py

@@ -9,7 +9,7 @@
 __author__ = "Michael Hall"
 __license__ = "Apache-2.0"
 __copyright__ = "Copyright 2020-Present Michael Hall"
-__version__ = "2025.05.16b"
+__version__ = "2025.05.26b"
 
 import os
 import sys

src/async_utils/lru.py

@@ -85,7 +85,10 @@ def __getitem__(self, key: K, /) -> V:
     def __setitem__(self, key: K, value: V, /) -> None:
         self._cache[key] = value
         if len(self._cache) > self._maxsize:
-            self._cache.pop(next(iter(self._cache)))
+            try:
+                self._cache.pop(next(iter(self._cache)))
+            except (KeyError, StopIteration):
+                pass
 
     def setdefault(self, key: K, value: V, /) -> V:
         """Set a value if not already set, returning the actual value.
@@ -103,7 +106,10 @@ def setdefault(self, key: K, value: V, /) -> V:
         """
         value = self._cache.setdefault(key, value)
         if len(self._cache) > self._maxsize:
-            self._cache.pop(next(iter(self._cache)))
+            try:
+                self._cache.pop(next(iter(self._cache)))
+            except (KeyError, StopIteration):
+                pass
         return value
 
     def remove(self, key: K, /) -> None:
@@ -183,7 +189,11 @@ def _remove_some_expired(self) -> None:
         tr = max((len(self._expirations) - self._maxsize) >> self._smooth, 2)
 
         while self._expirations and tr > 0:
-            ts, k = heapq.heappop(self._expirations)
+            try:
+                ts, k = heapq.heappop(self._expirations)
+            except IndexError:
+                continue
+
             if ts < now:
                 tr -= 1
                 try:
@@ -211,7 +221,10 @@ def __setitem__(self, key: K, value: V, /) -> None:
         self._cache[key] = (ts, value)
         self._remove_some_expired()
         if len(self._cache) > self._maxsize:
-            self._cache.pop(next(iter(self._cache)))
+            try:
+                self._cache.pop(next(iter(self._cache)))
+            except (KeyError, StopIteration):
+                pass
 
     def get[T](self, key: K, default: T, /) -> V | T:
         """Get a value by key or default value.