Struct ThreadSafeRandAgent

pub struct ThreadSafeRandAgent { /* private fields */ }

线程安全的 RandAgent，支持多线程并发访问

Implementations

impl ThreadSafeRandAgent

pub fn new(agents: Vec<(BoxAgent<'static>, String, String)>) -> Self

创建新的线程安全 RandAgent

pub fn with_max_failures( agents: Vec<(BoxAgent<'static>, String, String)>, max_failures: u32, ) -> Self

使用自定义最大失败次数创建线程安全 RandAgent

pub fn add_agent( &self, agent: BoxAgent<'static>, provider: String, model: String, )

添加代理到集合中

pub fn add_agent_with_max_failures( &self, agent: BoxAgent<'static>, provider: String, model: String, max_failures: u32, )

使用自定义最大失败次数添加代理

pub fn len(&self) -> usize

获取有效代理数量

pub fn total_len(&self) -> usize

获取总代理数量（包括无效的）

pub fn is_empty(&self) -> bool

检查是否有有效代理

pub async fn prompt( &self, message: &str, ) -> Result<String, Box<dyn Error + Send + Sync>>

向随机有效代理发送消息

pub fn agents(&self) -> Vec<(String, String, u32, u32)>

获取所有代理（用于调试或检查）

pub fn failure_stats(&self) -> Vec<(usize, u32, u32)>

获取失败统计

pub fn reset_failures(&self)

重置所有代理的失败计数

Trait Implementations

impl Send for ThreadSafeRandAgent

impl Sync for ThreadSafeRandAgent