thead - Code Search

docs_src/websockets/tutorial002_an_py39.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)

github.com/google/guava

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

 * invoke methods, they invoke methods on the {@code ForwardingQueue}.
 *
 * <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: Sun Dec 22 03:38:46 GMT 2024

- 3.9K bytes

- Click Count (0)

github.com/google/guava

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

    assertEquals(1, listenerLatch.getCount());
    assertFalse(task.isDone());
    assertFalse(task.isCancelled());

    // Start the task to put it in the RUNNING state.  Have to use a separate
    // thread because the task will block on the task latch after unblocking
    // the run latch.
    exec.execute(task);
    runLatch.await();
    assertEquals(1, listenerLatch.getCount());
    assertFalse(task.isDone());

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

- Last Modified: Thu Dec 11 21:00:51 GMT 2025

- 4.8K bytes

- Click Count (0)

github.com/google/guava

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

      synchronized (this) {
        if (!executed) {
          RunnableExecutorPair newTail = new RunnableExecutorPair(runnable, executor);
          if (head == null) {
            head = newTail;
            tail = newTail;
          } else {
            tail.next = newTail;
            tail = newTail;
          }
          return;
        }
      }

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

- Last Modified: Wed Jul 16 17:42:14 GMT 2025

- 15.8K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/tr/docs/tutorial/first-steps.md

Burada "operasyon" HTTP "metodlarından" birini ifade eder.

Bunlardan biri:

* `POST`
* `GET`
* `PUT`
* `DELETE`

...veya daha az kullanılan diğerleri:

* `OPTIONS`
* `HEAD`
* `PATCH`
* `TRACE`

HTTP protokolünde, bu "metodlardan" birini (veya daha fazlasını) kullanarak her bir yol ile iletişim kurabilirsiniz.

---

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

- Last Modified: Sat Oct 11 17:48:49 GMT 2025

- 10.4K bytes

- Click Count (0)

github.com/google/guava

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

 * are stored in the cache until either evicted or manually invalidated. The common way to build
 * instances is using {@link CacheBuilder}.
 *
 * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed
 * by multiple concurrent threads.
 *
 * <p>When evaluated as a {@link Function}, a cache yields the same result as invoking {@link
 * #getUnchecked}.
 *

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

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

- 8.3K bytes

- Click Count (0)

github.com/google/guava

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

        // proceed. So we cannot yet null out each bin.
        E head = oldTable.get(oldIndex);

        if (head != null) {
          E next = head.getNext();
          int headIndex = head.getHash() & newMask;

          // Single node on list
          if (next == null) {
            newTable.set(headIndex, head);
          } else {

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

- Last Modified: Mon Sep 22 18:35:44 GMT 2025

- 89.9K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/eventbus/Subscriber.java

  /**
   * Checks whether {@code method} is thread-safe, as indicated by the presence of the {@link
   * AllowConcurrentEvents} annotation.
   */
  private static boolean isDeclaredThreadSafe(Method method) {
    return method.getAnnotation(AllowConcurrentEvents.class) != null;
  }

  /**
   * Subscriber that synchronizes invocations of a method to ensure that only one thread may enter
   * the method at a time.
   */

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

- Last Modified: Wed May 14 19:40:47 GMT 2025

- 4.7K bytes

- Click Count (0)

github.com/square/okhttp

mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

    var ms = nanos / 1_000_000L
    val ns = nanos - (ms * 1_000_000L)

    while (ms > 100) {
      Thread.sleep(100)
      if (javaNetSocket.isClosed) throw InterruptedIOException("socket closed")
      ms -= 100L
    }

    if (ms > 0L || ns > 0) {
      Thread.sleep(ms, ns.toInt())
    }
  }

  override fun cancel() {
    delegate.cancel()
  }

  override fun close() {

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

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

- 3.3K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-core/src/test/java/org/apache/maven/internal/MultilineMessageHelperTest.java

        msgs.add("* as @threadSafe to support parallel building.                  *");
        msgs.add("* While this /may/ work fine, please look for plugin updates    *");
        msgs.add("* and/or request plugins be made thread-safe.                   *");
        msgs.add("* If reporting an issue, report it against the plugin in        *");
        msgs.add("* question, not against maven-core                              *");

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

- Last Modified: Fri Oct 25 12:31:46 GMT 2024

- 3.5K bytes

- Click Count (0)

Search Options