tokio-fusion是一个基于Tokio构建的高性能线程池服务仓库,提供了简单易用的异步任务执行API。仓库地址:https://github.com/lispking/tokio-fusion项目概述核心功能:提供了一个线程池服务,用于异步任务的高效执行。它支持单个任务和批量任
tokio-fusion 是一个基于 Tokio 构建的高性能线程池服务仓库,提供了简单易用的异步任务执行 API。
仓库地址:https\://github.com/lispking/tokio-fusion
use std::sync::Arc;
use tokio_fusion::{ThreadPool, Task, ThreadPoolResult};
async fn my_task(id: usize) -> ThreadPoolResult<String> {
// Your async task logic here
Ok(format!("Result from task {id}"))
}
#[tokio::main]
async fn main() {
// Create a thread pool with default configuration
let thread_pool = Arc::new(ThreadPool::default());
// Create and submit a task
let task = Task::new(my_task(1), 1);
let handle = thread_pool.submit(task).await.unwrap();
// Wait for the result
let result = handle.await_result().await;
println!("Task result: {:?}", result);
}
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!