private long closeIOThreadPool()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/LogProducer.java [491:502]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  private long closeIOThreadPool(long timeoutMs) throws InterruptedException, ProducerException {
    long startMs = System.currentTimeMillis();
    ioThreadPool.shutdown();
    if (ioThreadPool.awaitTermination(timeoutMs, TimeUnit.MILLISECONDS)) {
      LOGGER.debug("The ioThreadPool is terminated");
    } else {
      LOGGER.warn("The ioThreadPool is not fully terminated");
      throw new ProducerException("the ioThreadPool is not fully terminated");
    }
    long nowMs = System.currentTimeMillis();
    return Math.max(0, timeoutMs - nowMs + startMs);
  }