本文整理了Java中org.apache.storm.utils.Utils.exitProcess()方法的一些代码示例，展示了Utils.exitProcess()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Utils.exitProcess()方法的具体详情如下：
包路径：org.apache.storm.utils.Utils
类名称：Utils
方法名：exitProcess

Utils.exitProcess介绍

暂无

代码示例

代码示例来源：origin: apache/storm

@Override
  public void run() {
    exitProcess(1, "Worker died");
  }
};

代码示例来源：origin: apache/storm

@Override
  public void uncaughtException(Thread t, Throwable e) {
    LOG.error("Error when processing event", e);
    Utils.exitProcess(20, "Error when processing an event");
  }
}

代码示例来源：origin: apache/storm

public void uncaughtException(Thread t, Throwable e) {
    LOG.error("Async loop died!", e);
    Utils.exitProcess(1, "Async loop died!");
  }
});

代码示例来源：origin: apache/storm

private StormTimer mkHaltingTimer(String name) {
  return new StormTimer(name, (thread, exception) -> {
    LOG.error("Error when processing event", exception);
    Utils.exitProcess(20, "Error when processing an event");
  });
}

代码示例来源：origin: apache/storm

/**
 * Start log cleanup thread.
 */
public void start() {
  if (intervalSecs != null) {
    LOG.debug("starting log cleanup thread at interval: {}", intervalSecs);
    logviewerCleanupTimer = new StormTimer("logviewer-cleanup", (t, e) -> {
      LOG.error("Error when doing logs cleanup", e);
      Utils.exitProcess(20, "Error when doing log cleanup");
    });
    logviewerCleanupTimer.scheduleRecurring(0, intervalSecs, this);
  } else {
    LOG.warn("The interval for log cleanup is not set. Skip starting log cleanup thread.");
  }
}

代码示例来源：origin: apache/storm

@Override
  public void run() {
    while (running.get()) {
      try {
        Runnable r = queue.take();
        if (r == null) {
          return;
        }
        r.run();
        proccessInc();
      } catch (Throwable t) {
        if (Utils.exceptionCauseIsInstanceOf(InterruptedIOException.class, t)) {
          LOG.info("Event manager interrupted while doing IO");
        } else if (Utils.exceptionCauseIsInstanceOf(ClosedByInterruptException.class, t)) {
          LOG.info("Event manager interrupted while doing NIO");
        } else if (Utils.exceptionCauseIsInstanceOf(InterruptedException.class, t)) {
          LOG.info("Event manager interrupted");
        } else {
          LOG.error("{} Error when processing event", t);
          Utils.exitProcess(20, "Error when processing an event");
        }
      }
    }
  }
};

代码示例来源：origin: apache/storm

} catch (Error error) {
  LOG.error("AsyncLocalizer cleanup failure", error);
  Utils.exitProcess(20, "AsyncLocalizer cleanup failure");

代码示例来源：origin: apache/storm

if (!Utils.exceptionCauseIsInstanceOf(InterruptedException.class, e)) {
  LOG.error("Error when processing event", e);
  Utils.exitProcess(20, "Error when processing an event");

代码示例来源：origin: apache/storm

Utils.exitProcess(13, "Error on initialization of nimbus");

代码示例来源：origin: apache/storm

this.timer = new StormTimer(null, (t, e) -> {
  LOG.error("Error while processing event", e);
  Utils.exitProcess(20, "Error while processing event");
});
this.underlyingScheduler = makeScheduler(conf, inimbus);

代码示例来源：origin: org.apache.storm/storm-core

@Override
  public void run() {
    Utils.exitProcess(1, "Worker died");
  }
};

代码示例来源：origin: org.apache.storm/storm-core

@Override
  public void uncaughtException(Thread t, Throwable e) {
    LOG.error("Error when processing event", e);
    Utils.exitProcess(20, "Error when processing an event");
  }
}

代码示例来源：origin: org.apache.storm/storm-core

public void uncaughtException(Thread t, Throwable e) {
    LOG.error("Async loop died!", e);
    Utils.exitProcess(1, "Async loop died!");
  }
});

代码示例来源：origin: org.apache.storm/storm-core

@Override
  public void run() {
    while (running.get()) {
      try {
        Runnable r = queue.take();
        if (r == null) {
          return;
        }
        r.run();
        proccessInc();
      } catch (Throwable t) {
        if (Utils.exceptionCauseIsInstanceOf(InterruptedIOException.class, t)) {
          LOG.info("Event manager interrupted while doing IO");
        } else if (Utils.exceptionCauseIsInstanceOf(InterruptedException.class, t)) {
          LOG.info("Event manager interrupted");
        } else {
          LOG.error("{} Error when processing event", t);
          Utils.exitProcess(20, "Error when processing an event");
        }
      }
    }
  }
};

代码示例来源：origin: org.apache.storm/storm-core

if (!Utils.exceptionCauseIsInstanceOf(InterruptedException.class, e)) {
  LOG.error("Error when processing event", e);
  Utils.exitProcess(20, "Error when processing an event");