process

process module - implements process concepts. yessirre.

class sake.process.Process

Process monitor

StartProcess()

StartProcess() -> None Called by app when process or service starts

StopProcess()

StopProcess() -> None Called when process or service stops

Wait(timeout=-1)

Wait(timeout) -> bool Wait on all tasklets in the process. If the function returns ‘True’, all tasklets have exited. If the function returns ‘False, one or more tasklets are still busy. ‘timeout’ is timeout in milliseconds. Use WAIT_INFINITE for no timeout. If ‘timeout’ is WAIT_CHECK, the function returns immediately.

If the calling tasklet is part of the process, the function will return when all other tasklets have exited (i.e. it will not deadlock itself or raise an error).

class sake.process.Tasklet

Tasklet wrapper. Adds top-level exception handler and keeps reference to its owner

RestoreState(oldstate)

Restore the tasklet attributes to those that were before SetupState()

RunFunc(process, func, args, kwargs)

Run a function, along with the proper top level error handling and process bookkeeping. SetupState() must have been called previously.

SetupState(process)

Set up the tasklet with initial attributes pertaining to the process, returning any such previous attributes (oldstate)

class sake.process.TaskletPool

A class that recycles tasklets. This is useful not as a performance improvement, but to limit the number of actual tasklet IDs in use, when implementing C level code that uses the tasklet ID as an index to some sort of TLS structure.

DropTasklet()

Remove the oldest Tasklet from the queue, telling it to stop.

Flush()

Clear the queue of idle tasklets

GetWork()

Get the next piece of work to perform on the behalf of a user, or None

Tasklet(process, func)

Emulate the constructor of the Tasklet object. Tries to get the most recently used idle tasklet. If none are available, a new is created. Returns a callable that can be used to bind arguments to the call.

TaskletFunc(mutableArgs)

The main worker function for each tasklet managed by the TaskletPool Takes as arguments the initial process, function and arguments to execute.