thead - Code Search

src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

     *
     * @param manager channel manager
     */
    public ChannelFailover(ChannelManager manager) {
        this.manager = manager;
        this.executor = Executors.newCachedThreadPool(r -> {
            Thread t = new Thread(r, "MultiChannelFailover");
            t.setDaemon(true);
            return t;
        });
        this.failoverStates = new ConcurrentHashMap<>();
    }

    /**
     * Handle channel failure
     *

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

- Last Modified: Thu Aug 21 11:13:46 UTC 2025

- 11.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/profile/index.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.profile.title" /></title>
<link href="${fe:url('/css/admin/bootstrap.min.css')}" rel="stylesheet" type="text/css" />

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

- Last Modified: Sat Jan 18 12:09:07 UTC 2025

- 3.6K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/eventbus/AllowConcurrentEvents.java

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus
 * may invoke the event subscriber simultaneously from multiple threads.
 *
 * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}.
 *

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

- Last Modified: Sat Dec 21 03:10:51 UTC 2024

- 1.2K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/misc/DynamicProperties.java

 *   <li>{@link IORuntimeException} - Thrown if there are I/O errors during file operations.</li>
 * </ul>
 *
 * <p>Thread Safety:
 * This class uses synchronization to ensure thread-safe access to the properties.
 *
 * @see Properties
 */
public class DynamicProperties extends Properties {

    private static final long serialVersionUID = 1L;

    /**

Registered: Fri Sep 05 20:58:11 UTC 2025

- Last Modified: Sat Jul 05 00:11:05 UTC 2025

- 13.1K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt

   * lifted. Such writes occur on an application-provided thread and may occur concurrently with
   * reads of the [ResponseBody]. For duplex request bodies, [writeTo] should return
   * quickly, possibly by handing off the provided request body to another thread to perform
   * writing.
   *
   * [grpc]: https://github.com/grpc/grpc/blob/master/doc/PROTOCOL-HTTP2.md
   */

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

- Last Modified: Wed Jun 04 17:43:43 UTC 2025

- 9K bytes

- Viewed (0)

github.com/google/guava

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

 * invoke methods, they invoke methods on the {@code ForwardingBlockingDeque}.
 *
 * <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 Emily Soldal
 * @since 14.0
 * @deprecated This class has moved to {@code com.google.common.util.concurrent}. Please use {@link

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

- Last Modified: Sun Dec 22 03:38:46 UTC 2024

- 4.3K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/base/FinalizableWeakReference.java

import java.lang.ref.ReferenceQueue;
import java.lang.ref.WeakReference;
import org.jspecify.annotations.Nullable;

/**
 * Weak reference with a {@code finalizeReferent()} method which a background thread invokes after
 * the garbage collector reclaims the referent. This is a simpler alternative to using a {@link
 * ReferenceQueue}.
 *
 * @author Bob Lee
 * @since 2.0
 */
@J2ktIncompatible
@GwtIncompatible

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

- Last Modified: Sun Dec 22 03:38:46 UTC 2024

- 1.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/base/FinalizableWeakReference.java

import java.lang.ref.ReferenceQueue;
import java.lang.ref.WeakReference;
import org.jspecify.annotations.Nullable;

/**
 * Weak reference with a {@code finalizeReferent()} method which a background thread invokes after
 * the garbage collector reclaims the referent. This is a simpler alternative to using a {@link
 * ReferenceQueue}.
 *
 * @author Bob Lee
 * @since 2.0
 */
@J2ktIncompatible
@GwtIncompatible

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

- Last Modified: Sun Dec 22 03:38:46 UTC 2024

- 1.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/scheduler/admin_scheduler_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.scheduledjob_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: Mon Jan 16 12:54:35 UTC 2023

- 9.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/job/CrawlJob.java

     * -2: use system default, -1: never expire, 0 or positive: expire after specified days.
     */
    protected int documentExpires = -2;

    /**
     * Hot thread monitoring interval in seconds.
     * -1: disabled, positive value: enable hot thread monitoring with specified interval.
     * Used for performance analysis and debugging of the crawler process.
     */
    protected int hotThreadInterval = -1;

    /**

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

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

- 19.6K bytes

- Viewed (0)

Search Options