不协调连接池使用队列内部存储连接。鉴于从池中取出的连接可能被占用非均匀的时间段，队列可能从其初始状态变为以下状态

这种情况并不理想，因为同一后端必须处理多个连续的请求，而其他后端则空闲。对于不协调球来说，理想的状况是在后端之间均匀分配工作，不仅限于连接数，而且还涉及随时间推移的请求分布。诚然，上面的例子是一个极端情况，模式可能会根据工作负载迅速解决，但没有保证这种情况一定会发生。不协调球中周期性洗牌的目标是扰乱可能持续一段时间的这种模式。

有一个与不协调相关的配置选项：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。