(self, obj)
| 21 | if self._rlock: self._rlock.release() |
| 22 | return ret |
| 23 | def put(self, obj): |
| 24 | if self._wlock: self._wlock.acquire() |
| 25 | self._writer.send_bytes(pickle.dumps(obj)) |
| 26 | if self._wlock: self._wlock.release() |
| 27 | |
| 28 | def shuffled_indices(n, seed=None): |
| 29 | rng = random.Random(seed) |