thead - Code Search

src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

import jakarta.annotation.PreDestroy;
import jakarta.annotation.Resource;

/**
 * IndexUpdater is responsible for updating the search index with crawled document data.
 * This class extends Thread and continuously processes access results from the crawler,
 * transforms them into indexed documents, and updates the OpenSearch index.
 *
 * <p>The updater performs the following key operations:
 * <ul>

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

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

- 32.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/fileconfig/admin_fileconfig_edit.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.file_crawling_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

- 15.3K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/ProcessHelper.java

                ist.interrupt();
            } catch (final Exception e) {
                logger.warn("Could not interrupt a thread of an input stream.", e);
            }

            final CountDownLatch latch = new CountDownLatch(3);
            final Process process = jobProcess.getProcess();
            new Thread(() -> {
                try {
                    CloseableUtil.closeQuietly(process.getInputStream());

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

- Last Modified: Thu Jul 17 08:28:31 UTC 2025

- 9.8K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

        static final ThreadGroup GROUP = new ThreadGroup(THREADGROUP_NAME);

        static final AtomicInteger THREAD_NUMBER = new AtomicInteger(1);

        @Override
        public Thread newThread(Runnable r) {
            Thread newThread = new Thread(GROUP, r, "resolver-" + THREAD_NUMBER.getAndIncrement());
            newThread.setDaemon(true);
            newThread.setContextClassLoader(null);
            return newThread;
        }

Registered: Sun Sep 07 03:35:12 UTC 2025

- Last Modified: Fri Jun 06 14:28:57 UTC 2025

- 25K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

/** Dispatcher is not [Lockable] because we don't want that type in our public API. */
internal fun Dispatcher.assertLockNotHeld() {
  if (assertionsEnabled && Thread.holdsLock(this)) {
    throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
  }
}

/**
 * Returns the string "OkHttp" unless the library has been shaded for inclusion in another library,

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

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

- 10.2K bytes

- Viewed (1)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb1/com/SmbComTreeDisconnectTest.java

    }

    /**
     * Test thread safety of read/write operations
     */
    @Test
    @DisplayName("Test thread safety of operations")
    public void testThreadSafety() throws InterruptedException {
        // Given
        smbComTreeDisconnect = new SmbComTreeDisconnect(config);
        byte[] buffer = new byte[1000];
        int numThreads = 10;
        Thread[] threads = new Thread[numThreads];

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

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 18.5K bytes

- Viewed (0)

github.com/google/guava

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

   * which is still better than alternatives.
   *
   * Per-thread hash codes are initialized to random values.
   * Contention and/or table collisions are indicated by failed
   * CASes when performing an update operation (see method
   * retryUpdate). Upon a collision, if the table size is less than
   * the capacity, it is doubled in size unless some other thread
   * holds the lock. If a hashed slot is empty, and lock is

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

- Last Modified: Wed Jan 15 22:17:15 UTC 2025

- 11.4K bytes

- Viewed (0)

github.com/google/guava

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

  }

  public void testFutureCancellableBeforeFunctionCompletion() throws Exception {
    // Set the result in a separate thread since this test runs the function
    // (which will block) in the same thread.
    new Thread() {
      @Override
      public void run() {
        inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
      }
    }.start();
    funcIsWaitingLatch.await();

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

- Last Modified: Thu Dec 19 18:03:30 UTC 2024

- 6.3K bytes

- Viewed (0)

github.com/google/guava

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

 * comparator is not consistent with {@code equals}.
 *
 * <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

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

- Last Modified: Wed Aug 06 17:32:30 UTC 2025

- 4.3K bytes

- Viewed (0)

github.com/google/guava

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

  }

  public void testFutureCancellableBeforeFunctionCompletion() throws Exception {
    // Set the result in a separate thread since this test runs the function
    // (which will block) in the same thread.
    new Thread() {
      @Override
      public void run() {
        inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
      }
    }.start();
    funcIsWaitingLatch.await();

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

- Last Modified: Thu Dec 19 18:03:30 UTC 2024

- 6.3K bytes

- Viewed (0)

Search Options