Struct Pool 

pub(crate) struct Pool {
    server: Arc<Server>,
    queues: Vec<Sender<Cmd>>,
    workers: Mutex<Vec<JoinHandle<()>>>,
    topology: Vec<usize>,
    busy: AtomicUsize,
    queued_max: AtomicUsize,
}

Runs blocking database reads away from asynchronous runtime workers.

Operating-system threads service uncached point queries and iterator seeks submitted through bounded queues. The pool keeps those blocking calls from occupying Tokio workers.

Fields

server: Arc<Server>

queues: Vec<Sender<Cmd>>

workers: Mutex<Vec<JoinHandle<()>>>

topology: Vec<usize>

busy: AtomicUsize

queued_max: AtomicUsize

Implementations

impl Pool

pub(crate) fn new(server: &Arc<Server>) -> Result<Arc<Self>>

Constructs the configured database worker pool.

Queue topology and worker counts derive from detected hardware together with server configuration. Worker groups are spawned before the shared pool handle is returned.

impl Pool

pub(crate) fn close(&self)

impl Pool

fn spawn_group( self: &Arc<Self>, recv: &[Receiver<Cmd>], chan_id: usize, count: usize, ) -> Result

impl Pool

fn spawn_one( self: Arc<Self>, workers: &mut Vec<JoinHandle<()>>, recv: &[Receiver<Cmd>], chan_id: usize, ) -> Result

impl Pool

pub(crate) async fn execute_get( self: &Arc<Self>, cmd: Get, ) -> Result<SmallVec<[Result<Handle<'_>>; 1]>>

impl Pool

pub(crate) async fn execute_iter( self: &Arc<Self>, cmd: Seek, ) -> Result<State<'_>>

impl Pool

fn select_queue(&self) -> &Sender<Cmd>

Selects the queue assigned to the first CPU affinity entry.

The configured topology maps that affinity identifier to a worker group, falling back to the first queue when the mapped group is absent.

Panics

Panics if the current thread has no available CPU affinity entry.

impl Pool

async fn execute(&self, queue: &Sender<Cmd>, cmd: Cmd) -> Result

impl Pool

fn worker(self: Arc<Self>, id: usize, chan_id: usize, recv: &Receiver<Cmd>)

impl Pool

fn worker_init(&self, id: usize, chan_id: usize)

impl Pool

fn worker_loop(self: &Arc<Self>, recv: &Receiver<Cmd>)

impl Pool

fn worker_wait(self: &Arc<Self>, recv: &Receiver<Cmd>) -> Result<Cmd, RecvError>

Trait Implementations

impl Drop for Pool

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.