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

Question

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

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 函数返回一个移动闭包，该闭包使用传递的端点(上面代码中的 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.

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

Answer 1

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