f1f433f
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
import threading def mutex_wrapper(lock: threading.Lock): def wrap(f): def func(*args, **kw): lock.acquire() try: return f(*args, **kw) finally: lock.release() return func return wrap
