thead - Code Search

src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java

     *
     * @param task
     *            the task to execute
     */
    public static void execute(final Runnable task) {
        ForkJoinPool.commonPool().execute(() -> {
            final Thread currentThread = Thread.currentThread();
            final ClassLoader orignal = currentThread.getContextClassLoader();
            currentThread.setContextClassLoader(CommonPoolUtil.class.getClassLoader());
            try {

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

- Last Modified: Thu Jul 31 08:16:49 UTC 2025

- 1.7K bytes

- Viewed (0)

github.com/apache/maven

api/maven-api-annotations/src/main/java/org/apache/maven/api/annotations/ThreadSafe.java

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

/**
 * The {@code ThreadSafe} annotation can be used to indicate a given type
 * is thread safe.  {@link Immutable} objects are automatically thread safe.
 *
 * @see Immutable
 * @see NotThreadSafe
 * @since 4.0.0
 */
@Experimental
@Documented
@Retention(RetentionPolicy.CLASS)
@Target(ElementType.TYPE)

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

- Last Modified: Tue Dec 10 21:43:27 UTC 2024

- 1.4K bytes

- Viewed (0)

github.com/google/guava

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

   * calling thread. Tasks are run to completion before a {@code Future} is returned to the caller
   * (unless the executor has been shutdown).
   *
   * <p>The returned executor is backed by the executor returned by {@link
   * MoreExecutors#newDirectExecutorService} and subject to the same constraints.
   *
   * <p>Although all tasks are immediately executed in the thread that submitted the task, this

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

- Last Modified: Thu Jul 17 15:26:41 UTC 2025

- 6.6K 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/dashboard/admin_dashboard.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.dashboard_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: Wed Feb 12 12:21:50 UTC 2020

- 1.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/helper/DataIndexHelperTest.java

    public void test_thread_priority_settings() {
        // Test basic priority configurations without creating threads
        dataIndexHelper.setCrawlerPriority(Thread.MIN_PRIORITY);
        dataIndexHelper.setCrawlerPriority(Thread.NORM_PRIORITY);
        dataIndexHelper.setCrawlerPriority(Thread.MAX_PRIORITY);
        assertTrue("Priority settings should be fast", true);
    }

    public void test_multiple_quick_operations() {
        try {

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

- Last Modified: Sat Jul 12 05:35:01 UTC 2025

- 12.7K bytes

- Viewed (0)

github.com/google/guava

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

  private final CountDownLatch exitRun = new CountDownLatch(1);

  private Thread executionThread;
  private Throwable thrownByExecutionThread;
  private final Executor exceptionCatchingExecutor =
      new Executor() {
        @Override
        public void execute(Runnable command) {
          executionThread = new Thread(command);
          executionThread.setUncaughtExceptionHandler(

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

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

- 12.8K 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/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

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt

  /** The maximum size of [buffer]. */
  val bufferMaxSize: Long,
) : Lockable {
  /** The thread that currently has access to upstream. Possibly null. Guarded by this. */
  var upstreamReader: Thread? = null

  /**
   * A buffer for [upstreamReader] to use when pulling bytes from upstream. Only the
   * [upstreamReader] thread may access this buffer.
   */
  val upstreamBuffer = Buffer()

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

- Last Modified: Wed May 28 17:15:47 UTC 2025

- 11.8K bytes

- Viewed (0)

Search Options