

def __init__(self, channel, klass, greenlet_maker, size=1):
    self._channel = channel
    self._pool = gevent.queue.Queue()
    self._klass = klass
    self._gm = greenlet_maker
    for i in range(size):
        self._create()

dataset/ETHPy150Open seatgeek/cronq/cronq/runner.py ConsumerPool.__init__/original