Struct AsyncCheckpointer 

pub struct AsyncCheckpointer<R> { /* private fields */ }

Async checkpointer.

Implementations

impl<R> AsyncCheckpointer<R>

where R: Checkpoint,

pub fn new<C>(checkpointer: C) -> Self

where C: Checkpointer<R> + Send + 'static,

Create a new async checkpointer.

Arguments

• checkpointer - The checkpointer.

Returns

The async checkpointer.

pub fn with_interrupter(self, interrupter: Interrupter) -> Self

Assign a handle used to interrupt training in case of checkpointing error.

Trait Implementations

impl<R> Checkpointer<R> for AsyncCheckpointer<R>

where R: Checkpoint,

fn save(&self, epoch: usize, record: R) -> Result<(), CheckpointerError>

Save the record.

fn restore(&self, epoch: usize) -> Result<R, CheckpointerError>

Restore the record from the checkpoint saved at the given epoch.

fn delete(&self, epoch: usize) -> Result<(), CheckpointerError>

Delete the checkpoint saved at the given epoch if present.

impl<E> Drop for AsyncCheckpointer<E>

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.