搜索结果
查询Tags标签： Tokio，共有 14条记录-
文盘Rust -- tokio绑定cpu实践
tokio 是 rust 生态中流行的异步运行时框架。在实际生产中我们如果希望 tokio 应用程序与特定的 cpu core 绑定该怎么处理呢？这次我们来聊聊这个话题。 首先我们先写一段简单的多任务程序。 use tokio::runtime; pub fn main() {let rt = runtime::Builder::new_multi_th…
2023/6/5 14:23:27 人评论 次浏览 -
文盘Rust -- 用Tokio实现简易任务池
作者：京东科技 贾世闻 Tokio 无疑是 Rust 世界中最优秀的异步Runtime实现。非阻塞的特性带来了优异的性能，但是在实际的开发中我们往往需要在某些情况下阻塞任务来实现某些功能。 我们看看下面的例子 fn main(){let max_task = 1;let rt = runtime::Builder::new_multi_…
2023/4/14 18:52:00 人评论 次浏览 -
【Tokio】mini-redis 服务器
环境Time 2022-01-13 Rust 1.57.0 Tokio 1.15.0概念 参考：https://tokio.rs/tokio/tutorial/setup 示例 查看版本 C:\Users\jiangbo\work\rust\game>rustc --version rustc 1.57.0 (f1edd0429 2021-11-29)安装 cargo install mini-redis 启动 mini-redis-server 访问 …
2022/3/31 19:19:27 人评论 次浏览 -
【Tokio】单线程运行时
环境Time 2022-01-11 Rust 1.57.0 Tokio 1.15.0概念 参考：https://docs.rs/tokio/latest/tokio/runtime/struct.Builder.html 除了可以使用线程池运行时，还可以直接在当前线程运行任务，使用单线程。 示例 main.rs use std::{io, thread, time::Duration};use tokio::ru…
2022/2/27 23:29:38 人评论 次浏览 -
【Tokio】任务运行句柄
环境Time 2022-01-10 Rust 1.57.0 Tokio 1.15.0概念 参考：https://docs.rs/tokio/latest/tokio/runtime/struct.Runtime.html handle 方法返回一个可以执行任务的句柄。 示例 main.rs use std::{io, thread, time::Duration};use tokio::runtime::Runtime;fn main() ->…
2022/2/27 23:29:37 人评论 次浏览 -
【Tokio】进入运行时上下文
环境Time 2022-01-10 Rust 1.57.0 Tokio 1.15.0概念 参考：https://docs.rs/tokio/latest/tokio/runtime/struct.Runtime.html enter 方法可以进入异步运行时的上下文。 示例 main.rs use std::{io, time::Duration};use tokio::runtime::Runtime;fn main() -> io::Res…
2022/2/27 23:27:32 人评论 次浏览 -
【Tokio】阻塞线程任务
环境Time 2022-01-10 Rust 1.57.0 Tokio 1.15.0概念 参考：https://docs.rs/tokio/latest/tokio/runtime/struct.Runtime.html spawn_blocking 方法可以接收一个闭包，可以是一个阻塞任务。Tokio 有两种线程。一种给异步任务的核心线程，一种是运行同步任务的阻塞线程。 核…
2022/2/27 23:27:28 人评论 次浏览 -
【Tokio】当前线程任务
环境Time 2022-01-10 Rust 1.57.0 Tokio 1.15.0概念 参考：https://docs.rs/tokio/latest/tokio/runtime/struct.Runtime.html block_on 方法可以接收一个异步任务，在当前线程中运行并阻塞直到完成。Runtime::new() 创建的运行时，会有一个主线程和 CPU 逻辑核数相等工作…
2022/2/27 23:27:25 人评论 次浏览 -
【Tokio】非阻塞关闭运行时
环境Time 2022-01-10 Rust 1.57.0 Tokio 1.15.0概念 参考：https://docs.rs/tokio/latest/tokio/runtime/struct.Runtime.html shutdown_background 方法可以立即关闭运行时，不会产生阻塞。通常在另一个运行时中调用，避免阻塞。由于 shutdown_background 不等待任务结束…
2022/2/27 23:27:21 人评论 次浏览 -
【Tokio】阻塞关闭运行时
环境Time 2022-01-10 Rust 1.57.0 Tokio 1.15.0概念 参考：https://docs.rs/tokio/latest/tokio/runtime/struct.Runtime.html shutdown_timeout 方法关闭运行时会阻塞，等待任务完成。参数可以提供最大等待时间，超时将被强制结束。 示例 main.rs use std::{io, thread, …
2022/2/27 23:27:21 人评论 次浏览 -
Rust 程序设计语言 web server (tokio)
Rust 程序设计语言 web server 1 web server 源码2 web server (tokio)1 web server 源码 // src/bin/main.rs use std::fs; use std::io::prelude::*; use std::net::{TcpListener, TcpStream}; use web_server::ThreadPool;fn main() {let listener = TcpListener::bind…
2021/12/21 1:20:51 人评论 次浏览 -
Rust 程序设计语言 web server (tokio)
Rust 程序设计语言 web server 1 web server 源码2 web server (tokio)1 web server 源码 // src/bin/main.rs use std::fs; use std::io::prelude::*; use std::net::{TcpListener, TcpStream}; use web_server::ThreadPool;fn main() {let listener = TcpListener::bind…
2021/12/21 1:20:51 人评论 次浏览 -
Rust网络编程框架-深入理解Tokio中的管道
我们在上文《Rust网络编程框架-Tokio进阶》介绍了async/await和锁的基本用法，并完成了一个Server端的DEMO代码。本文继续来探讨这个话题。 客户端代码DEMO 上文中依靠telnet来触发服务端代码的执行，本文我们将自己实现一个客户端。由于笔者也没有从之前比如GO、JAVA等语…
2021/9/25 11:12:29 人评论 次浏览 -
Rust网络编程框架-深入理解Tokio中的管道
我们在上文《Rust网络编程框架-Tokio进阶》介绍了async/await和锁的基本用法，并完成了一个Server端的DEMO代码。本文继续来探讨这个话题。 客户端代码DEMO 上文中依靠telnet来触发服务端代码的执行，本文我们将自己实现一个客户端。由于笔者也没有从之前比如GO、JAVA等语…
2021/9/25 11:12:29 人评论 次浏览
