equal
deleted
inserted
replaced
150 |
150 |
151 def qsize(self): |
151 def qsize(self): |
152 return None |
152 return None |
153 |
153 |
154 def get(self): |
154 def get(self): |
|
155 return self._new_cnxset() |
|
156 |
|
157 def _new_cnxset(self): |
155 return self._source.wrapped_connection() |
158 return self._source.wrapped_connection() |
156 |
159 |
157 def release(self, cnxset): |
160 def release(self, cnxset): |
158 cnxset.close(True) |
161 cnxset.close(True) |
159 |
162 |
171 super().__init__(source) |
174 super().__init__(source) |
172 self._cnxsets = [] |
175 self._cnxsets = [] |
173 self._queue = queue.Queue() |
176 self._queue = queue.Queue() |
174 |
177 |
175 for i in range(size): |
178 for i in range(size): |
176 cnxset = source.wrapped_connection() |
179 self._queue.put_nowait(self._new_cnxset()) |
177 self._cnxsets.append(cnxset) |
180 |
178 self._queue.put_nowait(cnxset) |
181 def _new_cnxset(self): |
|
182 cnxset = super()._new_cnxset() |
|
183 self._cnxsets.append(cnxset) |
|
184 return cnxset |
179 |
185 |
180 def qsize(self): |
186 def qsize(self): |
181 return self._queue.qsize() |
187 return self._queue.qsize() |
182 |
188 |
183 def get(self): |
189 def get(self): |