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。