refactor: rename _mix_pool_size -> _min_pool_size

This commit is contained in:
Youngjoon Lee 2024-08-12 11:07:24 +09:00
parent cefe352402
commit 495b633837
No known key found for this signature in database
GPG Key ID: 167546E2D1712F8C

View File

@ -114,13 +114,13 @@ class MinSizeMixQueue(MixQueue[T]):
# Initialize the queue with noise messages
# to ensure that the queue size is at least `min_pool_size`.
self._queue = [self._noise_msg] * min_pool_size
self._mix_pool_size = min_pool_size
self._min_pool_size = min_pool_size
@abstractmethod
async def get(self) -> T:
if len(self._queue) < self._mix_pool_size:
if len(self._queue) < self._min_pool_size:
self._queue.extend(
[self._noise_msg] * (self._mix_pool_size - len(self._queue))
[self._noise_msg] * (self._min_pool_size - len(self._queue))
)
# Subclass must implement this method