Struct MetadataScheduler 

pub struct MetadataScheduler { /* private fields */ }

元数据调度器（优雅版：Worker 池 + Channel） 负责管理元数据获取队列和任务调度

Implementations

impl MetadataScheduler

pub fn new( hash_rx: Receiver<HashDiscovered>, fetcher: Arc<RbitFetcher>, max_queue_size: usize, max_concurrent: usize, callback: Arc<RwLock<Option<Arc<dyn Fn(TorrentInfo) + Send + Sync>>>>, on_metadata_fetch: Arc<RwLock<Option<Arc<dyn Fn(String) -> Pin<Box<dyn Future<Output = bool> + Send>> + Send + Sync>>>>, queue_len: Arc<AtomicUsize>, ) -> Self

pub fn set_callback(&mut self, callback: Arc<dyn Fn(TorrentInfo) + Send + Sync>)

设置 torrent 回调

pub fn set_metadata_fetch_callback( &mut self, callback: Arc<dyn Fn(String) -> Pin<Box<dyn Future<Output = bool> + Send>> + Send + Sync>, )

设置元数据获取前的检查回调

pub async fn run(self)

运行调度器（完全事件驱动）