threading.activeCount

All Samples(174) | Call(169) | Derive(0) | Import(5)

No Document.

Show Implementation

        def activeCount():
    with _active_limbo_lock:
        return len(_active) + len(_limbo)

src/m/i/milkcrate-HEAD/MoinMoin/server/standalone.py milkcrate(Download)

    def process_request(self, request, client_address):
        """ Start a new thread to process the request
 
        If the thread limit has been reached, wait on the lock. The
        next thread will notify when finished.
        """
        from threading import Thread, activeCount
        self.lock.acquire()
        try:
            if activeCount() > self.thread_limit:

src/y/o/Yotsuba-HEAD/yotsuba3-python/yotsuba3/core/mt.py Yotsuba(Download)

 
import sys
from Queue import Queue
from threading import Thread, activeCount
 
PACKAGE_VERSION = 1.0

src/p/y/pyvm-HEAD/projects/python_in_a_can/trunk/win32/mercurial-1.6.4/lib/mercurial/hgweb/server.py pyvm(Download)

            pass
 
try:
    from threading import activeCount
    _mixin = SocketServer.ThreadingMixIn
except ImportError:
    if hasattr(os, "fork"):

src/m/i/milkcrate-HEAD/MoinMoin/wikimacro.py milkcrate(Download)

 
        t_count = None
        try:
            from threading import activeCount
            t_count = activeCount()
        except ImportError:
            pass

src/p/y/pyClanSphere-HEAD/pyClanSphere/views/admin.py pyClanSphere(Download)

    """
    from platform import platform
    from sys import version as python_version
    from threading import activeCount
    from jinja2.defaults import DEFAULT_NAMESPACE, DEFAULT_FILTERS
    from pyClanSphere import environment, __version__ as pyClanSphere_version

        hosting_env={
            'persistent':       not request.is_run_once,
            'multithreaded':    request.is_multithread,
            'thread_count':     activeCount(),
            'multiprocess':     request.is_multiprocess,
            'wsgi_version':     '.'.join(map(str, request.environ['wsgi.version']))
        },