净资产并发

Question

我正在实施，ChannelInboundHandlerAdapter并且对并发性有疑问。是否有必要使其线程安全？我的意思是我必须为每个客户端的会话存储一些状态。

public class Impl extends ChannelInboundHandlerAdapter{
    private List<Integer> someState;
    //

    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        int size = someState.size();  //Should I worry about memory consitency here?
        //...
    }
}

关键是，如果从一个请求到channelRead另一个请求，该方法是由不同的线程调用的，那么我将不得不放置一些内存障碍。

有必要吗？还是Netty自己照顾？

Answer 1

对于Netty 4.x

定义明确的线程模型

尽管尝试修复3.5中的不一致，但3.x中没有定义明确的线程模型。4.0定义了一个严格的线程模型，可以帮助用户编写ChannelHandler而不用过多担心线程安全。

• Netty绝不会同时调用ChannelHandler的方法，除非使用@Sharable注释ChannelHandler。这与处理程序方法的类型无关-入站，出站或生命周期事件处理程序方法。
  • 用户不再需要同步入站或出站事件处理程序方法。
  • 4.0不允许多次添加ChannelHandler，除非使用@Sharable注释。
• Netty进行的每个ChannelHandler方法调用之间总是存在事前发生的关系。
  • 用户无需定义易失性字段即可保留处理程序的状态。
• 用户在将处理程序添加到ChannelPipeline时可以指定EventExecutor。
  • 如果指定，则始终由指定的EventExecutor调用ChannelHandler的处理程序方法。
  • 如果未指定，则处理程序方法始终由与其关联的Channel注册到的EventLoop调用。
• 分配给处理程序或通道的EventExecutor和EventLoop始终是单线程的。
  • 处理程序方法将始终由同一线程调用。
  • 如果指定了多线程EventExecutor或EventLoop，则将首先选择一个线程，然后将使用所选择的线程，直到注销为止。
  • 如果在同一管道中的两个处理程序被分配了不同的EventExecutor，则它们将同时被调用。如果多个处理程序访问共享数据，即使共享数据仅由同一管道中的处理程序访问，用户也必须注意线程安全。
• 添加到ChannelFuture的ChannelFutureListener始终由分配给将来的关联Channel的EventLoop线程调用。
• ChannelHandlerInvoker可用于控制Channel事件的顺序。DefaultChannelHandlerInvoker将立即执行EventLoop线程中的事件，并将其他线程中的事件作为EventExecutor上的Runnable对象执行。请参阅以下示例，以了解与EventLoop线程和其他线程中的Channel进行交互时可能产生的含义。

（强调是我的）