Function benchmark

tests/benchmark.rs:11–34

()

#[test]
fn benchmark() -> Result<(), Box<dyn Error>> {
    let queries = TASKS * QUERIES;
    let tcp_url = var("TCP_URL")?;
    let uds_url = var("UDS_URL")?;
    let mut tokio_rr = tokio::runtime::Runtime::new()?;

    println!("Benchmark concurrency({}), queries({}):", TASKS, queries);
    println!("  - async-postgres on async-std runtime:");
    let elapsed = async_std::task::block_on(async_runtime(&tcp_url))?;
    println!("      - tcp: {} us/q", elapsed.as_micros() / queries);
    let elapsed = async_std::task::block_on(async_runtime(&uds_url))?;
    println!("      - uds: {} us/q", elapsed.as_micros() / queries);
    println!("  - async-postgres on tokio runtime:");
    let elapsed = tokio_rr.block_on(tokio_runtime(&tcp_url))?;
    println!("      - tcp: {} us/q", elapsed.as_micros() / queries);
    let elapsed = tokio_rr.block_on(tokio_runtime(&uds_url))?;
    println!("      - uds: {} us/q", elapsed.as_micros() / queries);
    println!("  - tokio-postgres on tokio runtime:");
    let elapsed = tokio_rr.block_on(tokio_postgres(&tcp_url))?;
    println!("      - tcp: {} us/q", elapsed.as_micros() / queries);
    let elapsed = tokio_rr.block_on(tokio_postgres(&uds_url))?;
    println!("      - uds: {} us/q", elapsed.as_micros() / queries);
    Ok(())
}

async fn async_runtime(url: &str) -> Result<Duration, Box<dyn Error>> {
    use async_std::task::spawn;