Struct TaskState 

pub struct TaskState { /* private fields */ }

An owned duckdb_task_state that drives a database’s task execution.

Holds the database Arc so the underlying database outlives the state.

Implementations

impl TaskState

pub fn new(db: &Database) -> TaskState

Creates a task state for db.

pub fn execute(&self)

Executes pending tasks on the calling thread until finish is signalled. Intended to be run on a dedicated worker thread (and may be run on several threads sharing this state).

pub fn execute_n(&self, max_tasks: u64) -> u64

Executes up to max_tasks pending tasks on the calling thread, returning how many actually ran. Stops early if finish is signalled or there are no more tasks.

pub fn finish(&self)

Signals every execute_* call on this state to stop.

pub fn is_finished(&self) -> bool

Whether finish has been signalled on this state.

Trait Implementations

impl Drop for TaskState

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.

impl Send for TaskState

impl Sync for TaskState