thead - Code Search

guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingSortedMultiset.java

 * method.
 *
 * <p>The {@code standard} methods and any 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 Louis Wasserman
 */
public abstract class ForwardingSortedMultiset<E extends @Nullable Object>
    extends ForwardingMultiset<E> implements SortedMultiset<E> {

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

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

- 8K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/ForwardingMap.java

 * not consistent with {@code equals}.
 *
 * <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 Kevin Bourrillion
 * @author Jared Levy
 * @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

- 9.8K bytes

- Click Count (0)

github.com/google/guava

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

   * instance. This method is guaranteed to only be called once.
   *
   * <p>By default this returns a new {@link ScheduledExecutorService} with a single thread pool
   * that sets the name of the thread to the {@linkplain #serviceName() service name}. Also, the
   * pool will be {@linkplain ScheduledExecutorService#shutdown() shut down} when the service

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

- Last Modified: Sat Aug 09 01:14:59 GMT 2025

- 27.7K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportAggregationWorkAction.kt

        outputFile.parentFile.mkdirs()
        outputFile.printWriter(Charsets.UTF_8).use { writer ->
            writer.println(
                """<html lang="en">
    <head>
       <META http-equiv="Content-Type" content="text/html; charset=UTF-8">
       <title>Incubating APIs</title>

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

- Last Modified: Mon Jun 02 09:57:54 GMT 2025

- 5.2K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/ConsumingQueueIterator.java

import java.util.Queue;
import org.jspecify.annotations.Nullable;

/**
 * An Iterator implementation which draws elements from a queue, removing them from the queue as it
 * iterates. This class is not thread safe.
 */
@GwtCompatible
final class ConsumingQueueIterator<T extends @Nullable Object> extends AbstractIterator<T> {
  private final Queue<T> queue;

  ConsumingQueueIterator(Queue<T> queue) {

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

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

- 1.4K bytes

- Click Count (0)

github.com/square/okhttp

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

    try {
      wait()
    } catch (_: InterruptedException) {
      Thread.currentThread().interrupt() // Retain interrupted status.
      throw InterruptedIOException()
    }
  }

  /**
   * The Okio timeout watchdog will call [timedOut] if the timeout is reached. In that case we close
   * the stream (asynchronously) which will notify the waiting thread.
   */
  internal inner class StreamTimeout : AsyncTimeout() {

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

- Last Modified: Mon Jul 07 18:57:05 GMT 2025

- 22.4K bytes

- Click Count (0)

github.com/google/guava

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

          }
        } else {
          // In the case of a concurrent remove, we might observe a zero value, which means another
          // thread is about to remove (element, existingCounter) from the map. Rather than wait,
          // we can just do that work here.
          AtomicInteger newCounter = new AtomicInteger(occurrences);

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

- Last Modified: Mon Dec 08 22:42:14 GMT 2025

- 22.3K bytes

- Click Count (0)

github.com/apache/maven

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

            while (true) {
                try {
                    failure.set(null);
                    systemRegistry.cleanUp();
                    Thread commandThread = new Thread(() -> {
                        try {
                            systemRegistry.execute(reader.readLine(
                                    context.cwd.get().getFileName().toString() + " mvnsh> ",

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

- Last Modified: Thu Oct 16 06:12:36 GMT 2025

- 10.1K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_operations_signatures.py

import inspect

from fastapi import APIRouter, FastAPI

method_names = ["get", "put", "post", "delete", "options", "head", "patch", "trace"]


def test_signatures_consistency():
    base_sig = inspect.signature(APIRouter.get)
    for method_name in method_names:
        router_method = getattr(APIRouter, method_name)
        app_method = getattr(FastAPI, method_name)
        router_sig = inspect.signature(router_method)

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

- Last Modified: Mon May 27 12:08:13 GMT 2019

- 934 bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/FindBadMultiLangSnippets.java

                continue;
            }

            if (line.equals("[.multi-language-sample]")) { // first [.multi-language-sample]
                int headerLine = i + 1; // 1-based
                // Look ahead to find [source, ...] until next sample or end of example block
                String sourceLang = null;
                for (int j = i + 1; j < lines.size(); j++) {
                    String look = lines.get(j).trim();

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

- Last Modified: Fri Aug 29 10:12:17 GMT 2025

- 7.2K bytes

- Click Count (0)

Search Options