• 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/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/process/plugins.py   skink(Download)
        if threading.activeCount() != 1:
            self.bus.log('There are %r active threads. '
                         'Daemonizing now may cause strange failures.' %
                         threading.enumerate(), level=30)
 
        # See http://www.erlenstar.demon.co.uk/unix/faq_2.html#SEC16
        # (or http://www.faqs.org/faqs/unix-faq/programmer/faq/ section 1.7)

src/f/o/Forban-HEAD/lib/ext/cherrypy/process/plugins.py   Forban(Download)
        if threading.activeCount() != 1:
            self.bus.log('There are %r active threads. '
                         'Daemonizing now may cause strange failures.' %
                         threading.enumerate(), level=30)
 
        # See http://www.erlenstar.demon.co.uk/unix/faq_2.html#SEC16
        # (or http://www.faqs.org/faqs/unix-faq/programmer/faq/ section 1.7)

src/o/r/orcatorrent-HEAD/Player/BaseApp.py   orcatorrent(Download)
import time
from sets import Set
 
from threading import enumerate,currentThread,RLock
from traceback import print_exc
 
if sys.platform == "darwin":
            self.tbicon.RemoveIcon()
            self.tbicon.Destroy()
 
        ts = enumerate()
        for t in ts:
            print >>sys.stderr,"main: ONEXIT: Thread still running",t.getName(),"daemon",t.isDaemon()
 

src/w/e/wecowi-HEAD/trunk/tools/pywecowi/imagecopy.py   wecowi(Download)
                imageTransfer(imagepage, newname).start()
 
    wikipedia.output(u'Still ' + str(threading.activeCount()) + u' active threads, lets wait')
    for openthread in threading.enumerate():
        if openthread != threading.currentThread():
            openthread.join()
    wikipedia.output(u'All threads are done')

src/v/o/votv-HEAD/trunk/portable/dl_daemon/command.py   votv(Download)
    def action(self):
        starttime = time.time()
        from dl_daemon import download
        download.shutDown()
        import threading
        eventloop.threadPoolQuit()
        for thread in threading.enumerate():
            if thread != threading.currentThread() and not thread.isDaemon():
                thread.join()
        endtime = starttime + DAEMONIC_THREAD_TIMEOUT
        for thread in threading.enumerate():

src/w/e/wecowi-HEAD/tools/pywecowi/imagecopy.py   wecowi(Download)
                imageTransfer(imagepage, newname).start()
 
    wikipedia.output(u'Still ' + str(threading.activeCount()) + u' active threads, lets wait')
    for openthread in threading.enumerate():
        if openthread != threading.currentThread():
            openthread.join()
    wikipedia.output(u'All threads are done')

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