По умолчаниюEventExecutor поделился между каналами

Question

В приведенном ниже коде я представил DefaultEventExecutor, где выполняется фактическая вставка базы данных. Я сомневаюсь, что это действительно правильный путь, потому что в качестве Каналов будет столько DefaultEventExecutors. Может ли кто-нибудь помочь мне в этом?

public class SocketChannelInitializer extends ChannelInitializer<SocketChannel> { 
final static Logger logger = Logger.getLogger("com.my.snapshot"); 
public ComboPooledDataSource cpds; 

public SocketChannelInitializer(ComboPooledDataSource cpds) { 
    this.cpds = cpds; 

} 


@Override 
public void initChannel(SocketChannel ch) throws Exception { 
    if (logger.isDebugEnabled()) { 
     logger.debug("New SocketChannel connection from " + ch.remoteAddress()); 

    } 

    ChannelPipeline pipeline = ch.pipeline(); 
    EventExecutor e1 = new DefaultEventExecutor(); 
    // and then business logic. 

    pipeline.addLast("readTimeoutHandler", new ReadTimeoutHandler(200)); 
    pipeline.addLast("decoder", new MyPacketHeaderDecoder()); 

    /** 
    * Inserting in DB happens in single Thread (e1) 
    * 
    */ 
    pipeline.addLast(e1, "logic", new PacketDatabaseHandler(cpds)); 

} 
} 

Answer 1

Вы должны создать один экземпляр DefaultEventExecutorGroup и использовать тот же экземпляр в методе initChannel (....). В противном случае это не имеет никакого смысла, поскольку у вас будет столько потоков, как Channel.s