sourceserver.info

Quellcode

def tick():
    try:
        '''
        Internal use recommended.
        '''
        # handle normal q
        while not q.empty():
            function, a, kw = q.get()
            function(*a, **kw)
        # check the first one to speed this up since none are ready unless it is.
        first = timeq.getFirst()
        if first:
            now = time.time()
            if first.gotime <= now:
                _executenode(first)
                # make a copy of the list so that we don't
                tasks = list(timeq.getList())
                for task in tasks:
                    if task.gotime <= now:
                        _executenode(task)
                    else:
                        break
    
        if timeq.empty() and q.empty():
            unregisterTicker()
    except KeyboardInterrupt:
        es.server.cmd("quit")