equal
deleted
inserted
replaced
141 |
141 |
142 def stop(self): |
142 def stop(self): |
143 pass |
143 pass |
144 |
144 |
145 |
145 |
146 class _CnxSetPool(object): |
146 class _CnxSetPool: |
147 |
147 |
148 def __init__(self, source, size): |
148 def __init__(self, source, size): |
149 self._cnxsets = [] |
149 self._cnxsets = [] |
150 if size is not None: |
150 if size is not None: |
151 self._queue = queue.Queue() |
151 self._queue = queue.Queue() |
154 self._cnxsets.append(cnxset) |
154 self._cnxsets.append(cnxset) |
155 self._queue.put_nowait(cnxset) |
155 self._queue.put_nowait(cnxset) |
156 else: |
156 else: |
157 self._queue = None |
157 self._queue = None |
158 self._source = source |
158 self._source = source |
159 super(_CnxSetPool, self).__init__() |
|
160 |
159 |
161 def qsize(self): |
160 def qsize(self): |
162 if self._queue is None: |
161 if self._queue is None: |
163 return None |
162 return None |
164 return self._queue.qsize() |
163 return self._queue.qsize() |