code: public void startup() throws InterruptedException {
          final int maxCacheConnectionPerThread = serverConfig.getMaxConnections() / processors.length;
          logger.debug("start {} Processor threads",processors.length);
          for (int i = 0; i < processors.length; i++) {
              processors[i] = new Processor(handlerFactory, stats, maxRequestSize, maxCacheConnectionPerThread);
              Utils.newThread("jafka-processor-" + i, processors[i], false).start();
          }
          Utils.newThread("jafka-acceptor", acceptor, false).start();
          acceptor.awaitStartup();
      }
docs: Start the socket server and waiting for finished
  
  @throws InterruptedException thread interrupted