thead - Code Search

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

 * invoke methods, they invoke methods on the {@code ForwardingBlockingDeque}.
 *
 * <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 Emily Soldal
 * @since 14.0
 * @deprecated This class has moved to {@code com.google.common.util.concurrent}. Please use {@link

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

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

- 4.3K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/eventbus/DispatcherTest.java

  }

  public void testLegacyAsyncDispatcher() {
    dispatcher = Dispatcher.legacyAsync();

    CyclicBarrier barrier = new CyclicBarrier(2);
    CountDownLatch latch = new CountDownLatch(2);

    new Thread(
            new Runnable() {
              @Override
              public void run() {
                try {
                  barrier.await();
                } catch (Exception e) {

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

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

- 5.6K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/builtin/BuiltinShellCommandRegistryFactory.java

                    builder.directory(shellContext.cwd.get().toFile());
                    Process process = builder.start();
                    Thread out = new Thread(new StreamGobbler(process.getInputStream(), shellContext.writer));
                    Thread err = new Thread(new StreamGobbler(process.getErrorStream(), shellContext.logger::error));
                    out.start();
                    err.start();

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

- Last Modified: Sat Jun 07 06:22:47 GMT 2025

- 12.3K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/cache/AbstractCache.java

     */
    void recordHits(int count);

    /**
     * Records cache misses. This should be called when a cache request returns a value that was not
     * found in the cache. This method should be called by the loading thread, as well as by threads
     * blocking on the load. Multiple concurrent calls to {@link Cache} lookup methods with the same
     * key on an absent value should result in a single call to either {@code recordLoadSuccess} or

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

- Last Modified: Tue May 13 17:27:14 GMT 2025

- 9.1K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-core/src/main/java/org/apache/maven/execution/MavenSession.java

        try {
            MavenSession clone = (MavenSession) super.clone();
            // the default must become the current project of the thread that clones this
            MavenProject current = getCurrentProject();
            // we replace the thread local of the clone to prevent write through and enforce the new default value
            clone.currentProject = ThreadLocal.withInitial(() -> current);

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

- Last Modified: Fri Jan 24 17:29:44 GMT 2025

- 16.7K bytes

- Click Count (0)

github.com/google/guava

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

    } catch (ExecutionException e) {
      throw new AssertionError(e);
    }
  }

  static void verifyThreadWasNotInterrupted() {
    assertFalse(Thread.currentThread().isInterrupted());
  }

  static void clearInterrupt() {
    Thread.interrupted();
  }

  /**
   * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long,
   * TimeUnit)} overload in order to test that method.

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

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

- 2.7K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/cache/ChainBenchmark.java

      if (i == 0) {
        head = chain;
      }
    }
  }

  @SuppressWarnings("GuardedBy")
  @Benchmark
  int time(int reps) {
    int dummy = 0;
    for (int i = 0; i < reps; i++) {
      // TODO(b/145386688): This access should be guarded by 'this.segment', which is not currently
      // held
      segment.removeEntryFromChain(chain, head);
      dummy += segment.count;
    }

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

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

- 2.1K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultProject.java

        this.session = session;
        this.project = project;
        ClassLoader ttcl = Thread.currentThread().getContextClassLoader();
        try {
            Thread.currentThread().setContextClassLoader(project.getClassRealm());
            this.packaging = session.requirePackaging(project.getPackaging());
        } finally {
            Thread.currentThread().setContextClassLoader(ttcl);
        }
    }

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

- Last Modified: Mon Mar 24 22:23:23 GMT 2025

- 8.7K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

     * until we send the frame that acknowledges this new size.
     *
     * Since we can't ACK settings on the current reader thread (the reader thread can't write) we
     * execute all peer settings logic on the writer thread. This relies on the fact that the
     * writer task queue won't reorder tasks; otherwise settings could be applied in the opposite
     * order than received.
     */

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

- Last Modified: Thu Jul 31 04:18:40 GMT 2025

- 31.8K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial002_an_py310.py

    Query,
    WebSocket,
    WebSocketException,
    status,
)
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">
            <label>Item ID: <input type="text" id="itemId" autocomplete="off" value="foo"/></label>

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

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

- 2.8K bytes

- Click Count (0)

Search Options