Struct AsyncTaskPlugin 

pub struct AsyncTaskPlugin { /* private fields */ }

异步任务插件：基于 Semaphore 的并发控制后台任务队列

stop() 时会等待所有正在执行的任务完成后才返回。

Implementations

impl AsyncTaskPlugin

pub fn new(workers: usize) -> Self

创建异步任务插件

workers = 0 时自动设为 4（CPU 核数的合理默认值）。

pub async fn submit<F>(&self, task: F)

where F: Future<Output = ()> + Send + 'static,

提交异步任务

pub fn worker_count(&self) -> usize

工作线程数

Trait Implementations

impl Plugin for AsyncTaskPlugin

fn name(&self) -> &str

插件唯一名称（用于注册、日志、依赖解析）

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

启动插件：验证连接、初始化资源

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

关闭插件：释放资源

fn depends_on(&self) -> &[&str]

依赖的其他插件名称（用于拓扑排序，保证启动顺序）