(self, maxsize=0)
| 43 | """ |
| 44 | |
| 45 | def __init__(self, maxsize=0): |
| 46 | self._maxsize = maxsize |
| 47 | |
| 48 | # Futures. |
| 49 | self._getters = collections.deque() |
| 50 | # Futures. |
| 51 | self._putters = collections.deque() |
| 52 | self._unfinished_tasks = 0 |
| 53 | self._finished = locks.Event() |
| 54 | self._finished.set() |
| 55 | self._init(maxsize) |
| 56 | self._is_shutdown = False |
| 57 | |
| 58 | # These three are overridable in subclasses. |
| 59 |