thead - Code Search

compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java

    private List<File> filesToDelete = new ArrayList<>();

    private final String baseFilename;

    private final String fileSuffix;

    private StackTraceElement callerInfo;

    private Thread cleanupWarning;

    private boolean warnAboutCleanup = false;

    public TestFileManager(String baseFilename, String fileSuffix) {
        this.baseFilename = baseFilename;
        this.fileSuffix = fileSuffix;

Created: Sun Dec 28 03:35:09 GMT 2025

- Last Modified: Wed Sep 17 10:01:14 GMT 2025

- 4.8K bytes

- Click Count (0)

github.com/google/guava

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

@J2ktIncompatible
@GwtIncompatible
public interface FinalizableReference {
  /**
   * Invoked on a background thread after the referent has been garbage collected unless security
   * restrictions prevented starting a background thread, in which case this method is invoked when
   * new references are created.
   */
  void finalizeReferent();

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

- Last Modified: Sat Dec 21 03:10:51 GMT 2024

- 1.4K bytes

- Click Count (0)

github.com/tiangolo/fastapi

.github/workflows/pre-commit.yml

      - uses: actions/checkout@v5
        name: Checkout PR for fork
        if: env.HAS_SECRETS == 'false'
        with:
        # To be able to commit it needs the head branch of the PR, the remote one
          ref: ${{ github.event.pull_request.head.sha }}
          fetch-depth: 0
      - name: Set up Python
        uses: actions/setup-python@v6
        with:
          python-version: "3.14"
      - name: Setup uv

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Tue Dec 23 11:17:16 GMT 2025

- 3K bytes

- Click Count (0)

github.com/minio/minio

helm/minio/templates/_helper_create_svcacct.txt

    rm -f $MINIO_ACCESSKEY_SECRETKEY_TMP
    return 1
  fi
  SVCACCT=$(head -1 $MINIO_ACCESSKEY_SECRETKEY_TMP)
  # Create the svcacct if it does not exist
  if ! checkSvcacctExists ; then
    echo "Creating svcacct '$SVCACCT'"
    # Check if policy file is define
    if [ -z $FILENAME ]; then

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Thu Mar 28 23:20:50 GMT 2024

- 3.4K bytes

- Click Count (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/collect/testing/MinimalIterable.java

 *
 * <p>Note that although your APIs should be liberal in what they accept, your methods which
 * <i>return</i> iterables should make every attempt to return ones of the robust variety.
 *
 * <p>This testing utility is not thread-safe.
 *
 * @author Kevin Bourrillion
 */
@GwtCompatible
public final class MinimalIterable<E extends @Nullable Object> implements Iterable<E> {

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

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

- 3.1K bytes

- Click Count (0)

github.com/google/guava

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

                }
                return toReturn;
              }
            }
            return super.loadClass(name);
          }
        };
    oldClassLoader = Thread.currentThread().getContextClassLoader();
    Thread.currentThread().setContextClassLoader(classReloader);
    abstractFutureClass = classReloader.loadClass(AbstractFuture.class.getName());

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

- Last Modified: Tue Oct 28 16:03:47 GMT 2025

- 6.2K bytes

- Click Count (0)

github.com/google/guava

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

 * comparator is not consistent with {@code equals}.
 *
 * <p>The {@code standard} methods 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 Aug 06 17:32:30 GMT 2025

- 4.3K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial003_py39.py

from fastapi import FastAPI, WebSocket, WebSocketDisconnect
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <h2>Your ID: <span id="ws-id"></span></h2>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sat Mar 18 12:29:59 GMT 2023

- 2.5K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

  }

  private fun makeSynchronousCall(call: Call): Thread {
    val thread =
      Thread {
        try {
          call.execute()
          throw AssertionError()
        } catch (expected: IOException) {
        }
      }
    thread.start()
    return thread
  }

  private fun newRequest(url: String): Request = Request.Builder().url(url).build()

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

- Last Modified: Tue Nov 04 19:13:52 GMT 2025

- 15.8K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/WholeOperationTimeoutTest.kt

      Request
        .Builder()
        .url(server.url("/"))
        .build()
    val call = client.newCall(request)
    call.timeout().timeout(250, TimeUnit.MILLISECONDS)
    val response = call.execute()
    Thread.sleep(500)
    assertFailsWith<IOException> {
      response.body.source().readUtf8()
    }.also { expected ->
      assertThat(expected.message).isEqualTo("timeout")
      assertThat(call.isCanceled()).isTrue()

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

- Last Modified: Wed Jun 18 12:28:21 GMT 2025

- 10.6K bytes

- Click Count (0)

Search Options