🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 21:23:51 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
internal
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/internal
🔄 Refresh
✏️
Editing: concurrency.py
Read Only
from threading import RLock, Thread from typing import Any, Callable, TypeVar from typing_extensions import ParamSpec from reactivex.typing import StartableTarget _T = TypeVar("_T") _P = ParamSpec("_P") def default_thread_factory(target: StartableTarget) -> Thread: return Thread(target=target, daemon=True) def synchronized(lock: RLock) -> Callable[[Callable[_P, _T]], Callable[_P, _T]]: """A decorator for synchronizing access to a given function.""" def wrapper(fn: Callable[_P, _T]) -> Callable[_P, _T]: def inner(*args: _P.args, **kw: _P.kwargs) -> Any: with lock: return fn(*args, **kw) return inner return wrapper
💾 Save Changes
❌ Cancel