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

ForkJoinPool.shutdownNow介绍

[英]Possibly attempts to cancel and/or stop all tasks, and reject all subsequently submitted tasks. Invocation has no effect on execution state if this is the #commonPool(), and no additional effect if already shut down. Otherwise, tasks that are in the process of being submitted or executed concurrently during the course of this method may or may not be rejected. This method cancels both existing and unexecuted tasks, in order to permit termination in the presence of task dependencies. So the method always returns an empty list (unlike the case for some other Executors).
[中]可能会尝试取消和/或停止所有任务，并拒绝所有随后提交的任务。如果这是#commonPool（），则调用对执行状态没有影响，如果已经关闭，则不会产生其他影响。否则，在本方法过程中同时提交或执行的任务可能会被拒绝，也可能不会被拒绝。此方法取消现有和未执行的任务，以允许在存在任务依赖项时终止。因此，该方法总是返回一个空列表（与某些其他执行器的情况不同）。

代码示例

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

synchronized void shutDownNow() {
  if (pool == null || pool.isShutdown()) {
   return;
  }
  pool.shutdownNow();
 }
}

代码示例来源：origin: fengjiachun/Jupiter

@Override
  public void shutdown() {
    logger.warn("ForkJoinPoolExecutorFactory#{} shutdown.", executor);
    executor.shutdownNow();
  }
};

代码示例来源：origin: fengjiachun/Jupiter

@Override
  public void shutdown() {
    logger.warn("ForkJoinPoolExecutorFactory#{} shutdown.", executor);
    executor.shutdownNow();
  }
};

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

closeGirdTables(builderList);
sw.stop();
builderPool.shutdownNow();
logger.info("Dogged Cube Build2 end, totally took " + sw.elapsedMillis() + " ms");
logger.info("Dogged Cube Build2 return");

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

@Override
 public void run() {
  if (!dfsUsedSaved) {
   saveDfsUsed();
   addReplicaThreadPool.shutdownNow();
  }
 }
};

代码示例来源：origin: org.junit.platform/junit-platform-engine

@Override
public void close() {
  forkJoinPool.shutdownNow();
}

代码示例来源：origin: com.oracle.substratevm/svm

private void shutdownPoolSafe() {
  if (imageBuildPool != null) {
    imageBuildPool.shutdownNow();
  }
}

代码示例来源：origin: de.unijena.bioinf/jjobs-core

List<Runnable> shutdownNow() {
  return executor.shutdownNow();
}

代码示例来源：origin: org.jupiter-rpc/jupiter-all

@Override
  public void shutdown() {
    logger.warn("ForkJoinPoolExecutorFactory#{} shutdown.", executor);
    executor.shutdownNow();
  }
};

代码示例来源：origin: org.jupiter-rpc/jupiter-rpc

@Override
  public void shutdown() {
    logger.warn("ForkJoinPoolExecutorFactory#{} shutdown.", executor);
    executor.shutdownNow();
  }
};

代码示例来源：origin: co.paralleluniverse/quasar-core

@Override
  public void shutdownNow() {
    fjPool().shutdownNow();
  }
}

代码示例来源：origin: io.projectreactor.addons/reactor-extra

@Override
public void dispose() {
  if (disposeScheduler) {
    scheduler.dispose();
  }
  pool.shutdownNow();
}

代码示例来源：origin: PreferredAI/venom

/**
 * Interrupts crawler, fetcher and worker threads.
 *
 * @throws Exception if any resources throws an exception on close.
 */
private void interrupt() throws Exception {
 exitWhenDone.set(true);
 crawlerThread.interrupt();
 threadPool.shutdownNow();
 Exception cachedException = null;
 for (final Interruptible interruptible : new Interruptible[]{workerManager, fetcher}) {
  try {
   interruptible.interruptAndClose();
  } catch (final Exception e) {
   if (cachedException != null) {
    cachedException.addSuppressed(e);
   } else {
    cachedException = e;
   }
  }
 }
 if (cachedException != null) {
  throw cachedException;
 }
}

代码示例来源：origin: org.talend.sdk.component/documentation

@Override
  public void close() {
    executorService.shutdown();
    tasks.forEach(it -> {
      try {
        it.get();
      } catch (final InterruptedException e) {
        Thread.currentThread().interrupt();
      } catch (final ExecutionException e) {
        final Throwable cause = e.getCause();
        errors.add(cause);
        throw new IllegalStateException(cause);
      }
    });
    try {
      if (!executorService.awaitTermination(5, SECONDS)) {
        executorService.shutdownNow();
      }
    } catch (final InterruptedException e) {
      Thread.currentThread().interrupt();
    }
    if (!errors.isEmpty()) {
      throw new IllegalStateException(errors.stream().map(Throwable::getMessage).collect(joining("\n")));
    }
  }
}

代码示例来源：origin: PreferredAI/venom

} catch (InterruptedException e) {
 LOGGER.warn("The producer thread joining has been interrupted", e);
 threadPool.shutdownNow();
 Thread.currentThread().interrupt();

代码示例来源：origin: chocoteam/choco-solver

e.printStackTrace();
forkJoinPool.shutdownNow();
getSolverTerminated().set(false);// otherwise, solver.isStopCriterionMet() always returns true
if(getSolutionFound().get() && models.get(0).getResolutionPolicy()!=ResolutionPolicy.SATISFACTION) {

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

closeGirdTables(builderList);
sw.stop();
builderPool.shutdownNow();
logger.info("Dogged Cube Build2 end, totally took " + sw.elapsedMillis() + " ms");
logger.info("Dogged Cube Build2 return");

代码示例来源：origin: com.oracle.substratevm/svm

} catch (InterruptImageBuilding e) {
  if (analysisExecutor != null) {
    analysisExecutor.shutdownNow();
    compilationExecutor.shutdownNow();