Did I find the right examples for you? yes no      Crawl my project      Python Jobs

PyRQ.RRQ.RQueue.RQueueImpl.RQueueImpl

All Samples(2)  |  Call(1)  |  Derive(0)  |  Import(1)


src/p/y/PyRQ-0.4.1/PyRQ/RRQ/RQueue/RQueueWrapper.py   PyRQ(Download)
'''
 
from PyRQ.RRQ.RQueue.RQueueImpl import RQueueImpl
from PyRQ.RRQ.RRQType import RRQType
 

    def __init__(self, queueType, getLogger, namespace, maxsize=0, pollInterval=None, quiet=True):
        self.namespace = namespace
        self.maxsize = maxsize
        if queueType==RRQType.LOCKED_LIST:
            q = RQueueImpl(namespace, getLogger, maxsize=maxsize, pollInterval=pollInterval, quiet=quiet)