netty - 在netty中给自己发消息

Question

我想向netty的线程分派一个工作，如果我不这样做，我必须关心线程同步，因为该工作不是由从客户端收到的消息触发的。我发现 ChannelPipeline 有一个方法 sendUpstream 符合我的要求，但我无法获取所有 ChannelPipeline 的对象。我是说：

// code in thread which not belong to netty's thread
for(all pipeline)
    pipeline.sendUpstream(my_pseudo_message)

MyChannelHander.messageReceive() {
    //code to deal with my_pseudo_message
}

Answer 1

如果您想在 Netty 的 Worker-Thread 中执行某些操作，请使用：

channel.getPipeline().execute(new Runnable() {...});