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