thead - Code Search

fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java

 * The delay is calculated based on the configured delayMillisBeforeProcessing parameter.
 * If the time since the last request to the host is less than the configured delay,
 * the thread waits until the delay has elapsed.
 * This class is thread-safe.
 */
public class HostIntervalController extends DefaultIntervalController {

    /** Map storing the last access time for each host. */

Registered: Sun Sep 21 03:50:09 UTC 2025

- Last Modified: Sun Jul 06 02:13:03 UTC 2025

- 4.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

   * the list otherwise we'll be left in a bad state. If the thread was interrupted prior to this
   * operation, it will be re-interrupted after the list is read.
   */
  private fun readTheListUninterruptibly() {
    var interrupted = false
    try {
      while (true) {
        try {
          readTheList()
          return
        } catch (_: InterruptedIOException) {
          Thread.interrupted() // Temporarily clear the interrupted state.

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

- Last Modified: Mon Jul 28 07:33:49 UTC 2025

- 3.6K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

fess-crawler/src/main/java/org/codelibs/fess/crawler/builder/RequestDataBuilder.java

        public RequestDataContext get() {
            return method(Method.GET);
        }

        /**
         * Sets the HTTP method to HEAD.
         * @return The current RequestDataContext instance.
         */
        public RequestDataContext head() {
            return method(Method.HEAD);
        }

        /**
         * Sets the HTTP method to POST.
         * @return The current RequestDataContext instance.

Registered: Sun Sep 21 03:50:09 UTC 2025

- Last Modified: Sun Jul 06 02:13:03 UTC 2025

- 4.3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/AuthenticationRateLimiterTest.java

                });
            }

            // Start all threads
            for (Thread t : threads) {
                t.start();
            }

            // Wait for completion
            for (Thread t : threads) {
                t.join();
            }

            // Verify thread safety - no unexpected exceptions

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

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

- 15.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/admin/plugin/AdminPluginAction.java

    }

    /**
     * Installs the specified artifact in a background thread.
     * Also removes any previously installed versions of the same plugin.
     *
     * @param artifact the artifact to install
     */
    public static void installArtifact(final Artifact artifact) {
        new Thread(() -> {
            final PluginHelper pluginHelper = ComponentUtil.getPluginHelper();

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

- Last Modified: Thu Aug 07 03:06:29 UTC 2025

- 11.9K bytes

- Viewed (0)

github.com/square/okhttp

docs/features/calls.md

Calls are executed in one of two ways:

 * **Synchronous:** your thread blocks until the response is readable.
 * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.

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

- Last Modified: Sun Feb 06 02:19:09 UTC 2022

- 3.9K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/user/admin_user_details.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.user_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

- 17.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/SmbTransportPoolTest.java

            // When - simulate concurrent requests
            Thread thread1 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, false));
            Thread thread2 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, true));

            thread1.start();
            thread2.start();

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

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

- 22.6K bytes

- Viewed (0)

github.com/apache/maven

api/maven-api-core/src/main/java/org/apache/maven/api/services/ProjectManager.java

 *   <li>Handle project forking states</li>
 * </ul>
 *
 * The service maintains the mutable state of projects as they progress through
 * their build lifecycle, ensuring thread-safety and proper state management.
 * All implementations must be thread-safe as they may be accessed concurrently
 * during parallel builds.
 *
 * @since 4.0.0
 * @see org.apache.maven.api.services.ProjectBuilder
 * @see Project
 */
@Experimental

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

- Last Modified: Thu Jan 30 23:29:13 UTC 2025

- 12K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/HtmlExtractor.java

        }

        return parser;
    }

    /**
     * Gets a thread-local XPathAPI instance for thread-safe XPath evaluation.
     *
     * @return the XPathAPI instance for the current thread
     */
    protected XPathAPI getXPathAPI() {
        XPathAPI cachedXPathAPI = xpathAPI.get();
        if (cachedXPathAPI == null) {

Registered: Sun Sep 21 03:50:09 UTC 2025

- Last Modified: Sun Jul 06 02:13:03 UTC 2025

- 9.3K bytes

- Viewed (0)

Search Options