MCPcopy Create free account
hub / github.com/dask/dask / CounterLock

Class CounterLock

dask/array/tests/test_array_core.py:2329–2342  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2327
2328
2329class CounterLock:
2330 def __init__(self, *args, **kwargs):
2331 self.lock = Lock(*args, **kwargs)
2332
2333 self.acquire_count = 0
2334 self.release_count = 0
2335
2336 def acquire(self, *args, **kwargs):
2337 self.acquire_count += 1
2338 return self.lock.acquire(*args, **kwargs)
2339
2340 def release(self, *args, **kwargs):
2341 self.release_count += 1
2342 return self.lock.release(*args, **kwargs)
2343
2344
2345def test_store_locks_failure_lock_released():

Callers 3

test_store_locksFunction · 0.85

Calls

no outgoing calls

Tested by 3

test_store_locksFunction · 0.68