thead - Code Search

android/guava/src/com/google/common/base/internal/Finalizer.java

        logger.log(
            Level.INFO, "Failed to create a thread without inherited thread-local values", t);
      }
    }
    if (thread == null) {
      thread = new Thread((ThreadGroup) null, finalizer, threadName);
    }
    thread.setDaemon(true);

    try {
      if (inheritableThreadLocals != null) {
        inheritableThreadLocals.set(thread, null);
      }
    } catch (Throwable t) {
      logger.log(

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Mar 11 03:19:29 GMT 2026

- 9.6K bytes

- Click Count (0)

github.com/google/guava

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

  /** Returns a new started daemon Thread running the given runnable. */
  final Thread newStartedThread(Runnable runnable) {
    Thread t = new Thread(runnable);
    t.setDaemon(true);
    t.start();
    return t;
  }

  /**
   * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
   * Thread#join(long)}), else interrupts the thread (in the hope that it may terminate later) and

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sat Mar 07 02:20:33 GMT 2026

- 8.8K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/SynchronizedNavigableMapTest.java

    @Override
    public boolean equals(@Nullable Object object) {
      assertTrue(Thread.holdsLock(mutex));
      return super.equals(object);
    }

    @Override
    public K getKey() {
      assertTrue(Thread.holdsLock(mutex));
      return super.getKey();
    }

    @Override
    public V getValue() {
      assertTrue(Thread.holdsLock(mutex));
      return super.getValue();
    }

    @Override

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Mar 13 13:01:07 GMT 2026

- 12.8K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/crawler/transformer/FessXpathTransformerTest.java

        responseData.setUrl("http://example.com/");

        String data = "<html><head></head><body>aaa</body></html>";
        Document document = getDocument(data);
        String value = transformer.getCanonicalUrl(responseData, document);
        assertNull(value);

        data = "<html><head><link rel=\"canonical\" href=\"http://example.com/\"></head><body>aaa</body></html>";
        document = getDocument(data);

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Mar 13 23:01:26 GMT 2026

- 62.9K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

    @Override
    public boolean offer(E o) {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.offer(o);
    }

    @Override
    public @Nullable E poll() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.poll();
    }

    @Override
    public E remove() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.remove();
    }

    @Override

Created: Fri Apr 03 12:43:13 GMT 2026

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

- 4.8K bytes

- Click Count (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/timer/TimeoutManager.java

        return instance;
    }

    /**
     * Starts the process.
     */
    public synchronized void start() {
        if (thread == null) {
            thread = new Thread(this, "CoreLib-TimeoutManager");
            thread.setDaemon(true);
            thread.start();
            if (logger.isDebugEnabled()) {
                logger.debug("TimeoutManager started.");
            }
        }
    }

Created: Fri Apr 03 20:58:12 GMT 2026

- Last Modified: Sat May 10 01:32:17 GMT 2025

- 7.8K bytes

- Click Count (0)

github.com/google/guava

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

    Interruptenator interruptingTask = new Interruptenator(Thread.currentThread());
    Thread interruptingThread = new Thread(interruptingTask);
    interruptingThread.start();
    tearDownAccepter.addTearDown(
        () -> {
          interruptingTask.stopInterrupting();
          interruptingThread.interrupt();
          joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
          Thread.interrupted();

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Mar 17 15:38:30 GMT 2026

- 3.4K bytes

- Click Count (0)

github.com/google/guava

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

  }

  /**
   * Causes this thread to call the named method, and asserts that this thread becomes blocked on
   * the lock-like object. The lock-like object must have a method equivalent to {@link
   * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}.
   */
  public void callAndAssertBlocks(String methodName, Object... arguments) throws Exception {

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Mar 13 13:01:07 GMT 2026

- 11.5K bytes

- Click Count (0)

github.com/google/guava

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

     *
     * 1. The client thread begins to block on a get() call to a future.
     * 2. The client thread is interrupted sometime before the result would be
     *   available.
     * 3. We expect the client's get() to throw an InterruptedException.
     * 4. We expect the client thread's interrupt state to be false.
     * 5. The client thread again makes a blocking call to get().

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 8.9K bytes

- Click Count (0)

github.com/google/guava

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

    Interruptenator interruptingTask = new Interruptenator(Thread.currentThread());
    Thread interruptingThread = new Thread(interruptingTask);
    interruptingThread.start();
    tearDownAccepter.addTearDown(
        () -> {
          interruptingTask.stopInterrupting();
          interruptingThread.interrupt();
          joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
          Thread.interrupted();

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Mar 17 15:38:30 GMT 2026

- 3.4K bytes

- Click Count (0)

Search Options