m_writeHandlers = WriteHandler.create(NIOreceiver.getWriterThreads()); m_readHandlers = ReadHandler.create(NIOreceiver.getReaderThreads(), this);
m_writeHandlers = WriteHandler.create(getWriterThreads(), thread_group); m_readHandlers = ReadHandler.create(getReaderThreads(), this, thread_group);
   protected void init()      throws Exception   {      TCP_NIO NIOreceiver = (TCP_NIO)receiver;      // use directExector if max thread pool size is less than or equal to zero.      if(NIOreceiver.getProcessorMaxThreads() <= 0) {         m_requestProcessors = new DirectExecutor();      }      else      {         // Create worker thread pool for processing incoming buffers         PooledExecutor requestProcessors = new PooledExecutor(new BoundedBuffer(NIOreceiver.getProcessorQueueSize()), NIOreceiver.getProcessorMaxThreads());          requestProcessors.setThreadFactory(new ThreadFactory() {              public Thread newThread(Runnable runnable) {                  return new Thread(Util.getGlobalThreadGroup(), runnable);              }          });         requestProcessors.setMinimumPoolSize(NIOreceiver.getProcessorMinThreads());         requestProcessors.setKeepAliveTime(NIOreceiver.getProcessorKeepAliveTime());         requestProcessors.waitWhenBlocked();         requestProcessors.createThreads(NIOreceiver.getProcessorThreads());         m_requestProcessors = requestProcessors;      }      m_writeHandlers = WriteHandler.create(NIOreceiver.getWriterThreads());      m_readHandlers = ReadHandler.create(NIOreceiver.getReaderThreads(), this);   }