thead - Code Search

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

    Node<K, V> head;
    Node<K, V> tail;
    int count;

    KeyList(Node<K, V> firstNode) {
      this.head = firstNode;
      this.tail = firstNode;
      firstNode.previousSibling = null;
      firstNode.nextSibling = null;
      this.count = 1;
    }
  }

  @CheckForNull private transient Node<K, V> head; // the head for all keys

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 13 14:11:58 UTC 2023

- 27.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/CallKotlinTest.kt

    assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)

    // Give the socket a chance to become stale.
    connection!!.idleAtNs -= IDLE_CONNECTION_HEALTHY_NS
    Thread.sleep(250)

    val requestB =
      Request(
        url = server.url("/"),
        body = "b".toRequestBody("text/plain".toMediaType()),
      )
    val responseB = client.newCall(requestB).execute()

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Jan 20 10:30:28 UTC 2024

- 8.4K bytes

- Viewed (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);

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Oct 24 13:01:38 UTC 2024

- 41.3K bytes

- Viewed (0)

github.com/google/guava

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

  @Footprint(exclude = {Runnable.class, Executor.class, Thread.class, Exception.class})
  public Object measureSize() {
    for (Thread thread : blockedThreads) {
      thread.interrupt();
    }
    blockedThreads.clear();
    final Facade<Object> f = impl.newFacade();
    for (int i = 0; i < numThreads; i++) {
      Thread thread =
          new Thread() {
            @Override
            public void run() {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Wed Oct 16 17:21:56 UTC 2024

- 2.9K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

    // Enqueueing the red task starts a thread because the head of the queue changed.
    redQueue.execute("red task") {
      log += "red:starting@${taskFaker.nanoTime}"
      taskFaker.sleep(100.µs)
      log += "red:finishing@${taskFaker.nanoTime}"
    }
    assertThat(taskFaker.executeCallCount).isEqualTo(1)

    // Enqueueing the blue task doesn't start a thread because the red one is still starting.

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Apr 29 00:33:04 UTC 2024

- 23K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.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

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Aug 06 17:23:04 UTC 2024

- 7.4K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

 *   <li>a {@linkplain ThreadFactoryBuilder#setNameFormat naming format}
 *   <li>a {@linkplain Thread#setPriority thread priority}
 *   <li>an {@linkplain Thread#setUncaughtExceptionHandler uncaught exception handler}
 *   <li>a {@linkplain ThreadFactory#newThread backing thread factory}
 * </ul>
 *

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Mon Oct 14 22:50:54 UTC 2024

- 7.9K 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 Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Aug 06 17:23:04 UTC 2024

- 4.6K bytes

- Viewed (0)

github.com/codelibs/fess-suggest

src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

public class DeferredTest {
    @Test
    public void test_doneBeforeResolve() throws Exception {
        final Deferred<SuggestResponse> deferred = new Deferred<>();

        Thread th = new Thread(() -> {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException ignore) {}
            deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null));
        });
        th.start();

Registered: Fri Nov 08 09:08:12 UTC 2024

- Last Modified: Thu Feb 22 01:36:54 UTC 2024

- 4.8K bytes

- Viewed (0)

github.com/google/guava

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

          @Override
          void afterRanInterruptiblyFailure(Throwable error) {}
        };
    Thread runner = new Thread(task, "runner");
    runner.start();
    isInterruptibleRegistered.await();
    // trigger the interrupt on another thread since it will block
    Thread interrupter =
        new Thread("Interrupter") {
          @Override
          public void run() {
            task.interruptTask();

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 18 22:10:29 UTC 2024

- 6.6K bytes

- Viewed (0)

Search Options