Struct ReentrantDispatch 

pub struct ReentrantDispatch { /* private fields */ }

Reentrancy-safe dispatcher for affinity-pinned threads.

Attach one of these to GracefulIpcChannel so that callers can safely dispatch work back to the “main” (or any named) thread without deadlocking when the caller itself is the affinity thread.

The pattern mirrors Swift’s MainActor.assumeIsolated and C#’s SynchronizationContext.Send:

• Caller is affinity thread → execute f inline, return immediately.
• Caller is any other thread → push f to the queue, block until the affinity thread drains it via ReentrantDispatch::pump.

Implementations

impl ReentrantDispatch

pub fn new() -> Self

Create a new dispatch queue.

pub fn bind_current_thread(&self)

Bind the current thread as the affinity thread.

Must be called once from the thread that will handle dispatched work (e.g. the DCC idle callback, Unity EditorApplication.update, Unreal FTSTicker, etc.).

Calling this again from a different thread replaces the binding.

pub fn is_affinity_thread(&self) -> bool

Returns true if the calling thread is the bound affinity thread.

pub fn submit_reentrant<F, R>(&self, f: F) -> Result<R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

Submit f to the affinity thread in a reentrancy-safe way.

• If the current thread is the affinity thread, f is called inline and its return value is propagated immediately — no queue, no blocking.
• Otherwise, f is pushed into the work queue and the calling thread blocks until the affinity thread processes it via pump.

Errors

Returns Err(IpcError::Closed) if the affinity thread has been dropped (the receiver end of the queue is gone).

Returns Err(IpcError::Other(...)) if f itself returns an error.

pub fn pump(&self, budget: Duration) -> usize

Drain at most one “budget” worth of pending work items on the current (affinity) thread.

Call this from your host’s idle callback:

// Maya scriptJob idleEvent / Unity EditorApplication.update / …
dispatch.pump(std::time::Duration::from_millis(8));

Returns the number of items processed.

pub fn pending_count(&self) -> usize

Number of items currently waiting in the queue.

Trait Implementations

impl Clone for ReentrantDispatch

fn clone(&self) -> ReentrantDispatch

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ReentrantDispatch

fn default() -> Self

Returns the “default value” for a type.