Threading API

Thread

Thread management.

Creates and starts a new thread.

Creates a delayed execution timer.

Pauses the current thread for the given number of seconds.

Returns a named or anonymous lock.

Acquires a named lock.

Releases a named lock.

Clears a named event (blocks waiters).

Sets a named event (unblocks waiters).

Waits for a named event. Returns True if event was set.

Returns a named or anonymous event.

Returns a named or anonymous semaphore.

Reference to Python’s Queue.Queue class.

@thread
def background_task():
    # This runs in a new thread
    ...

background_task()  # Returns immediately, function runs in background

@spawn
def init_task():
    # Runs immediately in a new thread when the module loads
    ...

@lock('my_operation')
def safe_operation():
    # Runs with 'my_operation' lock held
    ...

@parallelize
def fetch_all():
    for url in urls:

        @task
        def fetch(url=url):
            results.append(HTTP.Request(url).content)