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

ScheduledFuture.isCancelled介绍

暂无

代码示例

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

if (keyGeneratorTask != null && !keyGeneratorTask.isCancelled()) {
  keyGeneratorTask.cancel(false);

代码示例来源：origin: Cool-Coding/remote-desktop-control

private void check() throws IOException{
  if(isUnderControlled()){
    if(tasks.get(heartBeatTask)!=null && !tasks.get(heartBeatTask).isCancelled()){
      tasks.get(heartBeatTask).cancel(true);
    }
    if (tasks.get(screenSnapShotTask)==null || tasks.get(screenSnapShotTask).isCancelled()){
      tasks.put(screenSnapShotTask,startScreenSnapShotTask());
    }
  }else{
    if(tasks.get(screenSnapShotTask)!=null && !tasks.get(screenSnapShotTask).isCancelled()){
      tasks.get(screenSnapShotTask).cancel(true);
    }
    if (tasks.get(heartBeatTask)==null || tasks.get(heartBeatTask).isCancelled()){
      tasks.put(heartBeatTask,startHeartBeatTask());
    }
  }
}

代码示例来源：origin: org.ow2.petals/petals-bc-gateway

if (polling != null && !polling.isCancelled()) {
  scheduleNextPolling(nextDelay, accel, maxDelay);

代码示例来源：origin: NationalSecurityAgency/timely

@Override
  public void onError(Session session, Throwable t) {
    super.onError(session, t);
    LOG.error(t.getMessage(), t);
    Exception e = new TimelyException(HttpResponseStatus.INTERNAL_SERVER_ERROR.code(), t.getMessage(), "");
    WsRelayHandler.sendErrorResponse(ctx, HttpResponseStatus.INTERNAL_SERVER_ERROR, e);
    if (!ping.isCancelled()) {
      ping.cancel(false);
    }
  }
}

代码示例来源：origin: NationalSecurityAgency/timely

@Override
public void onClose(Session session, CloseReason reason) {
  super.onClose(session, reason);
  if (!reason.getCloseCode().equals(CloseReason.CloseCodes.NORMAL_CLOSURE)) {
    LOG.error("Abnormal close: " + reason.getReasonPhrase());
    Exception e = new TimelyException(HttpResponseStatus.INTERNAL_SERVER_ERROR.code(), reason.getReasonPhrase(),
        "");
    WsRelayHandler.sendErrorResponse(ctx, HttpResponseStatus.INTERNAL_SERVER_ERROR, e);
  }
  if (!ping.isCancelled()) {
    ping.cancel(false);
  }
}

代码示例来源：origin: org.jboss.aerogear/aerogear-simplepush-server-netty

private void processUnacked(final String uaid, final SockJsSessionContext session, final long delay) {
  final Set<Ack> unacked = simplePushServer.getUnacknowledged(uaid);
  if (unacked.isEmpty()) {
    if (ackJobFuture != null && !ackJobFuture.isCancelled()) {
      ackJobFuture.cancel(false);
      logger.info("Cancelled Re-Acknowledger job");
    }
  } else if (ackJobFuture == null) {
    ackJobFuture = session.getContext().executor().scheduleAtFixedRate(new Runnable() {
      @Override
      public void run() {
        final Set<Ack> unacked = simplePushServer.getUnacknowledged(uaid);
        logger.info("Resending " + unacked);
        session.send(toJson(new NotificationMessageImpl(unacked)));
      }
    },
        delay,
        simplePushServer.config().acknowledmentInterval(),
        TimeUnit.MILLISECONDS);
  }
}

代码示例来源：origin: aerogear/aerogear-simplepush-server

private void processUnacked(final String uaid, final SockJsSessionContext session, final long delay) {
  final Set<Ack> unacked = simplePushServer.getUnacknowledged(uaid);
  if (unacked.isEmpty()) {
    if (ackJobFuture != null && !ackJobFuture.isCancelled()) {
      ackJobFuture.cancel(false);
      logger.info("Cancelled Re-Acknowledger job");
    }
  } else if (ackJobFuture == null) {
    ackJobFuture = session.getContext().executor().scheduleAtFixedRate(new Runnable() {
      @Override
      public void run() {
        final Set<Ack> unacked = simplePushServer.getUnacknowledged(uaid);
        logger.info("Resending " + unacked);
        session.send(toJson(new NotificationMessageImpl(unacked)));
      }
    },
        delay,
        simplePushServer.config().acknowledmentInterval(),
        TimeUnit.MILLISECONDS);
  }
}

代码示例来源：origin: org.apache.pulsar/pulsar-client-original

if (keyGeneratorTask != null && !keyGeneratorTask.isCancelled()) {
  keyGeneratorTask.cancel(false);