import threading
import time


class DelayedQueryThread(threading.Thread):
    def __init__(self, targetdbm, targetname, delay, query, args):
        threading.Thread.__init__(self)
        self.targetdbm = targetdbm
        self.targetname = targetname
        self.delay = delay
        self.query = query
        self.args = args
        
    def run(self):
        time.sleep(self.delay)
        with self.targetdbm.cursor(self.targetname) as curs:
            curs.execute(self.query, self.args)


class DelayedQuery:
    def __init__(self, targetdbm):
        '''Initialize DelayedQuery.
        
        targetdbm -- PgManager-like object
        
        '''
        self.targetdbm = targetdbm
        self.queryids = set()

    def add(self, delay, query, args, targetname='default', queryid=None):
        '''Add query to schedule.
        
        delay -- how long to wait, in seconds
        query, args -- query to be run after delay
        targetname -- name of connection in PgManager
        queryid -- discard if query with same id is already scheduled
        
        '''
        if queryid is not None:
            if queryid in self.queryids:
                return
            self.queryids.add(queryid)
        
        t = DelayedQueryThread(self.targetdbm, targetname, delay, query, args)
        t.start()