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。