#!/usr/bin/env python
# -*- coding: utf-8 -*-
import threading
import time
import queue as Queue
class _timerThread(threading.Thread):
def __init__(self, t_name,queue,cond,args):
threading.Thread.__init__(self, name=t_name)
self.threadtimes = []
self.threadFunc = {}
self.lasttimes = {}
self.queue = queue
self.args = args
def setNewTimer(self,newobj):
if newobj.func == None:
self.threadtimes.remove(newobj.secendtime)
self.threadFunc[str(newobj.secendtime)] = None
self.lasttimes[str(newobj.secendtime)] = None
else:
if newobj.secendtime in self.threadtimes:
self.threadFunc[str(newobj.secendtime)] = newobj.func
self.lasttimes[str(newobj.secendtime)] = int(time.time())
else:
self.threadtimes.append(newobj.secendtime)
self.threadFunc[str(newobj.secendtime)] = newobj.func
self.lasttimes[str(newobj.secendtime)] = int(time.time())
def run(self):
last_threadtimes_len = len(self.threadtimes)
while(True):
#print("begin run")
if not self.queue.empty():
objtmp = self.queue.get()
self.setNewTimer(objtmp)
timetmp = int(time.time())
for tx in self.threadtimes:
if last_threadtimes_len == 0 and len(self.threadtimes) > 0:
self.lasttimes[str(tx)] = timetmp
self.threadFunc[str(tx)](self.args)
last_threadtimes_len = len(self.threadtimes)
if timetmp - self.lasttimes[str(tx)] >= tx and last_threadtimes_len > 0:
self.lasttimes[str(tx)] = timetmp
self.threadFunc[str(tx)](self.args)
self.condition.release()
class _timerObj():
def __init__(self,secendt,funct):
self.secendtime = secendt
self.func = funct
class threadtimer():
def __init__(self,args):
self.queue = Queue.Queue()
self.cond = threading.Condition()
self.args = args
self.t_thread = _timerThread(str(int(time.time())),self.queue, self.cond,self.args)
self._timers = []
self._initTimer()
def _initTimer(self):
self.t_thread.setDaemon(True)
self.t_thread.start()
def getTimers(self):
return self._timers
def setTimer(self,secendTime,Func):
objtmp = _timerObj(secendTime,Func)
self._timers.append(secendTime)
self.queue.put(objtmp)
def removeTimer(self,secendTime):
objtmp = _timerObj(secendTime,None)
self._timers.remove(secendTime)
self.queue.put(objtmp)
