(self)
| 381 | self._poll = self._reader.poll |
| 382 | |
| 383 | def get(self): |
| 384 | with self._rlock: |
| 385 | res = self._reader.recv_bytes() |
| 386 | # unserialize the data after having released the lock |
| 387 | return _ForkingPickler.loads(res) |
| 388 | |
| 389 | def put(self, obj): |
| 390 | # serialize the data before acquiring the lock |