def enumerate():
with _active_limbo_lock:
return _active.values() + _limbo.values()
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