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

ScheduledFuture.isCancelled介绍

暂无

代码示例

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

public static void cancelScheduledFuture(ScheduledFuture<?> scheduledFuture) {
    ScheduledFuture<?> future = scheduledFuture;
    if (future != null && !future.isCancelled()) {
      future.cancel(true);
    }
  }
}

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

public static void cancelScheduledFuture(ScheduledFuture<?> scheduledFuture) {
    ScheduledFuture<?> future = scheduledFuture;
    if (future != null && !future.isCancelled()) {
      future.cancel(true);
    }
  }
}

代码示例来源：origin: Bigkoo/Android-PickerView

public void cancelFuture() {
  if (mFuture != null && !mFuture.isCancelled()) {
    mFuture.cancel(true);
    mFuture = null;
  }
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public boolean isCancelled() {
  synchronized (this.triggerContextMonitor) {
    return obtainCurrentFuture().isCancelled();
  }
}

代码示例来源：origin: gzu-liyujiang/AndroidPicker

private void cancelFuture() {
  if (mFuture != null && !mFuture.isCancelled()) {
    mFuture.cancel(true);
    mFuture = null;
  }
}

代码示例来源：origin: Graylog2/graylog2-server

private void cancel(@Nullable ScheduledFuture<?> future) {
  if (future != null && !future.isCancelled()) {
    if (!future.cancel(true)) {
      LOG.warn("Could not cancel refresh job");
    }
  }
}

代码示例来源：origin: Graylog2/graylog2-server

/**
 * Cancel the polling job for the given {@link ScheduledFuture}.
 * @param future polling job future
 */
private void cancel(@Nullable ScheduledFuture<?> future) {
  if (future != null && !future.isCancelled()) {
    if (!future.cancel(true)) {
      LOG.warn("Couldn't cancel field type update job");
    }
  }
}

代码示例来源：origin: igniterealtime/Openfire

/**
 * Stop periodically checking the plugin directory.
 */
public void stopMonitoring()
{
  if ( monitorTaskScheduledFuture != null && !monitorTaskScheduledFuture.isDone() )
  {
    // Cancel, with an interrupt if this task has been cancelled before.
    monitorTaskScheduledFuture.cancel( monitorTaskScheduledFuture.isCancelled() );
  }
}

代码示例来源：origin: oracle/helidon

@Override
public boolean cancel(boolean mayInterruptIfRunning) {
  if (future != null) {
    if (!future.isDone() && !future.isCancelled()) {
      return future.cancel(mayInterruptIfRunning);
    }
  }
  return false;
}

代码示例来源：origin: org.springframework/spring-context

@Override
public boolean isCancelled() {
  synchronized (this.triggerContextMonitor) {
    return obtainCurrentFuture().isCancelled();
  }
}

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

/**
 * Start the scan task for long-idle connections.
 */
private synchronized void startScan() {
  if (scanTaskFuture == null
    || scanTaskFuture.isCancelled()
    || scanTaskFuture.isDone()) {
    scanTaskFuture = TIMER.scheduleAtFixedRate(
      new ScanIdleConnectionTask(this), 10, 30, TimeUnit.SECONDS);
  }
}

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

@Override
public Date getNextRunTime(LastExecution lastExecution, Date taskScheduledTime) {
  Date nextRunTime = trigger.getNextRunTime(lastExecution, taskScheduledTime);
  final ScheduledFuture future = this.future;
  if (future != null && future.isCancelled()) {
    nextRunTime = null;
  }
  return nextRunTime;
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public void run() {
  Date actualExecutionTime = new Date();
  super.run();
  Date completionTime = new Date();
  synchronized (this.triggerContextMonitor) {
    Assert.state(this.scheduledExecutionTime != null, "No scheduled execution");
    this.triggerContext.update(this.scheduledExecutionTime, actualExecutionTime, completionTime);
    if (!obtainCurrentFuture().isCancelled()) {
      schedule();
    }
  }
}

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

private void stopExtendingTtl() {
  if (!ttlExtendTaskExecutor.isShutdown()) {
    ttlExtendTaskExecutor.shutdown();
  }
  if (ttlExtendingFuture != null && !ttlExtendingFuture.isCancelled()) {
    logger.debug("Cancelling extending ttl...");
    ttlExtendingFuture.cancel(true);
  }
  closeSilently(extendingApiClient);
}

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

private void recycle() {
  readOpCount = -1;
  if (task != null && !task.isDone() && !task.isCancelled()) {
    try {
      task.cancel(false);
    } catch (Throwable th) {
      log.debug("[{}]Failed to cancle task for read-callback for {}-{}", name, ledgerId, entryId);
    }
  }
  readEntryCallback = null;
  readEntriesCallback = null;
  ledgerId = -1;
  entryId = -1;
  name = null;
  readCompleted = FALSE;
  recyclerHandle.recycle(this);
}

代码示例来源：origin: org.springframework/spring-context

@Override
public void run() {
  Date actualExecutionTime = new Date();
  super.run();
  Date completionTime = new Date();
  synchronized (this.triggerContextMonitor) {
    Assert.state(this.scheduledExecutionTime != null, "No scheduled execution");
    this.triggerContext.update(this.scheduledExecutionTime, actualExecutionTime, completionTime);
    if (!obtainCurrentFuture().isCancelled()) {
      schedule();
    }
  }
}

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

/**
 * @return true if the instance is heartbeating; false otherwise
 */
public boolean isHeartbeating() {
  readLock.lock();
  try {
    return heartbeatSenderFuture != null && !heartbeatSenderFuture.isCancelled();
  } finally {
    readLock.unlock("isHeartbeating");
  }
}

代码示例来源：origin: google/guava

public void testServiceStartStop() throws Exception {
 NullService service = new NullService();
 service.startAsync().awaitRunning();
 assertFalse(future.isDone());
 service.stopAsync().awaitTerminated();
 assertTrue(future.isCancelled());
}

代码示例来源：origin: google/guava

public void testListeningDecorator_cancelled() throws Exception {
 ScheduledThreadPoolExecutor delegate = new ScheduledThreadPoolExecutor(1);
 BlockingQueue<?> delegateQueue = delegate.getQueue();
 ListeningScheduledExecutorService service = listeningDecorator(delegate);
 ListenableFuture<?> future;
 ScheduledFuture<?> delegateFuture;
 Runnable runnable =
   new Runnable() {
    @Override
    public void run() {}
   };
 future = service.schedule(runnable, 5, TimeUnit.MINUTES);
 future.cancel(true);
 assertTrue(future.isCancelled());
 delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
 assertTrue(delegateFuture.isCancelled());
 delegateQueue.clear();
 future = service.scheduleAtFixedRate(runnable, 5, 5, TimeUnit.MINUTES);
 future.cancel(true);
 assertTrue(future.isCancelled());
 delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
 assertTrue(delegateFuture.isCancelled());
 delegateQueue.clear();
 future = service.scheduleWithFixedDelay(runnable, 5, 5, TimeUnit.MINUTES);
 future.cancel(true);
 assertTrue(future.isCancelled());
 delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
 assertTrue(delegateFuture.isCancelled());
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void scheduleAndCancelHeartbeat() throws Exception {
  ScheduledFuture<?> task = mock(ScheduledFuture.class);
  willReturn(task).given(this.taskScheduler).schedule(any(Runnable.class), any(Date.class));
  this.session.setActive(true);
  this.session.scheduleHeartbeat();
  verify(this.taskScheduler).schedule(any(Runnable.class), any(Date.class));
  verifyNoMoreInteractions(this.taskScheduler);
  given(task.isCancelled()).willReturn(false);
  given(task.cancel(false)).willReturn(true);
  this.session.cancelHeartbeat();
  verify(task).cancel(false);
  verifyNoMoreInteractions(task);
}