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

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)