cueball连接池使用队列内部存储连接。鉴于连接池中的连接可能被非均匀地占用一段时间，队列可能从其初始状态达到以下状态

这种情况并不理想，因为同一个后端必须处理多个连续请求，而其他后端处于空闲状态。对于cueball来说，理想的分布工作是在后端之间，不仅从连接数上，还从请求随时间分布的角度上。诚然，上述例子是一个极端情况，这种模式可能会根据工作负载迅速解决，但没有保证这种情况会发生。cueball周期性去相干性洗牌的目标是破坏这些可能持续很长时间的模式。

有关去相干性有一个配置选项：decoherence_interval。decoherence_interval表示去相干性洗牌周期的长度，以秒为单位。如果在ConnectionPoolOptions结构中没有指定此值，则默认值为300秒。

示例

使用cueball进行连接管理需要实现Resolver特性和Connection特性。Resolver特性的实现者向连接池提供有关提供特定服务的节点信息。Connection特性定义了建立和关闭特定服务连接的行为。

以下是一个使用假设的Resolver和Connection实现来创建cueball连接池的示例。

use std::thread;
use std::net::{IpAddr, Ipv4Addr, SocketAddr};
use std::sync::{Arc, Barrier, Mutex};
use std::sync::mpsc::Sender;
use std::{thread, time};

use slog::{Drain, Logger, info, o};

use cueball::backend;
use cueball::backend::{Backend, BackendAddress, BackendPort};
use cueball::connection::Connection;
use cueball::connection_pool::ConnectionPool;
use cueball::connection_pool::types::ConnectionPoolOptions;
use cueball::error::Error;
use cueball::resolver::{BackendAddedMsg, BackendMsg, Resolver};

fn main() {
    let plain = slog_term::PlainSyncDecorator::new(std::io::stdout());
    let log = Logger::root(
        Mutex::new(
            slog_term::FullFormat::new(plain).build()
        ).fuse(),
        o!("build-id" => "0.1.0")
    );

    let be1 = (IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 55555);
    let be2 = (IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 55556);
    let be3 = (IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 55557);

    let resolver = FakeResolver::new(vec![be1, be2, be3]);

    let pool_opts = ConnectionPoolOptions::<FakeResolver> {
        max_connections: 15,
        claim_timeout: Some(1000)
        resolver: resolver,
        log: log.clone(),
        decoherence_interval: None,
    };

    let pool = ConnectionPool::<DummyConnection, FakeResolver>::new(pool_opts);

    for _ in 0..10 {
        let pool = pool.clone();
        thread::spawn(move || {
            let conn = pool.claim()?;
            // Do stuff here
            // The connection is returned to the pool when it falls out of scope.
        })
    }
}

存在多种实现Resolver和Connection特性的方案，这些方案对想要开始使用cueball的人来说可能很有用。

Resolver特性实现者

• cueball-dns-resolver
• manatee-primary-resolver
• cueball-static-resolver

Connection特性实现者

• cueball-postgres-connection
• cueball-tcp-stream-connection

最低支持的Rust版本

当前最低支持的Rust版本是1.39。