Operator Can Be Used in Functions That Return Result 章节中学到的知识应用到我的共享mpsc通道代码中。下面是最小的代码： use std::sync::{ mpsc, Arc, Mutex };{
fn sh_rx_get(sh_rx : Arc< Mutex< mpsc::Receiver< usize > > > ) -> Result< u
浏览 8提问于2021-07-12得票数 2
回答已采纳
我有一个结构的向量，每个结构都包含一个mpsc::Sender和mpsc::Receiver，我试图将这些结构中的每一个都移动到一个线程中，并不断得到这个编译错误(对于发送者来说是一个对称的错误)。由于发送者和接收者是结构的一部分，我不确定如何克隆它们。obj in objs.iter() { ^^^^^^^^^^^^^ `std::sync::mpsc
浏览 0提问于2021-04-15得票数 0
1回答
我试图将一些请求传递给另一个带有通道的线程(试图避免使用弧形/互斥)。不过，我仍然注意到，当我将mpsc：：sync：：sync传递给warp处理程序时，我会得到这个错误。“std：：sync：：mpsc：：发件人不能在线程之间安全共享”“没有为‘`std：：sync：：mpsc：：Sync’实现该特性Sync”
pub async fn init_server(run_tx: Sen
浏览 6提问于2022-11-22得票数 1
1回答
我正在尝试多处理一些现有的代码，我发现使用Pool将数据分拣/取消分拣到进程中太慢了。我认为就我的情况而言，Manager也会遇到同样的问题，因为它会在幕后进行同样的处理。为了解决这个问题，我正在尝试使用共享内存阵列。为此，我需要一个字符串数组。multiprocessing.Array似乎支持ctypes.c_char_p，但我很难将其扩展为字符串数组。构造函数的共享内存字符串。在版本1和版本2中，您可以看到在进程外工作时数据是如何被打乱的(正如预期的那样)。似乎应该有一种方法来创建共
浏览 6提问于2018-02-11得票数 3
回答已采纳
1回答
我将代码简化为以下内容(我最初尝试共享包含一个HashMap的Vec)：use std::sync::mpsc;usestd::sync::Arc; let(tx, rx) = mpsc::channel();
// some computation
Arc::from(Mute
浏览 0提问于2019-03-25得票数 0
回答已采纳
我正在使用mpsc创建一个多线程应用程序，以便在线程之间共享内存：use std::sync::mpsc::{Sender, Receiver};
pub content: Vec<i16>, /* ... */
fn child(rx: mpsc::Receiver<Msg>,
浏览 0提问于2018-03-19得票数 4
回答已采纳
我认为通道的全部目的是在线程之间共享数据。result = ctx.method()})error[E0277]: the trait bound `std::sync::mpsc::Sender<(std::string::String:9137 | thread::spawn(
浏览 0提问于2016-11-02得票数 18
回答已采纳
1回答
我希望在异步函数与运行在单独线程上的另一个异步函数之间共享一些数据。在这种情况下，它是一个任人唯亲的工作。到目前为止，这是我想出的解决方案：use tokio::sync::mpsc;use tokio_cron_scheduler::{Job, JobScheduler};
pub async fn main() {
let (tx, mut rx): (mpsc::Sender<i16>, mpsc::Receive
浏览 2提问于2022-05-14得票数 0
extern crate num;
use std::io::{self, Write};use std:Factorial { n: BigInt },}
let (input_tx, input_rx) = mpscinput_tx.send(Arc::new(Mutex::new(Command::Quit)));}
error: the trait
浏览 2提问于2016-07-11得票数 0
回答已采纳
但是，我得到了一个错误 | | ^^^^^^^^^^^^^ `std::sync::mpscself:Foo]`如果我将结构改为保
浏览 1提问于2018-04-30得票数 4
回答已采纳
我想使用线程两个线程，一个用于在stdout中读取，另一个用于在stderr上读取，这些线程将每一行读到通道。主线程收集行并检查超时，如果发生超时，则应终止进程。我的问题是如何共享timeout /err句柄，如果发生超时，它仍然能够在以后终止进程。rx_stdout): (Sender<Result<Vec<u8>, ExecutionError>>, Receiver<Result<Vec<u8>, ExecutionError>>) = mpsc
浏览 2提问于2021-03-22得票数 0
回答已采纳
我想修改一个上传异步文件的库，这样它就可以在什么迭代中“公开”或“通知”它，我的目标是防止直接从库中“打印/写入”，而是从使用库的方法中进行，这样通过使用“公开的”数据，他们就可以做一些事情。“共享状态”(如果可以这样调用)，这样如果我接收到一个Sender作为参数，我就可以写到它，并从进行调用的方法中，使用Receiver来做一些事情(例如，显示进度条)，这就是我正在尝试的： use tokio::sync::mpsc;
fn upload(file: String, sender: Op
浏览 16提问于2020-08-12得票数 0
我想发送事件之间的游戏客户端和服务器，我已经让它工作，但我不知道如何做它与贝维。我依赖于使用tokios异步TcpStream，因为我必须能够使用stream.into_split()将流拆分为OwnedWriteHalf和OwnedReadhalf。我的第一个想法是生成一个处理连接的线程，然后使用mpsc::channel将接收到的事件发送到队列中。最好将异步TcpStream初始化和tokio::sync::mpsc::Sender以及Queue.pull封装到同步函数中，但我不知道
浏览 12提问于2022-03-27得票数 2
回答已采纳
1回答
我们有这样的状态：
let tasks = vec![String::from("task1"), String::from("task2")];
let tx1 = tx.clone我似乎真的不明白如何设置并行线程，以及如何将通道与线程和任务列表一起处理。
浏览 1提问于2021-12-30得票数 -1
我的次级线程看起来是这样的： // Here the buffer is sent via mpscirrelevant to th
浏览 3提问于2021-01-07得票数 1
回答已采纳
我试图使用MPSC构建一个多线程应用程序，并且在标题中遇到了错误。我不知道这个用例的正确模式是什么--我正在寻找一种模式，它将允许我克隆生产者通道，并将它移动到一个新的线程中使用。使用者线程中将需要来自其他线程的数据，这就是为什么我认为MPSC模式是一个合适的选择。除了标题中的消息外，它还显示了以下内容：help: thetrait
浏览 13提问于2022-08-16得票数 2
回答已采纳
2回答
例如，通过调用sleep我知道我可以使用std::sync::mpsc在线程之间进行通信我曾经想过使用std::sync::mpsc，可能是Builder和.name与线程相关联，但我不知道如何唤醒线程。
浏览 7提问于2017-05-14得票数 2
回答已采纳
1回答
我正在尝试使用tonic和grpc实现一个简单的流rpc。我一直在跟踪。^ expected enum `Result`, found struct `PrngResponse` = note: expected struct `tokio::sync::mpsc>`
note: return type inferred to be `tokio::sync::mpsc::Receiver<Result<PrngResponse, Status>>` here::Receiver`, found
浏览 15提问于2022-06-16得票数 0
回答已采纳
我有一个函数collect_n，它返回一个Future，它反复地将一个futures::sync::mpsc::Receiver收集到一个向量中，并使用该向量进行解析。问题是它消耗了Receiver，因此不能再次使用Receiver。我正在尝试编写一个版本，该版本接受Receiver的所有权，但当返回的Future解析时，将所有权返回给调用方。<T>( n: usize,
) -> impl Future<Item =
浏览 2提问于2020-03-11得票数 2
回答已采纳
1回答
我正在研究用POSIX共享内存代替POSIX消息队列的IPC。我计划创建一个足够大的共享内存区域，以容纳50条消息，每条消息750字节。关于POSIX共享内存，我有三个问题： (1)有没有一种方法可以在新数据可用时自动通知客户端，就像POSIX管道和消息队列提供的方法一样？(2)使用没有锁的共享内存会出现什么问题，其中数据是一次写入、一次读取？ (3)我读到过共享内存是最快的IPC方法，因为它具有最高的带宽，并且数据在服务器和客户端内核中都立即可用。但是，使用消息队列和
浏览 18提问于2020-04-28得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
