threading.Condition

    def __init__(self,limits):
        self.buffer=[]
        self.limits=limits
        self.cv=threading.Condition(threading.RLock())
 
 
    def put(self,tname,cake):

    def __init__(self):
        self._read_ready = threading.Condition(threading.RLock())
        self._readers = 0
 
    def acquire_read(self):
        self._read_ready.acquire()
        try:

    def __init__(self,i):
        self.initialCount=i
        self.currentCount=i
        self.nCompleted=0
        self.cv=threading.Condition(threading.Lock())
 
    def barrierWait(self):

 
    print '\n\t######## testing Queue.Queue\n'
    test_queuespeed(threading.Thread, Queue.Queue(),
                    threading.Condition())
    print '\n\t######## testing processing.Queue\n'
    test_queuespeed(processing.Process, processing.Queue(),
                    processing.Condition())

    print
 
    print '\n\t######## testing threading.Condition\n'
    test_conditionspeed(threading.Thread, threading.Condition())
    print '\n\t######## testing processing.Condition\n'
    test_conditionspeed(processing.Process, processing.Condition())
    print '\n\t######## testing condition managed by a server process\n'

from net.grinder.script.Grinder import grinder
 
# You need to install Jython to access the threading package. See
# http://grinder.sourceforge.net/faq.html#jython-libraries
from threading import Condition
 
 
# Global lock
c = Condition()

    def __init__(self,on_kill=None,*args,**kw):
        code.InteractiveConsole.__init__(self,*args,**kw)
        self.code_to_run = None
        self.ready = threading.Condition()
        self._kill = False
        if on_kill is None:
            on_kill = []

    def __init__(self,on_kill=None,*args,**kw):
        code.InteractiveConsole.__init__(self,*args,**kw)
        self.code_to_run = None
        self.ready = threading.Condition()
        self._kill = False
        if on_kill is None:
            on_kill = []

    def __init__(self,on_kill=None,*args,**kw):
        code.InteractiveConsole.__init__(self,*args,**kw)
        self.code_to_run = None
        self.ready = threading.Condition()
        self._kill = False
        if on_kill is None:
            on_kill = []

from javax.naming import Context, InitialContext
from net.grinder.script.Grinder import grinder
from net.grinder.script import Test
from threading import Condition
from weblogic.jndi import WLInitialContextFactory
 
# Look up connection factory and queue in JNDI.

    def __init__(self):
        self.messageQueue = []          # Queue of received messages not yet recorded.
        self.cv = Condition()           # Used to synchronise thread activity.
 
    def __call__(self):
        log = grinder.logger.output
 

    def __init__(self, sessionHost):
        dbgp.serverBase.session.__init__(self, sessionHost)
 
        # setup some event vars
        self._resp_cv = threading.Condition()
        self._responses = {}
        self.statusName = 'stopped'