docs: private void startup() throws InterruptedException {
          try {
              arbitrateEventService.mainStemEvent().await(pipelineId);
          } catch (Throwable e) {
              if (isInterrupt(e)) {
                  logger.info("INFO ## this node is interrupt", e);
              } else {
                  logger.warn("WARN ## this node is crashed.", e);
              }
              arbitrateEventService.mainStemEvent().release(pipelineId);
              return;
          }
  
          executor = Executors.newFixedThreadPool(2); // 启动两个线程
          // 启动selector
          otterSelector = otterSelectorFactory.getSelector(pipelineId); // 获取对应的selector
          otterSelector.start();
  
          canStartSelector.set(false);// 初始化为false
          startProcessTermin();
          startProcessSelect();
  
          isStart = true;
      }