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

Instant.plusSeconds介绍

[英]Returns a copy of this instant with the specified duration in seconds added.

This instance is immutable and unaffected by this method call.
[中]返回此瞬间的副本，添加指定的持续时间（秒）。
此实例是不可变的，不受此方法调用的影响。

代码示例

代码示例来源：origin: googleapis/google-cloud-java

@Override
 public void run() {
  try {
   if (ackHandler
     .totalExpiration
     .plusSeconds(messageDeadlineSeconds.get())
     .isBefore(now())) {
    // Message expired while waiting. We don't extend these messages anymore,
    // so it was probably sent to someone else. Don't work on it.
    // Don't nack it either, because we'd be nacking someone else's message.
    ackHandler.forget();
    return;
   }
   receiver.receiveMessage(message, consumer);
  } catch (Exception e) {
   response.setException(e);
  }
 }
});

代码示例来源：origin: googleapis/google-cloud-java

@InternalApi
void extendDeadlines() {
 int extendSeconds = getMessageDeadlineSeconds();
 List<PendingModifyAckDeadline> modacks = new ArrayList<>();
 PendingModifyAckDeadline modack = new PendingModifyAckDeadline(extendSeconds);
 Instant now = now();
 Instant extendTo = now.plusSeconds(extendSeconds);
 for (Map.Entry<String, AckHandler> entry : pendingMessages.entrySet()) {
  String ackId = entry.getKey();
  Instant totalExpiration = entry.getValue().totalExpiration;
  if (totalExpiration.isAfter(extendTo)) {
   modack.ackIds.add(ackId);
   continue;
  }
  // forget removes from pendingMessages; this is OK, concurrent maps can
  // handle concurrent iterations and modifications.
  entry.getValue().forget();
  if (totalExpiration.isAfter(now)) {
   int sec = Math.max(1, (int) now.until(totalExpiration, ChronoUnit.SECONDS));
   modacks.add(new PendingModifyAckDeadline(sec, ackId));
  }
 }
 logger.log(Level.FINER, "Sending {0} modacks", modack.ackIds.size() + modacks.size());
 modacks.add(modack);
 List<String> acksToSend = Collections.emptyList();
 ackProcessor.sendAckOperations(acksToSend, modacks);
}

代码示例来源：origin: org.threeten/threetenbp

/**
 * Returns a copy of this instant with the specified duration in seconds subtracted.
 * <p>
 * This instance is immutable and unaffected by this method call.
 *
 * @param secondsToSubtract  the seconds to subtract, positive or negative
 * @return an {@code Instant} based on this instant with the specified seconds subtracted, not null
 * @throws DateTimeException if the result exceeds the maximum or minimum instant
 * @throws ArithmeticException if numeric overflow occurs
 */
public Instant minusSeconds(long secondsToSubtract) {
  if (secondsToSubtract == Long.MIN_VALUE) {
    return plusSeconds(Long.MAX_VALUE).plusSeconds(1);
  }
  return plusSeconds(-secondsToSubtract);
}

代码示例来源：origin: ThreeTen/threetenbp

/**
 * Returns a copy of this instant with the specified duration in seconds subtracted.
 * <p>
 * This instance is immutable and unaffected by this method call.
 *
 * @param secondsToSubtract  the seconds to subtract, positive or negative
 * @return an {@code Instant} based on this instant with the specified seconds subtracted, not null
 * @throws DateTimeException if the result exceeds the maximum or minimum instant
 * @throws ArithmeticException if numeric overflow occurs
 */
public Instant minusSeconds(long secondsToSubtract) {
  if (secondsToSubtract == Long.MIN_VALUE) {
    return plusSeconds(Long.MAX_VALUE).plusSeconds(1);
  }
  return plusSeconds(-secondsToSubtract);
}

代码示例来源：origin: ThreeTen/threetenbp

/**
 * {@inheritDoc}
 * @throws DateTimeException {@inheritDoc}
 * @throws ArithmeticException {@inheritDoc}
 */
@Override
public Instant plus(long amountToAdd, TemporalUnit unit) {
  if (unit instanceof ChronoUnit) {
    switch ((ChronoUnit) unit) {
      case NANOS: return plusNanos(amountToAdd);
      case MICROS: return plus(amountToAdd / 1000000, (amountToAdd % 1000000) * 1000);
      case MILLIS: return plusMillis(amountToAdd);
      case SECONDS: return plusSeconds(amountToAdd);
      case MINUTES: return plusSeconds(Jdk8Methods.safeMultiply(amountToAdd, SECONDS_PER_MINUTE));
      case HOURS: return plusSeconds(Jdk8Methods.safeMultiply(amountToAdd, SECONDS_PER_HOUR));
      case HALF_DAYS: return plusSeconds(Jdk8Methods.safeMultiply(amountToAdd, SECONDS_PER_DAY / 2));
      case DAYS: return plusSeconds(Jdk8Methods.safeMultiply(amountToAdd, SECONDS_PER_DAY));
    }
    throw new UnsupportedTemporalTypeException("Unsupported unit: " + unit);
  }
  return unit.addTo(this, amountToAdd);
}

代码示例来源：origin: org.threeten/threetenbp

/**
 * {@inheritDoc}
 * @throws DateTimeException {@inheritDoc}
 * @throws ArithmeticException {@inheritDoc}
 */
@Override
public Instant plus(long amountToAdd, TemporalUnit unit) {
  if (unit instanceof ChronoUnit) {
    switch ((ChronoUnit) unit) {
      case NANOS: return plusNanos(amountToAdd);
      case MICROS: return plus(amountToAdd / 1000000, (amountToAdd % 1000000) * 1000);
      case MILLIS: return plusMillis(amountToAdd);
      case SECONDS: return plusSeconds(amountToAdd);
      case MINUTES: return plusSeconds(Jdk8Methods.safeMultiply(amountToAdd, SECONDS_PER_MINUTE));
      case HOURS: return plusSeconds(Jdk8Methods.safeMultiply(amountToAdd, SECONDS_PER_HOUR));
      case HALF_DAYS: return plusSeconds(Jdk8Methods.safeMultiply(amountToAdd, SECONDS_PER_DAY / 2));
      case DAYS: return plusSeconds(Jdk8Methods.safeMultiply(amountToAdd, SECONDS_PER_DAY));
    }
    throw new UnsupportedTemporalTypeException("Unsupported unit: " + unit);
  }
  return unit.addTo(this, amountToAdd);
}

代码示例来源：origin: googleapis/gax-java

@Test
public void testTimeoutAfterDeadline() {
 HttpJsonChannel mockChannel = Mockito.mock(HttpJsonChannel.class);
 String expectedRequest = "fake";
 HttpJsonDirectCallable<String, String> callable = new HttpJsonDirectCallable<>(API_DESCRIPTOR);
 // Mock the channel that captures the call options
 ArgumentCaptor<HttpJsonCallOptions> capturedCallOptions =
   ArgumentCaptor.forClass(HttpJsonCallOptions.class);
 Mockito.when(
     mockChannel.issueFutureUnaryCall(
       capturedCallOptions.capture(),
       Mockito.anyString(),
       Mockito.any(ApiMethodDescriptor.class)))
   .thenReturn(SettableApiFuture.create());
 // Compose the call context
 Instant priorDeadline = Instant.now().plusSeconds(5);
 Duration timeout = Duration.ofSeconds(10);
 HttpJsonCallContext callContext =
   HttpJsonCallContext.createDefault()
     .withChannel(mockChannel)
     .withDeadline(priorDeadline)
     .withTimeout(timeout);
 callable.futureCall(expectedRequest, callContext);
 // Verify that the timeout was ignored
 assertThat(capturedCallOptions.getValue().getDeadline()).isEqualTo(priorDeadline);
}

代码示例来源：origin: googleapis/gax-java

@Test
public void testTimeoutBeforeDeadline() {
 HttpJsonChannel mockChannel = Mockito.mock(HttpJsonChannel.class);
 String expectedRequest = "fake";
 HttpJsonDirectCallable<String, String> callable = new HttpJsonDirectCallable<>(API_DESCRIPTOR);
 // Mock the channel that captures the call options
 ArgumentCaptor<HttpJsonCallOptions> capturedCallOptions =
   ArgumentCaptor.forClass(HttpJsonCallOptions.class);
 Mockito.when(
     mockChannel.issueFutureUnaryCall(
       capturedCallOptions.capture(),
       Mockito.anyString(),
       Mockito.any(ApiMethodDescriptor.class)))
   .thenReturn(SettableApiFuture.create());
 // Compose the call context
 Duration timeout = Duration.ofSeconds(10);
 Instant subsequentDeadline = Instant.now().plusSeconds(15);
 Instant minExpectedDeadline = Instant.now().plus(timeout);
 HttpJsonCallContext callContext =
   HttpJsonCallContext.createDefault()
     .withChannel(mockChannel)
     .withDeadline(subsequentDeadline)
     .withTimeout(timeout);
 callable.futureCall(expectedRequest, callContext);
 Instant maxExpectedDeadline = Instant.now().plus(timeout);
 // Verify that the timeout was converted into a deadline
 assertThat(capturedCallOptions.getValue().getDeadline()).isAtLeast(minExpectedDeadline);
 assertThat(capturedCallOptions.getValue().getDeadline()).isAtMost(maxExpectedDeadline);
}