thead - Code Search

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

      }
    }
  }

  private static class Interrupter implements Runnable {
    final Thread threadToInterrupt;

    Interrupter(Thread threadToInterrupt) {
      this.threadToInterrupt = threadToInterrupt;
    }

    @Override
    public void run() {
      try {
        Thread.sleep(100);
      } catch (InterruptedException e) {
        throw new AssertionError();
      } finally {

Registered: Fri Sep 05 12:43:10 UTC 2025

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

- 12.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/util/JobProcessTest.java

        InputStreamThread thread = jobProcess.getInputStreamThread();
        thread.start();
        thread.join(1000);

        String output = thread.getOutput();
        assertTrue("Should contain recent lines", output.contains("line5"));

        assertTrue("Should have line3", thread.contains("line3"));
        assertTrue("Should have line4", thread.contains("line4"));

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jul 12 07:34:10 UTC 2025

- 8.5K bytes

- Viewed (0)

github.com/google/guava

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

    @Override
    public String toString() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.toString();
    }

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

    @Override
    public int hashCode() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.hashCode();
    }

Registered: Fri Sep 05 12:43:10 UTC 2025

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

- 4.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessSecurityResourceProviderTest.java

    }

    // Test thread safety
    public void test_threadSafety() {
        // Test that the provider returns the same instances in multi-threaded environment
        final int threadCount = 10;
        final Thread[] threads = new Thread[threadCount];
        final InvertibleCryptographer[] invertibles = new InvertibleCryptographer[threadCount];

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Tue Aug 19 14:09:36 UTC 2025

- 12.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt

  }

  @JvmStatic
  fun threadFactory(name: String): ThreadFactory =
    object : ThreadFactory {
      private var nextId = 1

      override fun newThread(runnable: Runnable): Thread = Thread(runnable, "$name-${nextId++}")
    }
}

fun getEnv(name: String) = System.getenv(name)

val SYSTEM_FILE_SYSTEM = FileSystem.SYSTEM

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed Mar 19 19:25:20 UTC 2025

- 4.3K bytes

- Viewed (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

    assertFalse(future.isDone());
    assertFalse(future.isCancelled());

    CountDownLatch successLatch = new CountDownLatch(1);

    // Run cancellation in a separate thread as an extra thread-safety test.
    new Thread(
            () -> {
              assertThrows(CancellationException.class, future::get);
              successLatch.countDown();
            })
        .start();

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Fri Jul 11 18:52:30 UTC 2025

- 6.1K bytes

- Viewed (0)

github.com/google/guava

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

            }
          }
        });
    awaitUninterruptibly(enteredLatch);
  }

  @CanIgnoreReturnValue
  static Thread startThread(Runnable runnable) {
    Thread thread = new Thread(runnable);
    thread.setDaemon(true);
    thread.start();
    return thread;
  }

  /**
   * Generates a test case verifying that calling any enterXxx, tryEnterXxx, or waitForXxx method

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Mon Aug 11 19:31:30 UTC 2025

- 27K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

    }
  }

  /** Confirm all tasks have completed. Used by the test thread only. */
  fun assertNoMoreTasks() {
    taskRunner.assertLockNotHeld()

    taskRunner.withLock {
      assertThat(activeThreads).isEqualTo(0)
    }
  }

  /** Unblock a waiting task thread. Used by the test thread only. */
  fun interruptCoordinatorThread() {
    taskRunner.assertLockNotHeld()

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed May 28 23:28:25 UTC 2025

- 11.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/SmbCircuitBreakerTest.java

        // Trip circuit
        circuitBreaker.trip();
        Thread.sleep(100);

        long afterTripTime = circuitBreaker.getTimeSinceLastStateChange();
        assertTrue(afterTripTime >= 100, "Time should have advanced");
        assertTrue(afterTripTime < 200, "Time should be reasonable");

        // Reset circuit
        circuitBreaker.reset();
        Thread.sleep(50);

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 30 05:58:03 UTC 2025

- 23.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/wizard/admin_wizard.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %><!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.wizard_title_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Thu Feb 13 07:47:04 UTC 2020

- 3.5K bytes

- Viewed (0)

Search Options