Struct ShardedNodeQueue 

pub struct ShardedNodeQueue { /* private fields */ }

分片节点队列 - 支持高并发，IPv4 和 IPv6 节点分开存储

Implementations

impl ShardedNodeQueue

pub fn new(total_capacity: usize) -> Self

创建新的分片队列

pub fn push(&self, node: NodeTuple)

添加节点（根据地址类型自动存入对应队列）

pub fn pop_batch( &self, count: usize, filter_ipv6: Option<bool>, ) -> Vec<NodeTuple>

批量弹出节点

Arguments

• count - 需要获取的节点数量
• filter_ipv6 - 如果为 Some(true)，只从 IPv6 队列获取；如果为 Some(false)，只从 IPv4 队列获取；如果为 None，从两个队列混合获取

pub fn get_random_nodes( &self, count: usize, filter_ipv6: Option<bool>, ) -> Vec<NodeTuple>

获取随机节点（用于DHT响应）

Arguments

• count - 需要获取的节点数量
• filter_ipv6 - 如果为 Some(true)，只返回 IPv6 节点；如果为 Some(false)，只返回 IPv4 节点；如果为 None，返回所有节点（混合）

pub fn len(&self) -> usize

获取总长度（IPv4 + IPv6）

pub fn is_empty(&self) -> bool

检查是否为空

pub fn is_empty_for(&self, filter_ipv6: Option<bool>) -> bool

检查指定地址族的队列是否为空

Arguments

• filter_ipv6 - 如果为 Some(true)，检查 IPv6 队列；如果为 Some(false)，检查 IPv4 队列；如果为 None，检查两个队列