Struct ThreadAwareAccountLocks 

pub struct ThreadAwareAccountLocks { /* private fields */ }

Thread-aware account locks which allows for scheduling on threads that already hold locks on the account. This is useful for allowing queued transactions to be scheduled on a thread while the transaction is still being executed on the thread.

Implementations

impl ThreadAwareAccountLocks

pub fn new(num_threads: usize) -> Self

Creates a new ThreadAwareAccountLocks with the given number of threads.

pub fn try_lock_accounts<'a>( &mut self, write_account_locks: impl Iterator<Item = &'a Pubkey> + Clone, read_account_locks: impl Iterator<Item = &'a Pubkey> + Clone, allowed_threads: ThreadSet, thread_selector: impl FnOnce(ThreadSet) -> ThreadId, ) -> Result<ThreadId, TryLockError>

Returns the ThreadId if the accounts are able to be locked for the given thread, otherwise None is returned. allowed_threads is a set of threads that the caller restricts locking to. If accounts are schedulable, then they are locked for the thread selected by the thread_selector function. thread_selector is only called if all accounts are schdulable, meaning that the thread_set passed to thread_selector is non-empty.

pub fn unlock_accounts<'a>( &mut self, write_account_locks: impl Iterator<Item = &'a Pubkey>, read_account_locks: impl Iterator<Item = &'a Pubkey>, thread_id: ThreadId, )

Unlocks the accounts for the given thread.

Trait Implementations

impl Debug for ThreadAwareAccountLocks

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.