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

ScheduledExecutorService.shutdownNow介绍

暂无

代码示例

代码示例来源：origin: prestodb/presto

@PreDestroy
public void stop()
{
  coreExecutor.shutdownNow();
  updateScheduledExecutor.shutdownNow();
  errorScheduledExecutor.shutdownNow();
}

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

void stop() {
  executor.shutdown();
  try {
    if (!executor.awaitTermination(1, TimeUnit.SECONDS)) {
      executor.shutdownNow();
    }
  } catch (InterruptedException ignored) {
    executor.shutdownNow();
  }
}

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

@Override
public void shutdown() throws SchedulerException {
  logger.info("Shutting down DefaultScheduler ....");
  jobLock.unlockJobEngine();
  initialized = false;
  hasStarted = false;
  try {
    fetcherPool.shutdownNow();//interrupt
    fetcherPool.awaitTermination(1, TimeUnit.MINUTES);
  } catch (InterruptedException e) {
    //ignore it
    logger.warn("InterruptedException is caught when shutting down job fetcher.", e);
  }
  try {
    jobPool.shutdownNow();//interrupt
    jobPool.awaitTermination(1, TimeUnit.MINUTES);
  } catch (InterruptedException e) {
    //ignore it
    logger.warn("InterruptedException is caught when shutting down job pool.", e);
  }
}

代码示例来源：origin: prestodb/presto

@PreDestroy
public synchronized void stop()
{
  closed = true;
  executor.shutdownNow();
  splitMonitorExecutor.shutdownNow();
}

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

@Override
public void shutdown() {
  executor.shutdown();
  try {
    if (!executor.awaitTermination(2, TimeUnit.SECONDS)) {
      executor.shutdownNow();
    }
  } catch (InterruptedException ie) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
  }
}

代码示例来源：origin: wildfly/wildfly

globalThreadPool.shutdownNow();
try {
 if (!globalThreadPool.awaitTermination(time, unit)) {
   globalThreadPool.shutdownNow();
   ActiveMQClientLogger.LOGGER.unableToProcessGlobalThreadPoolIn10Sec();
globalScheduledThreadPool.shutdownNow();
try {
 if (!globalScheduledThreadPool.awaitTermination(time, unit)) {
   globalScheduledThreadPool.shutdownNow();
   ActiveMQClientLogger.LOGGER.unableToProcessScheduledlIn10Sec();

代码示例来源：origin: prestodb/presto

@PreDestroy
public void stop()
{
  queryTracker.stop();
  queryManagementExecutor.shutdownNow();
  queryExecutor.shutdownNow();
}

代码示例来源：origin: spotify/helios

@Override
protected void shutDown() throws Exception {
 zkWriterExecutor.shutdownNow();
 zkWriterExecutor.awaitTermination(1, TimeUnit.MINUTES);
}

代码示例来源：origin: baidu/uid-generator

/**
 * Shutdown executors
 */
public void shutdown() {
  if (!bufferPadExecutors.isShutdown()) {
    bufferPadExecutors.shutdownNow();
  }
  if (bufferPadSchedule != null && !bufferPadSchedule.isShutdown()) {
    bufferPadSchedule.shutdownNow();
  }
}

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

public void shutdown() {
    LOG.debug("Shutting down WaterMarkEventGenerator");
    executorService.shutdown();

    try {
      if (!executorService.awaitTermination(2, TimeUnit.SECONDS)) {
        executorService.shutdownNow();
      }
    } catch (InterruptedException ie) {
      executorService.shutdownNow();
      Thread.currentThread().interrupt();
    }
  }
}

代码示例来源：origin: apache/incubator-druid

/**
 * Shuts down the queue.
 */
@LifecycleStop
public void stop()
{
 giant.lock();
 try {
  tasks.clear();
  taskFutures.clear();
  active = false;
  managerExec.shutdownNow();
  storageSyncExec.shutdownNow();
  managementMayBeNecessary.signalAll();
 }
 finally {
  giant.unlock();
 }
}

代码示例来源：origin: alibaba/jstorm

@Override
public void shutdown() {
  executor.shutdown();
  try {
    if (!executor.awaitTermination(2, TimeUnit.SECONDS)) {
      executor.shutdownNow();
    }
  } catch (InterruptedException ie) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
  }
}

代码示例来源：origin: prestodb/presto

@AfterMethod
public void tearDown()
{
  executor.shutdownNow();
  scheduledExecutor.shutdownNow();
}

代码示例来源：origin: OpenHFT/Chronicle-Queue

@Override
  public void close() {
    THREAD_LOCAL_CLEANER_EXECUTOR_SERVICE.shutdownNow();
    try {
      THREAD_LOCAL_CLEANER_EXECUTOR_SERVICE.awaitTermination(1, TimeUnit.SECONDS);
    } catch (InterruptedException ignore) {

    }
  }
}

代码示例来源：origin: prestodb/presto

@AfterMethod
public void tearDown()
{
  executor.shutdownNow();
  scheduledExecutor.shutdownNow();
}

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

private void closeFlushScheduler() {
    if (flushScheduler != null) {
      flushScheduler.shutdown();
      try {
        if (!flushScheduler.awaitTermination(2, TimeUnit.SECONDS)) {
          flushScheduler.shutdownNow();
        }
      } catch (InterruptedException ie) {
        // (Re-)Cancel if current thread also interrupted
        flushScheduler.shutdownNow();
        // Preserve interrupt status
        Thread.currentThread().interrupt();
      }
    }
  }
}

代码示例来源：origin: prestodb/presto

@AfterMethod
public void tearDown()
{
  executor.shutdownNow();
  scheduledExecutor.shutdownNow();
}

代码示例来源：origin: azkaban/azkaban

public void shutdown() {
 this.scheduler.shutdown();
 try {
  if (!this.scheduler.awaitTermination(60, TimeUnit.SECONDS)) {
   this.scheduler.shutdownNow();
  }
 } catch (final InterruptedException ex) {
  this.scheduler.shutdownNow();
  Thread.currentThread().interrupt();
 }
}

代码示例来源：origin: prestodb/presto

@AfterClass(alwaysRun = true)
public void tearDown()
{
  if (scheduler != null) {
    scheduler.shutdownNow();
    scheduler = null;
  }
  if (pageBufferClientCallbackExecutor != null) {
    pageBufferClientCallbackExecutor.shutdownNow();
    pageBufferClientCallbackExecutor = null;
  }
}

代码示例来源：origin: spotify/helios

@Override
protected void shutDown() throws Exception {
 if (future != null) {
  future.cancel(true);
 }
 executorService.shutdownNow();
 executorService.awaitTermination(1, DAYS);
}