回答情况：
提问时间：
问题标签：
tokio::run_async + futures 0.3 + tokio::net::UnixStream恐慌。2018"
futures-preview = {version="0.3.0-alpha.13", features=["compat", "io-compat"]}
use tokio::net:
浏览 0修改于2019-04-01得票数 2
我有大致如下的tokio::mainpub async fn my_tokio_main() { letlet Ok((stream, _)) = listener.accept().await { }使用大致如下的测试：async fn test_hello() {
浏览 1提问于2021-04-10得票数 1
回答已采纳
在没有主宏的情况下，如何使用定制的tokio运行时构建器来实现这个tokio_postgres示例？根据tokio_postgres docs，这可以正常工作 examples/withmacro.rs宏.rs use tokio_postgres::{NoTls, Error};
} 但是，我想像下面的主要部分一样定制tokio运行时构建器--而不是使用tokio宏。我应该如何重新配置以下代码，以便在
浏览 112修改于2020-12-25得票数 1
在tokio.rs文档中，我们可以看到以下代码片段 // split the socket stream into readable and writable parts
let (reader, writer
浏览 16修改于2019-05-29得票数 3
回答已采纳
我正在尝试使用tokio和mqtt_v5机箱中提供的编解码器创建一个MQTT连接。我的代码不能编译，我不明白为什么。这是我到目前为止所写的代码，发送代码可能不正确。use tokio::net::TcpStream;use tokio_util::codec::Decoder;
use std::net如果我尝试建议的导入，我发现模块tokio_util::codec::decoder是私有的。基于源，tokio_util:
浏览 35提问于2021-01-15得票数 0
回答已采纳
假设我想和Tokio同时下载两个网页..。要么我可以用tokio::spawn()实现这一点 let t1 = tokio::spawn(reqwest::get("https://example.com")); let (r1, r2) = (t1.await.unwr
浏览 8修改于2021-10-19得票数 15
回答已采纳
由于代码需要在某种程度上异步运行，所以我使用tokio。我将主函数创建为tokio::main。在主函数中，我创建了2个异步任务，一个侦听通道，另一个在create中触发消息队列。我的最新方法看起来像这样简化了：use tokio::sync::{
mpsc::{channel, Receiver, Sender我有一个使用横梁通道的工作示例，但是我更愿意使用tokio的异步通道，所以我没有太多的依赖项，而且所有东西都是异步的。::spa
浏览 1修改于2021-01-19得票数 2
回答已采纳
我仍然是Rust和Tokio的新手，所以毫无疑问我错过了一些明显的东西(我希望)…… main.rs： use tokio::net::TcpListener;tokio-codec = "0.1.1" 输出： error[E0277]: the trait bound `tokio::net::tcp::stream::TcpStream: tokio_iorequired by `tokio</
浏览 65提问于2019-12-30得票数 5
回答已采纳
我正在尝试使用tokio复制一个文件以进行异步操作。我看到tokio没有公开任何像tokio::fs::copy这样的方法，它可以为我完成这项工作(比如用于同步操作的等效std::fs::copy )。在尝试实现这样的方法时，我实际上无法使用tokio::fs::File::create创建一个文件，也就是说，以下代码不会创建任何文件： file.
浏览 0修改于2019-07-16得票数 4
回答已采纳
有没有一种方法可以使用Tokio0.2中的属性#[tokio::main]来指定单线程运行时？似乎没有这方面的例子。编辑:我想找到一种方法来设置tokio运行时，以便rustc知道tokio:spawn()不会是一个新线程。
浏览 2修改于2022-09-22得票数 4
但是它编译时有错误：use std::sync::{Arc, Mutex};use std::time::Duration;use tokio::net::TcpStream;
async fn main() -> Resultstream = Arc::new(Mutex::new(stream));
let common
浏览 8修改于2022-09-13得票数 1
回答已采纳
#[tokio::main]我们可以使用那里的确切示例来实现这一点。actix_web::main]如何合成两个fn main：一个用#[actix_web::main]装饰，另一个用#[tokio::main]装饰，以便在已经使用Tokio的应用程序中使用Actix Web？如何从Acti
浏览 70修改于2021-03-01得票数 8
我用cargo new tokio-test --bin创建了一个新项目，并复制粘贴了代码片段，并在链接中建立了一个基本的TCP连接。= "1.11.0", features = ["full"] }use tokio::prelude::*;}error[E0432]: unresolved
浏览 15提问于2021-09-09得票数 1
S: 250 Ok#[macro_use] extern crate bytes;externcrate tokio_service;use bytes::Bytes;use tokio_proto::streaming::{Message, Body};
use futures::{
浏览 0修改于2017-10-24得票数 1
在尝试从tokio TcpStream反序列化为JSON Value时，我尝试使用以下函数： use futures::prelude::*;use tokio::io::{AsyncReadExt, AsyncWriteExt};use tokio::stream::StreamExt;use to
浏览 58修改于2020-11-07得票数 2
在我的rust项目中，cargo在使用tokio：：sync时报告使用的类型不在作用域中： | ^^^^^ use of undeclaredcrate or module `tokio`use tokio::sync::RwLock;
pubstruct MyStruct {}
根据文档
浏览 57提问于2021-02-18得票数 0
所以我尝试遵循下面这段代码：https://github.com/bedroombuilds/python2rust/tree/main/23 我只想收听一个频道并打印到屏幕上；所以在我的实现中没有使用代码片段中tokio::stream::Stream<tokio::net::TcpStream, tokio_tls::TlsStream<tokio::net::TcpStream>>>>`
145 |::strea
浏览 78提问于2021-11-11得票数 0
回答已采纳
我的代码如下(与锈蚀食谱中提到的相同)：extern crate tempfile;extern crateforeign_links { HttpRequest(reqwest::Error);}
e
浏览 1修改于2021-04-07得票数 21
回答已采纳
1回答
我知道tokio允许编写并发代码。但我不确定它是否并行运行。我的电脑有八个核心。因此，理想情况下，我应该运行不超过8个线程。如果我需要更多的并发性，我会在这些线程之上运行协程(使用tokio)。当然，除非tokio已经是多线程的。在这种情况下，在开始时创建这8个线程将适得其反。所以我想问的是，tokio是默认的多线程，还是我应该自己实现？
浏览 128修改于2021-01-31得票数 0
回答已采纳
我如何将缓冲区的内容写入磁盘，并在不占用所有权的情况下对其进行.drain()，或者在这种情况下，由于tokio任务而不可能实现？use tokio::sync::mpsc;use std::fs::File;use serde_json;
async fn main() {
let mut inter
浏览 1提问于2022-02-20得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号