splut 15

Concurrency-related Python utils

splut

Concurrency-related Python utils

API

splut.actor

Spawn Objects

class Spawn()

__call__

def __call__(*objs)

Create an actor backed by the given object(s), each of which is used in a single-threaded way.

splut.actor.future

Future Objects

class Future()

wait

def wait()

Block until there is an outcome then return/raise it.

andforget

def andforget(log)

Send any exception to the given log.

splut.bg

Sleeper Objects

class Sleeper()

interrupt

def interrupt()

If a sleep is in progress that sleep returns now, otherwise the next sleep will return immediately. This is similar behaviour to interrupting a maybe-sleeping thread in Java.

splut.delay