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

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

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/GlobalActionsModel.py   PyRQ(Download)
        qType = None
        if index==0:
            qType = RRQType.LOCKED_LIST
        elif index==1:
            qType = RRQType.MULTIPROCESSING_QUEUE
        elif index==2:
            qType = NoChoice()
        elif index==3:
            qType = random.choice([RRQType.LOCKED_LIST, RRQType.MULTIPROCESSING_QUEUE])
            qType = random.choice([RRQType.LOCKED_LIST, RRQType.MULTIPROCESSING_QUEUE])
        else:
            qType = RandomChoice([RRQType.LOCKED_LIST, RRQType.MULTIPROCESSING_QUEUE])
        params["queueType"] = qType
        params["queueCount"] = int(self.spinBox_CreateCount.value())

src/p/y/PyRQ-0.4.1/PyRQ/Ui/qt4/RRQDebugger/QueueActionDialog.py   PyRQ(Download)
        iface = self.parent.getIface()
        typeMap = {
                   0:RRQType.LOCKED_LIST,
                   1:RRQType.MULTIPROCESSING_QUEUE,
                   2:None,
            queueType = typeMap[self.comboBox_CreateQueueType.currentIndex()]
            if queueType==-1:
                queueType = ran.sample([RRQType.LOCKED_LIST, RRQType.MULTIPROCESSING_QUEUE], 1)[0]
            ns.append(iface.create(maxsize=maxSize, timeout=timeout, queueType=queueType))
        result = ", ".join(ns)

src/p/y/PyRQ-0.4.1/PyRQ/RRQ/RQueue/RQueueWrapper.py   PyRQ(Download)
    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)

src/p/y/PyRQ-0.4.1/PyRQ/Core/Messages/CREATE.py   PyRQ(Download)
    def __init__(self, maxsize=0, queueType=None, pollInterval=None):
        self.maxsize = maxsize
        if queueType==None:
            queueType = RRQType.LOCKED_LIST
        self.queueType = queueType

src/p/y/PyRQ-0.4.1/PyRQ/Iface/PyRQIface.py   PyRQ(Download)
    NOT_CONNECTED = "NOT_CONNECTED"
    MINIMUM_SOCKET_LATENCY = 3
    DEFAULT_QUEUETYPE = RRQType.LOCKED_LIST
    def __init__(self,
                 namespace=None,

src/p/y/PyRQ-0.4.1/Mock/mock.py   PyRQ(Download)
    def __init__(self, queueType, getLogger, namespace, maxsize=0, pollInterval=None, quiet=True):
        self.namespace = namespace
        self.maxsize = maxsize
        if queueType==RRQType.LOCKED_LIST:
            q = MockQueue(namespace, getLogger, maxsize=maxsize, pollInterval=pollInterval, quiet=quiet)