Did I find the right examples for you? yes no

All Samples(58)  |  Call(48)  |  Derive(0)  |  Import(10)
A queue used to organize communication messaging between Wishbone Actors.

Parameters:

    - max_size (int):   The max number of elements in the queue.  0 is unlimited
                        Default: 0

src/w/i/wishbone-0.4.10/wishbone/tools/queuefunctions.py   wishbone(Download)
#
 
from wishbone.tools import WishboneQueue
 
class QueueFunctions():
    def createQueue(self, name, max_size=0):
        '''Creates a queue in <self.queuepool> named <name> with a size of <max_size>'''
 
        try:
            setattr(self.queuepool, name, WishboneQueue(max_size))

src/w/i/wishbone-HEAD/wishbone/tools/queuefunctions.py   wishbone(Download)
#
 
from wishbone.tools import WishboneQueue
 
class QueueFunctions():
    def createQueue(self, name, max_size=0):
        '''Creates a queue in <self.queuepool> named <name> with a size of <max_size>'''
 
        try:
            setattr(self.queuepool, name, WishboneQueue(max_size))

src/w/i/wishbone-0.4.10/wishbone/router/default.py   wishbone(Download)
 
from wishbone.tools import QLogging
from wishbone.tools import WishboneQueue
from wishbone.tools import LoopContextSwitcher
from wishbone.errors import QueueMissing, QueueOccupied, SetupError, QueueFull, QueueLocked
        signal(2, self.__signal_handler)
        self.logging=QLogging("Router")
        self.logs=WishboneQueue()
        self.metrics=WishboneQueue()
 

src/w/i/wishbone-HEAD/wishbone/router/default.py   wishbone(Download)
 
from wishbone.tools import QLogging
from wishbone.tools import WishboneQueue
from wishbone.tools import LoopContextSwitcher
from wishbone.errors import QueueMissing, QueueOccupied, SetupError, QueueFull, QueueLocked
        signal(2, self.__signal_handler)
        self.logging=QLogging("Router")
        self.logs=WishboneQueue()
        self.metrics=WishboneQueue()
 

src/w/i/wishbone-0.4.10/wishbone/tools/qlogging.py   wishbone(Download)
 
 
from wishbone.tools import WishboneQueue
from time import time
from os import getpid
    def __init__(self, name):
        self.logs=WishboneQueue()
        self.name=name
        self.pid=getpid()
 

src/w/i/wishbone-HEAD/wishbone/tools/qlogging.py   wishbone(Download)
 
 
from wishbone.tools import WishboneQueue
from time import time
from os import getpid
    def __init__(self, name):
        self.logs=WishboneQueue()
        self.name=name
        self.pid=getpid()
 

src/w/i/wishbone-0.4.10/wishbone/test/testwishbonequeue.py   wishbone(Download)
 
try:
    from wishbone.tools import WishboneQueue
    from wishbone.errors import QueueFull, QueueEmpty, QueueEmpty, QueueLocked
except:
    def test_import(self):
        try:
            from wishbone.tools import WishboneQueue
        except:
            assert WishboneQueue
 
    def test_init_max_size(self):
        queue = WishboneQueue(max_size=1)
    def test_clear(self):
        queue = WishboneQueue()
        queue.put("test")
        assert queue.size() == 1
 
    def test_dump(self):
        queue = WishboneQueue()

src/w/i/wishbone-HEAD/wishbone/test/testwishbonequeue.py   wishbone(Download)
 
try:
    from wishbone.tools import WishboneQueue
    from wishbone.errors import QueueFull, QueueEmpty, QueueEmpty, QueueLocked
except:
    def test_import(self):
        try:
            from wishbone.tools import WishboneQueue
        except:
            assert WishboneQueue
 
    def test_init_max_size(self):
        queue = WishboneQueue(max_size=1)
    def test_clear(self):
        queue = WishboneQueue()
        queue.put("test")
        assert queue.size() == 1
 
    def test_dump(self):
        queue = WishboneQueue()