core.dispatch module

basic package for the program.

class Dispatcher(zelf, *args, **kwargs)

Bases: core.Object

the dispatcher delegates the workload to the Runners. Runner gets instantiated when needed.

allowed(zelf, *args, **kwargs)

cleanup(zelf, dojoin=False)

remove idle Runners.

denied(zelf, *args, **kwargs)

dispatch(zelf, *args, **kwargs)

dispatch an event onto a Runner.

execute(zelf, *args, **kwargs)

execute a command, event pair.

exit(zelf, name=None)

stop the Runners.

is_alive(zelf, *args, **kwargs)

whether any Runners running.

make_new(zelf, *args, **kwargs)

create a Runner.

put(zelf, *args, **kwargs)

put load to the Runner.

register(zelf, *args, **kwargs)

callback type with corresponding callback function.

run_func(zelf, *args, **kwargs)

execute command/event pair.

class Runner(zelf, *args, **kwargs)

Bases: threading.Thread

the working unit of CORELIB.

clear(zelf)

clear the ready state.

exit(zelf, *args, **kwargs)

stop the Runner.

get_name(zelf, *args, **kwargs)

nr = 0

put(zelf, *args, **kwargs)

put arguments/kwargs to the Runner.

ready(zelf)

signal to ready state.

wait(zelf, sec=180.0)

wait for ready state.