(self)
| 16 | self._rlock = Lock() if multiple_readers else None |
| 17 | self._wlock = Lock() if multiple_writers else None |
| 18 | def get(self): |
| 19 | if self._rlock: self._rlock.acquire() |
| 20 | ret = pickle.loads(self._reader.recv_bytes()) |
| 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)) |