Some events

from asyncscheduler import AsyncScheduler
from time import sleep

a = AsyncScheduler()
a.start()
event = a.enter(1, 1, print, args=("event 1",))
a.enter(2, 1, print, args=("event 2",))
a.enter(3, 1, print, args=("event 3",))
a.enter(4, 1, print, args=("event 4",))
a.cancel(event)
sleep(3.1)
a.clear_scheduler()
a.stop()

event 2
event 3

Digital clock

from asyncscheduler import AsyncScheduler
import time, datetime


def display_time():
    print("\r{}".format(datetime.datetime.now().strftime("%H:%M:%S")), end='\r')


a = AsyncScheduler()
a.start()
a.repeatabs(math.floor(time.time()) + 1, 1, 1, display_time)

try:
    while True:
        time.sleep(0.25)
except KeyboardInterrupt:
    pass

a.stop()

12:34:56

enter

AsyncScheduler.enter(self, delay, priority, action, args=(), kwargs={})

Add an event to the scheduler. It will be executed after the provided delay with ‘action(*argument, **kwargs)’. In case of two events scheduled for the same time the priority is used for execution order. A lower number means a higher priority.

Parameter: * delay - delay call of func for this amount of seconds. e.g. 12.34 * priority - events scheduled for the same time are processed according to their priority. * action - function that is called upon expires * args - tuple of arguments for this function * kwargs - dict of arguments for this function

Returns the instance of the added event.

enterabs

AsyncScheduler.enterabs(self, time, priority, action, args=(), kwargs={})

Add an event to the scheduler. It will be executed at the provided time with ‘action(*argument, **kwargs)’. In case of two events scheduled for the same time the priority is used for execution order. A lower number means a higher priority.

Parameter: * time - call the action at this time stamp. * priority - events scheduled for the same time are processed according to their priority. * action - function that is called upon expires * args - tuple of arguments for this function * kwargs - dict of arguments for this function

Returns the instance of the added event.

clear_scheduler

AsyncScheduler.clear_scheduler(self)

Cancels all scheduled events.

cancel

AsyncScheduler.cancel(self, event)

Remove the provided event from the scheduler. In case of an unknown event, a ValueError will be raised.

Parameter: * event - event instance as returned from add_event.

repeat

repeat(self, every, priority, action, args=(), kwargs={})

Add a repeating event to the scheduler. It will be executed each time the provided delay (every-n-seconds) has expired with ‘func(*argument, **kwargs)’. In case of two events scheduled for the same time the priority is used for execution order. A lower number means a higher priority.

See repeatabs for more information.

Parameter: * time - call the action at this time stamp. * every - every-n-seconds call action. e.g. 12.34 * priority - events scheduled for the same time are processed according to their priority. * action - function that is called upon expirey * args - tuple of arguments for this function * kwargs - dict of arguments for this function

Returns the instance of the added event.

repeatabs

repeatabs(self, time, every, priority, action, args=(), kwargs={})

Add a repeating event to the scheduler. It will be executed each time the provided delay (every-n-seconds) has expired with ‘func(*argument, **kwargs)’. The first event is triggered at the provided time. In case of two events scheduled for the same time the priority is used for execution order. A lower number means a higher priority.

A repeating event will trigger one last time in case of a regular stop with wait=False (=default).

Note: the returned event instance is the instance of the first iteration only. Thus, after the first iteration it will not be part of scheduler.queue no more. Instead a new event for this repeating event has been created. AsyncScheduler keeps track of the current instance and uses the first instance for identification of which event to cancel. This is done with the method _repeat_event_hash and the map _repeat_event_mapping.

Parameter: * time - call the action at this time stamp. * every - every-n-seconds call action. e.g. 12.34 * priority - events scheduled for the same time are processed according to their priority. * action - function that is called upon expirey * args - tuple of arguments for this function * kwargs - dict of arguments for this function

Returns the instance of the added event.

start

start(self)

Starts the scheduler.

stop

stop(self)

Stops the scheduler. After stop, the scheduler is emptied. Thus, calling start after stop results in a new, blank schedule that must be filled.