chore: try to use a normal RLock arround aquiring an async lock part 2

Author: d-biehl

robotcode/language_server/common/text_document.py

@@ -164,15 +164,13 @@ def _invalidate_cache(self) -> None:
         self._cache.clear()
         create_sub_task(self.cache_invalidated(self))
 
-    @_logger.call
     def invalidate_cache(self) -> None:
         with self._lock:
             self._invalidate_cache()
 
     def _invalidate_data(self) -> None:
         self._data.clear()
 
-    @_logger.call
     def invalidate_data(self) -> None:
         with self._lock:
             self._invalidate_data()
@@ -234,7 +232,6 @@ async def get_cache(
 
             return cast(_T, e.data)
 
-    @_logger.call
     async def remove_cache_entry(
         self, entry: Union[Callable[[TextDocument], Awaitable[_T]], Callable[..., Awaitable[_T]]]
     ) -> None:

robotcode/utils/async_tools.py

@@ -471,8 +471,8 @@ def aaa(fut: asyncio.Future[Any]) -> None:
                     finally:
                         h.cancel()
                 finally:
-                    with self._lock:
-                        self._waiters.remove(fut)
+                    # with self._lock:
+                    self._waiters.remove(fut)
             except asyncio.CancelledError:
                 # with self._lock:
                 if not self._locked:
@@ -493,18 +493,18 @@ def release(self) -> None:
                 self._locker = None
                 wake_up = True
 
-        if wake_up:
-            self._wake_up_first()
+            if wake_up:
+                self._wake_up_first()
 
     def _wake_up_first(self) -> None:
         if not self._waiters:
             return
 
-        with self._lock:
-            try:
-                fut = next(iter(self._waiters))
-            except StopIteration:
-                return
+        # with self._lock:
+        try:
+            fut = next(iter(self._waiters))
+        except StopIteration:
+            return
 
         if fut.get_loop().is_running() and not fut.get_loop().is_closed():
             if fut.get_loop() == asyncio.get_running_loop():