Struct RefreshService 

pub struct RefreshService {
    pub store: Arc<TableStore>,
    pub signals: Receiver<RefreshSignal>,
    /* private fields */
}

刷新服务句柄：持有表快照库、信号接收端与各表任务（drop 时中止全部任务）。

Fields

store: Arc<TableStore>

表快照库（当前代数据在此；调用者随时 snapshot pull）。

signals: Receiver<RefreshSignal>

信号接收端（每表独立计时、换代完成即通知，顺序不保证）。

Implementations

impl RefreshService

pub fn spawn(specs: Vec<RefreshSpec>) -> Self

以给定规格启动服务（内部新建空快照库）。需在 tokio runtime 内调用 （内部 tokio::spawn）；空规格 = 无任务、信号通道即闭。宿主持有本句柄： drop / Self::shutdown 会中止全部刷新任务（信号通道随之关闭）。

pub fn spawn_with_store(specs: Vec<RefreshSpec>, store: Arc<TableStore>) -> Self

以给定规格与共享快照库启动：调用者（如引擎）先在启动期用自己的同步 装载 seed 同一 store（load_rows + TableStore::insert），运行期每次 tick 换代 + 信号都落在这个 store——启动与刷新的数据天然同源、同一交付面。 同名 spec 只保留首个（重复登记 = 两个并行 ticker 换代同一表，查询耗时 差异会让旧代覆盖新代）；空规格 = 无任务、信号通道即闭。

pub fn shutdown(&mut self)

中止全部刷新任务（等价于 drop，信号通道随后关闭）。

Trait Implementations

impl Drop for RefreshService

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.