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

Class ThreadSafeStore

dask/array/tests/test_array_core.py:2314–2323  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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

Callers 1

test_store_locksFunction · 0.85

Calls

no outgoing calls

Tested by 1

test_store_locksFunction · 0.68