m_requestProcessors = new PooledExecutor(new BoundedBuffer(NIOreceiver.getProcessorQueueSize()), NIOreceiver.getProcessorMaxThreads()); m_requestProcessors.setMinimumPoolSize(NIOreceiver.getProcessorMinThreads()); m_requestProcessors.setKeepAliveTime(NIOreceiver.getProcessormKeepAliveTime()); m_requestProcessors.waitWhenBlocked(); m_requestProcessors.createThreads(NIOreceiver.getProcessorThreads());
if(NIOreceiver.getProcessorMaxThreads() <= 0) { m_requestProcessors = new DirectExecutor(); } else {  PooledExecutor requestProcessors = new PooledExecutor(new BoundedBuffer(NIOreceiver.getProcessorQueueSize()), NIOreceiver.getProcessorMaxThreads()); requestProcessors.setMinimumPoolSize(NIOreceiver.getProcessorMinThreads()); requestProcessors.setKeepAliveTime(NIOreceiver.getProcessormKeepAliveTime()); requestProcessors.waitWhenBlocked(); requestProcessors.createThreads(NIOreceiver.getProcessorThreads()); m_requestProcessors = requestProcessors; }
   protected void init()      throws Exception   {      TCP_NIO NIOreceiver = (TCP_NIO)receiver;      // Create worker thread pool for processing incoming buffers      m_requestProcessors = new PooledExecutor(new BoundedBuffer(NIOreceiver.getProcessorQueueSize()), NIOreceiver.getProcessorMaxThreads());      m_requestProcessors.setMinimumPoolSize(NIOreceiver.getProcessorMinThreads());      m_requestProcessors.setKeepAliveTime(NIOreceiver.getProcessormKeepAliveTime());      m_requestProcessors.waitWhenBlocked();      m_requestProcessors.createThreads(NIOreceiver.getProcessorThreads());      m_writeHandlers = WriteHandler.create(NIOreceiver.getWriterThreads());      m_readHandlers = new ReadHandler[NIOreceiver.getReaderThreads()];      for (int i = 0; i < m_readHandlers.length; i++)         m_readHandlers[i] = new ReadHandler();   }