thead - Code Search

android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

     * simple approach would be for each caller CAS it from null to a Set populated with its
     * exception. But there's another race: If the first thread fails with an exception and a second
     * thread immediately fails with the same exception:
     *
     * Thread1: calls setException(), which returns true, context switch before it can CAS
     * seenExceptionsField to its exception
     *

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 8.5K bytes

- Click Count (0)

github.com/google/guava

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

    ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();

    Thread.currentThread().setContextClassLoader(classLoader);
    try {
      Class<?> test = classLoader.loadClass(AbstractFutureTest.class.getName());
      test.getMethod(getName()).invoke(test.getDeclaredConstructor().newInstance());
    } finally {
      Thread.currentThread().setContextClassLoader(oldClassLoader);
    }

Created: Fri Dec 26 12:43:10 GMT 2025

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

- 7.3K bytes

- Click Count (0)

github.com/google/guava

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

 * elements FIFO (first-in-first-out). The head of the queue is that element that has been
 * on the queue the longest time. The tail of the queue is that element that has been on
 * the queue the shortest time. New elements are inserted at the tail of the queue, and the queue
 * retrieval operations obtain elements at the head of the queue.
 *

Created: Fri Dec 26 12:43:10 GMT 2025

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

- 22.4K bytes

- Click Count (0)

github.com/gradle/gradle

.github/workflows/validate-codeowners.yml

    steps:
      - name: Get Secrets
        uses: gradle/actions-internal/get-aws-secrets@v1
        if: (github.event_name != 'pull_request' && github.repository_owner == 'gradle') || github.event.pull_request.head.repo.full_name == github.repository
        with:
          role-to-assume: arn:aws:iam::992382829881:role/GHASecrets_gradle_all
          secret-ids: |

Created: Wed Dec 31 11:36:14 GMT 2025

- Last Modified: Thu Nov 20 22:15:20 GMT 2025

- 1.5K bytes

- Click Count (0)

github.com/google/guava

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

              @Override
              public Integer call() {
                return Thread.currentThread().getStackTrace().length;
              }
            },
            directExecutor());
    settableFuture.set(null);
    assertThat(getDone(stackDepthCheck))
        .isLessThan(Thread.currentThread().getStackTrace().length + 100);
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Sep 23 01:35:55 GMT 2025

- 16.2K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/ForwardingSortedMap.java

 * equality for both keys and values, unlike {@code ForwardingMap}.
 *
 * <p>The {@code standard} methods and the collection views they return are not guaranteed to be
 * thread-safe, even when all of the methods that they depend on are thread-safe.
 *
 * @author Mike Bostock
 * @author Louis Wasserman
 * @since 2.0
 */
@GwtCompatible
/*

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Wed Feb 12 16:28:01 GMT 2025

- 5.7K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/TagsTest.kt

    val atomicTags = AtomicReference<Tags>(tags)
    val result =
      atomicTags.computeIfAbsent(String::class) {
        // 'Race' by making another computeIfAbsent call. In practice this would be another thread.
        assertThat(atomicTags.computeIfAbsent(Integer::class) { 5 as Integer }).isEqualTo(5)
        "a"
      }
    assertThat(result).isEqualTo("a")
    assertThat(atomicTags.get()[String::class]).isEqualTo("a")

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Fri Oct 24 11:37:46 GMT 2025

- 7.1K bytes

- Click Count (0)

github.com/square/okhttp

mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

  /**
   * Test that MockWebServer blocks for a call to enqueue() if a request is made before a mock
   * response is ready.
   */
  @Test
  fun dispatchBlocksWaitingForEnqueue() {
    Thread {
      try {
        Thread.sleep(1000)
      } catch (ignored: InterruptedException) {
      }
      server.enqueue(MockResponse().setBody("enqueued in the background"))
    }.start()

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Thu Jul 03 13:16:34 GMT 2025

- 22.3K bytes

- Click Count (0)

github.com/golang/go

misc/chrome/gophertool/popup.html

<html>
<!--
 Copyright 2011 The Go Authors. All rights reserved.
 Use of this source code is governed by a BSD-style
 license that can be found in the LICENSE file.
-->
<head>
<script src="gopher.js"></script>
<script src="popup.js"></script>
</head>
<body style='margin: 0.5em; font-family: sans;'>
<small><a href="#" url="https://golang.org/issue">issue</a>,
<a href="#" url="https://golang.org/cl">codereview</a>,

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Fri Mar 05 02:35:21 GMT 2021

- 830 bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/ForwardingSet.java

 * methods that they depend on are thread-safe.
 *
 * @author Kevin Bourrillion
 * @author Louis Wasserman
 * @since 2.0
 */
@GwtCompatible
public abstract class ForwardingSet<E extends @Nullable Object> extends ForwardingCollection<E>
    implements Set<E> {
  // TODO(lowasser): identify places where thread safety is actually lost

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Sun Dec 22 03:38:46 GMT 2024

- 3.7K bytes

- Click Count (0)

Search Options