threading.BoundedSemaphore

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

No Document.

Show Implementation

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

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/i/r/ironruby-HEAD/External.LCA_RESTRICTED/Languages/IronPython/27/Lib/multiprocessing/dummy/__init__.py ironruby(Download)

 
from multiprocessing import TimeoutError, cpu_count
from multiprocessing.dummy.connection import Pipe
from threading import Lock, RLock, Semaphore, BoundedSemaphore
from threading import Event
from Queue import Queue

src/i/r/ironruby-HEAD/External.LCA_RESTRICTED/Languages/CPython/27/Lib/multiprocessing/dummy/__init__.py ironruby(Download)

 
from multiprocessing import TimeoutError, cpu_count
from multiprocessing.dummy.connection import Pipe
from threading import Lock, RLock, Semaphore, BoundedSemaphore
from threading import Event
from Queue import Queue

src/p/y/pypy3-HEAD/lib-python/3.1.2/multiprocessing/dummy/__init__.py pypy3(Download)

 
from multiprocessing import TimeoutError, cpu_count
from multiprocessing.dummy.connection import Pipe
from threading import Lock, RLock, Semaphore, BoundedSemaphore
from threading import Event
from queue import Queue

1 | 2 | 3 Next