public final class Atomics {
  private Atomics() {}

  /**
   * Creates an {@code AtomicReference} instance with no initial value.
   *
   * @return a new {@code AtomicReference} with no initial value
   */
  public static <V> AtomicReference<@Nullable V> newReference() {
    return new AtomicReference<>();
  }

  /**
   * Creates an {@code AtomicReference} instance with the given initial value.
   *

    @Test
    public void test_OnConnect_ReceivesBothRequestAndConnection() throws Exception {
        // ## Arrange ##
        AtomicReference<CurlRequest> receivedRequest = new AtomicReference<>();
        AtomicReference<HttpURLConnection> receivedConnection = new AtomicReference<>();
        CurlRequest req = new OpenOverrideCurlRequest(Curl.Method.GET, "http://dummy",

    assertThat(sepLoader).isSameInstanceAs(sepStopwatchC.getClassLoader());
    AtomicReference<Object> sepStopwatchA =
        new AtomicReference<Object>(sepStopwatchC.getMethod("createUnstarted").invoke(null));
    AtomicReference<WeakReference<?>> sepStopwatchRef =
        new AtomicReference<WeakReference<?>>(
            (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get()));

        assertTrue(secondCalled.get());
    }

    @Test
    public void test_dispatchEvent_eventData() {
        final AtomicReference<String> receivedData = new AtomicReference<>();
        final AtomicReference<String> receivedInstanceId = new AtomicReference<>();
        coordinatorHelper.addEventHandler("config_updated", event -> {
            receivedData.set(event.data);

@NullUnmarked
public class AbstractLoadingCacheTest extends TestCase {

  public void testGetUnchecked_checked() {
    Exception cause = new Exception();
    AtomicReference<Object> valueRef = new AtomicReference<>();
    LoadingCache<Object, Object> cache =
        new AbstractLoadingCache<Object, Object>() {
          @Override
          public Object get(Object key) throws ExecutionException {
            Object v = valueRef.get();

    val tags = EmptyTags
    val atomicTags = AtomicReference<Tags>(tags)
    assertThat(atomicTags.computeIfAbsent(String::class) { "a" }).isEqualTo("a")
    assertThat(atomicTags.get()[String::class]).isEqualTo("a")
  }

  @Test
  fun computeIfAbsentWhenPresent() {
    val tags = EmptyTags.plus(String::class, "a")
    val atomicTags = AtomicReference(tags)

            @Override
            public void close() {
            }
        };

        CountDownLatch latch = new CountDownLatch(1);
        AtomicReference<SuggestIndexResponse> responseRef = new AtomicReference<>();
        AtomicReference<Throwable> errorRef = new AtomicReference<>();

        Deferred<SuggestIndexResponse>.Promise promise = suggester.indexer().indexFromQueryLog(emptyReader, 10, 0);

        final Deferred<SuggestResponse> deferred = new Deferred<>();
        final AtomicInteger callbackCount = new AtomicInteger(0);
        final AtomicReference<String> receivedIndex = new AtomicReference<>();

        deferred.promise().then(response -> {
            callbackCount.incrementAndGet();
            receivedIndex.set(response.getIndex());
        });

 * logger is created at start, and it exists while no logging is available yet.
 */
public class AccumulatingLogger implements Logger {
    private final AtomicReference<List<Entry>> entries = new AtomicReference<>(new CopyOnWriteArrayList<>());

    @Override
    public void log(Level level, String message, Throwable error) {
        requireNonNull(level, "level");
        requireNonNull(message, "message");

    AtomicBoolean actualIsOccupied = new AtomicBoolean();
    AtomicBoolean actualIsOccupiedByCurrentThread = new AtomicBoolean();
    AtomicInteger actualOccupiedDepth = new AtomicInteger();
    AtomicReference<Throwable> thrown = new AtomicReference<>();
    joinUninterruptibly(
        startThread(
            () -> {
              try {
                actualIsOccupied.set(monitor.isOccupied());