(self)
| 663 | self._instances_created = False |
| 664 | |
| 665 | def _get_fory(self): |
| 666 | with self._lock: |
| 667 | if self._pool: |
| 668 | return self._pool.pop() |
| 669 | self._instances_created = True |
| 670 | if self._fory_factory is not None: |
| 671 | fory = self._fory_factory() |
| 672 | else: |
| 673 | fory = self._fory_class(**self._config) |
| 674 | for callback in self._callbacks: |
| 675 | callback(fory) |
| 676 | return fory |
| 677 | |
| 678 | def _return_fory(self, fory): |
| 679 | with self._lock: |
no test coverage detected