threading.Condition

All Samples(759) | Call(684) | Derive(1) | Import(74)

No Document.

Show Implementation

        def Condition(*args, **kwargs):
    return _Condition(*args, **kwargs)

src/d/i/dionea-HEAD/dionea/trunk/sample/python/testP-C.py dionea(Download)

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

src/d/i/dionea-HEAD/dionea/trunk/sample/python/testRWLock.py dionea(Download)

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

src/d/i/dionea-HEAD/dionea/trunk/sample/python/testM-T.py dionea(Download)

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

src/b/i/biskit-HEAD/trunk/Biskit/PVM/ExampleSlave.py biskit(Download)

## empty test ##
import Biskit.test as BT
 
from threading import Thread, RLock, Condition
import time
 
class Flusher( Thread ):

src/b/i/biskit-HEAD/Biskit/PVM/ExampleSlave.py biskit(Download)

## empty test ##
import Biskit.test as BT
 
from threading import Thread, RLock, Condition
import time
 
class Flusher( Thread ):

src/p/r/processing-0.52/examples/benchmarks.py processing(Download)

 
    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'

src/t/r/track-HEAD/scaleHarness/trunk/external/grinder-3.0-beta33/examples/sync.py track(Download)

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()

src/m/a/matplotlib-HEAD/matplotlib/examples/user_interfaces/interactive.py matplotlib(Download)

    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 = []

src/m/a/matplotlib-HEAD/examples/user_interfaces/interactive.py matplotlib(Download)

    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 = []

src/m/a/Matplotlib--JJ-s-dev-HEAD/examples/user_interfaces/interactive.py Matplotlib--JJ-s-dev(Download)

    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 = []

1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 Next