PeterHarding: New page:

 #!/usr/bin/env python  #---------------------------------------------------------------------  import time import logging  from threading import * from datetime import datetime  #---...

2008-02-15T04:43:51Z

New page: <pre> #!/usr/bin/env python #--------------------------------------------------------------------- import time import logging from threading import * from datetime import datetime #---...

New page

<pre>
#!/usr/bin/env python

#---------------------------------------------------------------------

import time
import logging

from threading import *
from datetime import datetime

#---------------------------------------------------------------------

LOGFILE = 'threads.log'

#---------------------------------------------------------------------

class my_thread(Thread):
def __init__(self, target, args=(), name=None):
# we need a tuple here
if type(args)<>type((1,)):
args = (args,)
Thread.__init__(self, target=target, name=name, args=args)
self._uptime = datetime.now()
self.start()

def getUptime(self):
return self._uptime

def __str__(self):
return self.getName()

#---------------------------------------------------------------------

def get_threads():
"Does not list main thread..."

return filter(lambda x: x.getName()<>"MainThread", enumerate())

#---------------------------------------------------------------------

def DoSome(s=""):
msg = "[DoSome] %s Now it's %s" % (s, datetime.now())
print msg
log.info(msg)

time.sleep(0.3)

for i in range(5):
msg = "[DoSome] %s %s" % (s, datetime.now())
print msg
log.info(msg)
time.sleep(0.5)

#---------------------------------------------------------------------

if __name__=="__main__":
#----- Set up logging --------------------------------------------

log = logging.getLogger('test')
hdlr = logging.FileHandler(LOGFILE)
fmtr = logging.Formatter('%(asctime)s %(levelname)s %(message)s')

hdlr.setFormatter(fmtr)
log.addHandler(hdlr)
log.setLevel(logging.INFO)

log.info("[main] ===== Started processing =====")

#-----------------------------------------------------------------

t1 = my_thread(DoSome, ("one"))
t2 = my_thread(DoSome, ("two"))

time.sleep(0.7)

for t in get_threads():
msg = "[main] %s %s" % (t, t.getUptime())
print msg
log.info(msg)
time.sleep(0.7)

#-----------------------------------------------------------------

log.info("[main] ===== Finished processing =====")

#---------------------------------------------------------------------
</pre>

Threads.py - Revision history

PeterHarding: New page:
#!/usr/bin/env python #--------------------------------------------------------------------- import time import logging from threading import * from datetime import datetime #---...