#async-pool #signal #cbsk #run #callback #tool #sockets

cbsk_run

cbsk_run is async pool tool

16 releases (10 stable)

2.0.2 Sep 4, 2024
1.3.11 Aug 19, 2024
1.3.10 Jul 26, 2024
0.1.11 Apr 2, 2024
0.1.5 Dec 20, 2023

#616 in Asynchronous

Download history 15/week @ 2024-07-03 109/week @ 2024-07-17 203/week @ 2024-07-24 41/week @ 2024-07-31 134/week @ 2024-08-14 185/week @ 2024-08-21 149/week @ 2024-09-04 11/week @ 2024-09-18 42/week @ 2024-09-25 3/week @ 2024-10-09 2/week @ 2024-10-16

52 downloads per month

MIT/Apache

27KB
397 lines

cbsk_run is async pool tool
the main functions include async pool and signal::run

support the minimum version of Rust

1.80.0

signal::run example

Cargo.toml file :

cbsk_base = { version = "2.0.2" }
cbsk_run = { version = "2.0.2" }

main.rs file :

use std::time::Duration;
use cbsk_base::{anyhow, tokio};
use cbsk_base::tokio::task::JoinHandle;

#[tokio::main]
async fn main() {
    cbsk_run::run::signal::run(runnable()).await
}

fn runnable() -> anyhow::Result<Vec<JoinHandle<()>>> {
    Ok(vec![hello_world(), say_hi()])
}

fn hello_world() -> JoinHandle<()> {
    tokio::spawn(async {
        loop {
            println!("hello world");
            tokio::time::sleep(Duration::from_secs(1)).await;
        }
    })
}

fn say_hi() -> JoinHandle<()> {
    tokio::spawn(async {
        loop {
            println!("hi!");
            tokio::time::sleep(Duration::from_secs(2)).await;
        }
    })
}

running results :

E:\work\github\rust\cbsk_test>cargo run
Compiling cbsk_run v0.1.0 (E:\work\github\rust\cbsk\libs\cbsk_run)
Compiling cbsk_test v0.1.0 (E:\work\github\rust\cbsk_test)
Finished dev [unoptimized + debuginfo] target(s) in 4.21s
Running E:\work\cache\rust\github\target\debug\cbsk_test.exe
hello world
hi!
hello world
hello world
hi!
hello world
hello world
hi!
hello world
hello world
hi!
hello world
hello world
hi!
hello world
hello world
hi!
hello world
hi!
hello world
hello world
hello world
hi!
hello world

E:\work\github\rust\cbsk_test>

Dependencies

~2.5–8MB
~62K SLoC