threading.RLock

All Samples(1495) | Call(1151) | Derive(0) | Import(344)

No Document.

Show Implementation

        def RLock(*args, **kwargs):
    return _RLock(*args, **kwargs)

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 threading.Lock\n'
    test_lockspeed(threading.Lock())
    print '\n\t######## testing threading.RLock\n'
    test_lockspeed(threading.RLock())
    print '\n\t######## testing processing.Lock\n'
    test_lockspeed(processing.Lock())
    print '\n\t######## testing processing.RLock\n'

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/b/r/braintree_python_examples-HEAD/tr_checkout_app_engine/web/wsgiserver/__init__.py braintree_python_examples(Download)

    def __init__(self, *args):
        self._ssl_conn = SSL.Connection(*args)
        self._lock = threading.RLock()
 
    for f in ('get_context', 'pending', 'send', 'write', 'recv', 'read',
              'renegotiate', 'bind', 'listen', 'connect', 'accept',
              'setblocking', 'fileno', 'shutdown', 'close', 'get_cipher_list',

src/w/u/wu-ros-pkg-HEAD/stacks/wu_utils/trunk/pymp/examples/simple_test.py wu-ros-pkg(Download)

    def __init__(self):
        self.count = 0
        self.lock = threading.RLock()
 
    @trace_function
    def test(self):
        with self.lock:

src/w/u/wu-ros-pkg-HEAD/externals/wu-ros-pkg/wu_utils/pymp/examples/simple_test.py wu-ros-pkg(Download)

    def __init__(self):
        self.count = 0
        self.lock = threading.RLock()
 
    @trace_function
    def test(self):
        with self.lock:

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

global forks
forks = []
for i in range(0,N):
    forks.append(threading.RLock())
 
global state
state = []

src/p/y/pymp-HEAD/examples/simple_test.py pymp(Download)

    def __init__(self):
        self.count = 0
        self.lock = threading.RLock()
 
    @trace_function
    def test(self):
        with self.lock:

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