direct.stdpy.threading

from direct.stdpy.threading import BoundedSemaphore, Condition, Event, ExternalThread, Lock, MainThread, RLock, Semaphore, Thread, ThreadBase, Timer, active_count, current_thread, enumerate, main_thread, setprofile, settrace, stack_size

This module reimplements Python’s native threading module using Panda threading constructs. It’s designed as a drop-in replacement for the threading module for code that works with Panda; it is necessary because in some compilation models, Panda’s threading constructs are incompatible with the OS-provided threads used by Python’s thread module.

This module implements the threading module with a thin layer over Panda’s threading constructs. As such, the semantics are close to, but not precisely, the semantics documented for Python’s standard threading module. If you really do require strict adherence to Python’s semantics, see the threading2 module instead.

However, if you don’t need such strict adherence to Python’s original semantics, this module is probably a better choice. It is likely to be slighly faster than the threading2 module (and even slightly faster than Python’s own threading module). It is also better integrated with Panda’s threads, so that Panda’s thread debug mechanisms will be easier to use and understand.

It is permissible to mix-and-match both threading and threading2 within the same application.

Inheritance diagram

class BoundedSemaphore(value=1)

Bases: Semaphore

This class provides a wrapper around Panda’s Semaphore object. The wrapper is designed to emulate Python’s own threading.BoundedSemaphore object.

__init__(self, value=1)

release(self)

class Condition(lock=None)

Bases: ConditionVar

This class provides a wrapper around Panda’s ConditionVar object. The wrapper is designed to emulate Python’s own threading.Condition object.

__init__(self, lock=None)

acquire(self, *args, **kw)

notifyAll(self)

release(self)

wait(self, timeout=None)

class Event

Bases: object

This class is designed to emulate Python’s own threading.Event object.

__init__(self)

clear(self)

is_set(self)

set(self)

wait(self, timeout=None)

class ExternalThread(extThread, threadId)

Bases: ThreadBase

Returned for a Thread object that wasn’t created by this interface.

__init__(self, extThread, threadId)

isAlive(self)

is_alive(self)

join(self, timeout=None)

run(self)

setDaemon(self, daemon)

start(self)

class Lock(name='PythonLock')

Bases: Mutex

This class provides a wrapper around Panda’s Mutex object. The wrapper is designed to emulate Python’s own threading.Lock object.

__init__(self, name='PythonLock')

class MainThread(extThread, threadId)

Bases: ExternalThread

Returned for the MainThread object.

__init__(self, extThread, threadId)

class RLock(name='PythonRLock')

Bases: ReMutex

This class provides a wrapper around Panda’s ReMutex object. The wrapper is designed to emulate Python’s own threading.RLock object.

__init__(self, name='PythonRLock')

class Semaphore(value=1)

Bases: Semaphore

This class provides a wrapper around Panda’s Semaphore object. The wrapper is designed to emulate Python’s own threading.Semaphore object.

__init__(self, value=1)

acquire(self, blocking=True)

class Thread(group=None, target=None, name=None, args=(), kwargs={}, daemon=None)

Bases: ThreadBase

This class provides a wrapper around Panda’s PythonThread object. The wrapper is designed to emulate Python’s own threading.Thread object.

__init__(self, group=None, target=None, name=None, args=(), kwargs={}, daemon=None)

is_alive(self)

join(self, timeout=None)

run(self)

setName(self, name)

start(self)

class ThreadBase

Bases: object

A base class for both Thread and ExternalThread in this module.

__init__(self)

considerYield()

C++ Interface: consider_yield()

/**

• Possibly suspends the current thread for the rest of the current epoch, if

• it has run for enough this epoch. This is especially important for the

• simple thread implementation, which relies on cooperative yields like this.

*/

forceYield()

C++ Interface: force_yield()

/**

• Suspends the current thread for the rest of the current epoch.

*/

getName(self)

isDaemon(self)

setDaemon(self, daemon)

class Timer(interval, function, args=[], kwargs={})

Bases: Thread

Call a function after a specified number of seconds:

t = Timer(30.0, f, args=[], kwargs={}) t.start() t.cancel() # stop the timer’s action if it’s still waiting

__init__(self, interval, function, args=[], kwargs={})

cancel(self)

Stop the timer if it hasn’t finished yet

run(self)

active_count()

current_thread()

enumerate()

main_thread()

setprofile(func)

settrace(func)

stack_size(size=None)