Util - Code Search

CHANGELOG/CHANGELOG-1.21.md

- The `TTLAfterFinished` feature flag is now beta and enabled by default ([#98678](https://github.com/kubernetes/kubernetes/pull/98678), [@ahg-g](https://github.com/ahg-g))

Created: Fri Apr 03 09:05:14 GMT 2026

- Last Modified: Fri Oct 14 07:03:14 GMT 2022

- 367.3K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java

import java.time.Duration;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import junit.framework.TestCase;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sat Mar 07 02:20:33 GMT 2026

- 4.6K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

import static java.util.concurrent.Executors.newFixedThreadPool;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import java.util.concurrent.CancellationException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 6.5K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/base/Optional.java

  public java.util.Optional<T> toJavaUtil() {
    return java.util.Optional.ofNullable(orNull());
  }

  Optional() {}

  /**
   * Returns {@code true} if this holder contains a (non-null) instance.
   *
   * <p><b>Comparison to {@code java.util.Optional}:</b> no differences.
   */
  public abstract boolean isPresent();

  /**

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Jun 04 13:03:16 GMT 2025

- 15.1K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import junit.framework.TestCase;
import org.jspecify.annotations.NullUnmarked;

/**
 * Test for {@link WrappingScheduledExecutorService}
 *

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 7.5K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlan.java

import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.NoSuchElementException;
import java.util.Optional;
import java.util.Set;
import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.stream.Stream;

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Fri Mar 28 12:11:25 GMT 2025

- 6.1K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/util/concurrent/SingleThreadAbstractFutureBenchmark.java

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;
import org.jspecify.annotations.NullUnmarked;

/** A benchmark that times how long it takes to add a given number of */
@VmOptions({"-Xms8g", "-Xmx8g"})
@NullUnmarked

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue May 13 18:46:00 GMT 2025

- 3.7K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CancellationException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.Delayed;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 22.8K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CancellationException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.Delayed;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 22.8K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

 * limitations under the License.
 */

package com.google.common.util.concurrent;

import static com.google.common.base.Verify.verify;
import static com.google.common.truth.Truth.assertThat;
import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
import static com.google.common.util.concurrent.Futures.immediateFuture;
import static com.google.common.util.concurrent.MoreExecutors.directExecutor;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 4.7K bytes

- Click Count (0)

Search Options