threading.BoundedSemaphore

All Samples(115) | Call(90) | Derive(0) | Import(25)

No Document.

Show Implementation

        def BoundedSemaphore(*args, **kwargs):
    return _BoundedSemaphore(*args, **kwargs)

src/d/e/Decovent-1.1.1/decovent/decovent.py Decovent(Download)

 
log = logging.getLogger('decovent')
 
_active = threading.BoundedSemaphore(value=3)
_local = threading.local()
_local.events = {}
_memoize = {}

def active(value):
    """ Controls the maximum number of concurrent executions """
    global _active
    _active = threading.BoundedSemaphore(value=value)
 
 
def reset(class_=None, event=None):

src/p/h/phpsh-HEAD/src/cmd_util.py phpsh(Download)

        "\n- with fanout " + str(fanout) + " and retry " + str(retry_num) + \
        "\n- on <x> in " + str(hosts)
 
    fanout_sema = thg.BoundedSemaphore(value=fanout)
 
    class ShellCommThread(thg.Thread):
        def __init__(self, cmd, retry_num):

src/o/r/orchestralhero-HEAD/trunk/src/Resource.py orchestralhero(Download)

 
import os
from Queue import Queue, Empty
from threading import Thread, BoundedSemaphore
import time
import shutil
import stat

  def __init__(self, dataPath = os.path.join("..", "data")):
    self.resultQueue = Queue()
    self.dataPaths = [dataPath]
    self.loaderSemaphore = BoundedSemaphore(value = 1)
    self.loaders = []
 
  def addDataPath(self, path):

src/o/r/orchestralhero-HEAD/0.0.3/src/Resource.py orchestralhero(Download)

 
import os
from Queue import Queue, Empty
from threading import Thread, BoundedSemaphore
import time
import shutil
import stat

  def __init__(self, dataPath = os.path.join("..", "data")):
    self.resultQueue = Queue()
    self.dataPaths = [dataPath]
    self.loaderSemaphore = BoundedSemaphore(value = 1)
    self.loaders = []
 
  def addDataPath(self, path):

src/o/r/orchestralhero-HEAD/0.0.2/src/Resource.py orchestralhero(Download)

 
import os
from Queue import Queue, Empty
from threading import Thread, BoundedSemaphore
import time
import shutil
import stat

  def __init__(self, dataPath = os.path.join("..", "data")):
    self.resultQueue = Queue()
    self.dataPaths = [dataPath]
    self.loaderSemaphore = BoundedSemaphore(value = 1)
    self.loaders = []
 
  def addDataPath(self, path):

src/o/r/orchestralhero-HEAD/0.0.1/src/Resource.py orchestralhero(Download)

 
import os
from Queue import Queue, Empty
from threading import Thread, BoundedSemaphore
import time
import shutil
import stat

  def __init__(self, dataPath = os.path.join("..", "data")):
    self.resultQueue = Queue()
    self.dataPaths = [dataPath]
    self.loaderSemaphore = BoundedSemaphore(value = 1)
    self.loaders = []
 
  def addDataPath(self, path):

src/o/r/orchestralhero-HEAD/src/Resource.py orchestralhero(Download)

 
import os
from Queue import Queue, Empty
from threading import Thread, BoundedSemaphore
import time
import shutil
import stat

  def __init__(self, dataPath = os.path.join("..", "data")):
    self.resultQueue = Queue()
    self.dataPaths = [dataPath]
    self.loaderSemaphore = BoundedSemaphore(value = 1)
    self.loaders = []
 
  def addDataPath(self, path):

src/f/r/fretsonfire-HEAD/trunk/src/Resource.py fretsonfire(Download)

 
import os
from Queue import Queue, Empty
from threading import Thread, BoundedSemaphore
import time
import shutil
import stat

  def __init__(self, dataPath = os.path.join("..", "data")):
    self.resultQueue = Queue()
    self.dataPaths = [dataPath]
    self.loaderSemaphore = BoundedSemaphore(value = 1)
    self.loaders = []
 
  def addDataPath(self, path):

src/f/r/fretsonfire-HEAD/src/Resource.py fretsonfire(Download)

 
import os
from Queue import Queue, Empty
from threading import Thread, BoundedSemaphore
import time
import shutil
import stat

  def __init__(self, dataPath = os.path.join("..", "data")):
    self.resultQueue = Queue()
    self.dataPaths = [dataPath]
    self.loaderSemaphore = BoundedSemaphore(value = 1)
    self.loaders = []
 
  def addDataPath(self, path):

src/m/i/minibook-HEAD/minibook.py minibook(Download)

        self.friendsprofilepic = {}
        self._profilepics = {}
        # Semaphore to let only one status update proceed at a time
        self.update_sema = threading.BoundedSemaphore(value=1)
 
        # create a new window
        self.window = gtk.Window(gtk.WINDOW_TOPLEVEL)

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