接收器在尝试通过通道发送时关闭并返回 SendError

Question

我正在尝试在两个线程之间建立双向通信：子线程既可以向父线程发送数据也可以从父线程接收数据，而父线程既可以向子线程发送数据也可以从子线程接收数据。由于 Rust 中的通道是单向的，我使用了一组两个通道，组织方式如下（我自制的线程库中的一个片段）：

let (tx, rx) = channel();
let (tx2, rx2) = channel();

(Endpoint {
     sender: tx2,
     receiver: rx,
 },
 Endpoint {
     sender: tx,
     receiver: rx2,
 })

我的设置函数中的代码如下所示：

let BiChannel {
    e1: world,
    e2: thread,
} = BiChannel::new();

let ws = WorldState {
    ...
    thread_endpoint: thread,
};
std::thread::spawn(threading::handle_life(world));

在此代码段中，threading::handle_life 函数 returns 使用传递的端点（上面代码中的 world）与父线程通信的移动闭包，而父线程线程使用 ws.thread_endpoint 与子线程对话。

我在端点上对 send 的所有调用调用 unwrap，所以如果发送失败，它就会崩溃。果然，我收到了如下所示的运行时错误：

thread 'main' panicked at 'called `Result::unwrap()` on an `Err` value: "SendError(..)"', src/libcore/result.rs:860
note: Run with `RUST_BACKTRACE=1` for a backtrace.

这方面的文档非常少，但我能弄清楚的是，只有当频道关闭时才会发生这种情况。

Answer 1

原来问题出在我忘记把接收消息的代码放到子线程里死循环了，所以它一收到第一条消息就退出了，对应的通道也关闭了.

接收器在尝试通过通道发送时关闭并返回 SendError

Receiver closing and returning a SendError on attempt to send over channel

multithreading

channel

rust