threading._RLock

 
import threading2
from threading import *
from threading import _RLock,_Event,_Condition,_Semaphore,_BoundedSemaphore, \
                      _Timer,ThreadError,_time,_sleep,_get_ident,_allocate_lock
 
 

class RLock(_ContextManagerMixin,_RLock):
    """Re-implemented RLock object.
 
    This is pretty much a direct clone of the RLock object from the standard
    threading module; the only difference is that it uses a custom Lock class
    so that acquire() has a "timeout" parameter.
 

from Biskit.PVM.Status import Status
import Biskit.tools as T
 
from threading import Thread, RLock, _RLock, Condition, _Condition
import time
import copy
 

from Biskit.PVM.Status import Status
import Biskit.tools as T
 
from threading import Thread, RLock, _RLock, Condition, _Condition
import time
import copy
 

is responsible that id s are unique.
"""
 
from threading import _RLock, Lock
 
_ResourceMap = {}
_ResourceLock = Lock()

class _SharedResource(_RLock):
    # for __setattr__
    _myAttributes = { '_target' : None
      	            # _RLock instance variables
      	            , '_RLock__block' : None
      	            , '_RLock__count' : None
      	            , '_RLock__owner' : None

is responsible that id s are unique.
"""
 
from threading import _RLock, Lock
 
_ResourceMap = {}
_ResourceLock = Lock()

class _SharedResource(_RLock):
    # for __setattr__
    _myAttributes = { '_target' : None
      	            # _RLock instance variables
      	            , '_RLock__block' : None
      	            , '_RLock__count' : None
      	            , '_RLock__owner' : None

Currently, they do not support acquisition. This may change however.
'''
 
from threading import _RLock, Lock
from sys import stdout
 
_ResourceMap= {}

class _WrapResource(_RLock):
  # for __setattr__
  _myAttributes= { '_target' : None,
		   # _RLock instance variables
		   '_RLock__block' : None,
		   '_RLock__count' : None,
		   '_RLock__owner' : None,

$Id: SharedResource.py 1695 2009-02-08 08:21:58Z jens $
"""
 
from threading import _RLock, Lock
 
_ResourceMap = {}
_ResourceLock = Lock()

class _SharedResource(_RLock):
    # for __setattr__
    _myAttributes = { '_target' : None
      	            # _RLock instance variables
      	            , '_RLock__block' : None
      	            , '_RLock__count' : None
      	            , '_RLock__owner' : None

Therefore, several threads can safely call resource methods.
"""
 
from threading import _RLock, Lock
 
def get_resource(id, creator, *create_args, **create_kw):
  """return a resource for *id*.

class _WrapResource(_RLock):
  """Resource wrapper causing method calls on the resource to be synchronized.
  """
  # for __setattr__
  _myAttributes= { '_target' : None,
		   # _RLock instance variables
		   '_RLock__block' : None,

        def __init__(self, *args):
            from OpenSSL import SSL as _ssl
            self._ssl_conn = apply(_ssl.Connection, args)
            from threading import _RLock
            self._lock = _RLock()
 
        for f in ('get_context', 'pending', 'send', 'write', 'recv',