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

Class ThreadSafeStore

dask/array/tests/test_array_core.py:2312–2321  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2310
2311
2312class ThreadSafeStore:
2313 def __init__(self):
2314 self.concurrent_uses = 0
2315 self.max_concurrent_uses = 0
2316
2317 def __setitem__(self, key, value):
2318 self.concurrent_uses += 1
2319 self.max_concurrent_uses = max(self.concurrent_uses, self.max_concurrent_uses)
2320 time.sleep(0.01)
2321 self.concurrent_uses -= 1
2322
2323
2324class BrokenStore:

Callers 1

test_store_locksFunction · 0.85

Calls

no outgoing calls

Tested by 1

test_store_locksFunction · 0.68