• Facebook
  • Twitter
  • Reddit
  • StumbleUpon
  • Digg
  • email

All Samples(256)  |  Call(207)  |  Derive(0)  |  Import(49)
No Document.

        def enumerate():
    with _active_limbo_lock:
        return _active.values() + _limbo.values()
        


src/o/r/orcatorrent-HEAD/Core/APIImplementation/LaunchManyCore.py   orcatorrent(Download)
import binascii
import shutil
from UserDict import DictMixin
from threading import RLock,Condition,Event,Thread,currentThread,enumerate
from traceback import print_exc,print_stack
from types import StringType
 
            if diff < gracetime:
                print >>sys.stderr,"tlm: shutdown: sleeping for early shutdown tasks",gracetime-diff
                sleep(gracetime-diff) 
                ts = enumerate()
                print >>sys.stderr,"tlm: Number of threads still running",len(ts)
                for t in ts:
                    print >>sys.stderr,"tlm: Thread still running",t.getName(),"daemon",t.isDaemon()

src/g/e/genropy-HEAD/gnrpy/gnr/sql/ThreadingLocal.py   genropy(Download)
    from threading import current_thread
except ImportError: # Python >2.5
    from threading import currentThread as current_thread
from threading import RLock, enumerate
 
 
class _localbase(object):
	def __del__(self):
		try:
			key = object.__getattribute__(self, '_local__key')
			threads = list(enumerate())
		except:
			return
		for thread in threads:

src/o/r/orcatorrent-HEAD/Main/vwxGUI/MainFrame.py   orcatorrent(Download)
from wx import xrc
#import hotshot
 
from threading import Thread, Event,currentThread,enumerate
import time
from traceback import print_exc, print_stack
from cStringIO import StringIO
            print >>sys.stderr,"mainframe: OnCloseWindow END"
 
        if DEBUG:
            ts = enumerate()
            for t in ts:
                print >>sys.stderr,"mainframe: Thread still running",t.getName(),"daemon",t.isDaemon()
 

src/o/r/orcatorrent-HEAD/Main/tribler.py   orcatorrent(Download)
from wx import xrc
#import hotshot
 
from threading import Thread, Event,currentThread,enumerate
from time import time, ctime, sleep
from traceback import print_exc, print_stack
from cStringIO import StringIO

src/d/b/DBUtils-1.0/DBUtils/ThreadingLocal.py   DBUtils(Download)
    from threading import current_thread
except ImportError: # Python >2.5
    from threading import currentThread as current_thread
from threading import RLock, enumerate
 
 
class _localbase(object):
	def __del__(self):
		try:
			key = object.__getattribute__(self, '_local__key')
			threads = list(enumerate())
		except:
			return
		for thread in threads:

src/s/k/skink-HEAD/skink/lib/cherrypy/_cpthreadinglocal.py   skink(Download)
        return __del__
    __del__ = __del__()
 
from threading import currentThread, enumerate, RLock
 

src/g/o/google-app-engine-HEAD/lib/django/django/utils/_threading_local.py   google-app-engine(Download)
    __del__ = __del__()
 
try:
    from threading import currentThread, enumerate, RLock
except ImportError:
    from dummy_threading import currentThread, enumerate, RLock
 

src/r/e/reporter-lib-HEAD/packages/Django/django/utils/_threading_local.py   reporter-lib(Download)
    __del__ = __del__()
 
try:
    from threading import currentThread, enumerate, RLock
except ImportError:
    from dummy_threading import currentThread, enumerate, RLock
 

src/g/o/google_appengine-HEAD/lib/django/django/utils/_threading_local.py   google_appengine(Download)
    __del__ = __del__()
 
try:
    from threading import currentThread, enumerate, RLock
except ImportError:
    from dummy_threading import currentThread, enumerate, RLock
 

src/f/o/Forban-HEAD/lib/ext/cherrypy/_cpthreadinglocal.py   Forban(Download)
        return __del__
    __del__ = __del__()
 
from threading import currentThread, enumerate, RLock
 

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