warp v0.4 でシングルスレッド・マルチスレッド

README.md

warp v0.4 でシングルスレッド

シングルスレッド

Cargo.toml

[package]
name = "warp-project"
version = "0.1.0"
edition = "2024"

[dependencies]
tokio = { version = "1", features = ["macros", "rt"] }
warp  = { version = "0.4.2", features = ["server"] }

src/main.rs

use warp::Filter;

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let routes = warp::path::end().map(|| "ok");
    warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;
}

もしくは

use tokio::runtime::Builder;
use warp::Filter;

fn main() {
    let rt = Builder::new_current_thread()
        .enable_all()
        .build()
        .unwrap();

    rt.block_on(async {
        let routes = warp::any().map(|| "Hello");
        warp::serve(routes)
            .run(([127,0,0,1], 3030))
            .await;
    });
}

マルチスレッド

Cargo.toml

[package]
name = "warp-project"
version = "0.1.0"
edition = "2024"

[dependencies]
tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
warp  = { version = "0.4.2", features = ["server"] }

src/main.rs

use warp::Filter;

#[tokio::main(flavor = "multi_thread", worker_threads = 4)]
async fn main() {
    let routes = warp::path::end().map(|| "ok");
    warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;
}

もしくは

use tokio::runtime::Builder;
use warp::Filter;

fn main() {
    let rt = Builder::new_multi_thread()
        .worker_threads(4)   // ← ここでスレッド数指定
        .enable_all()
        .build()
        .unwrap();

    rt.block_on(async {
        let routes = warp::path::end().map(|| "ok");
        warp::serve(routes)
            .run(([127, 0, 0, 1], 3030))
            .await;
    });
}