Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 806 for thead (0.02 sec)

  2. github.com/square/okhttp

    okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt 

      }

  /** Receive frames until there are no more. Invoked only by the reader thread. */
  @Throws(IOException::class)
  fun loopReader(response: Response) {
    try {
      listener.onOpen(this@RealWebSocket, response)
      while (receivedCloseCode == -1) {
        // This method call results in one or more onRead* methods being called on this thread.
        reader!!.processNextFrame()
      }
    } catch (e: Exception) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  3. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/util/SystemUtilTest.java 

                for (Thread thread : threads) {
                thread.start();
            }

            // Wait for all threads to complete
            for (Thread thread : threads) {
                try {
                    thread.join();
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                    fail("Thread interrupted");
                }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  4. github.com/google/guava

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

      protected AbstractExecutionThreadService() {}

  /**
   * Start the service. This method is invoked on the execution thread.
   *
   * <p>By default this method does nothing.
   */
  protected void startUp() throws Exception {}

  /**
   * Run the service. This method is invoked on the execution thread. Implementations must respond
   * to stop requests. You could poll for lifecycle changes in a work loop:
   *
   * <pre>
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  5. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt 

      }

  private fun sleep(delayMillis: Int) {
    try {
      Thread.sleep(delayMillis.toLong())
    } catch (e: InterruptedException) {
      Thread.currentThread().interrupt()
    }
  }

  private fun interruptLater(delayMillis: Int) {
    val toInterrupt = Thread.currentThread()
    val interruptingCow =
      Thread {
        sleep(delayMillis)
        toInterrupt.interrupt()
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  6. github.com/apache/maven

    compat/maven-compat/src/main/java/org/apache/maven/plugin/internal/DefaultPluginManager.java 

            }

        ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
        try {
            Thread.currentThread().setContextClassLoader(pluginDescriptor.getClassRealm());

            return container.lookup(role, roleHint);
        } finally {
            Thread.currentThread().setContextClassLoader(oldClassLoader);
        }
    }

    @Override
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  7. github.com/codelibs/fess

    src/main/webapp/WEB-INF/view/admin/dict/kuromoji/admin_dict_kuromoji_download.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.dict_kuromoji_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
    - 5.9K bytes
    - Viewed (0)
  8. github.com/codelibs/jcifs

    src/test/java/jcifs/internal/smb2/lease/DirectoryLeasingIntegrationTest.java 

                    }
            });
            readThreads[i].start();
        }

        // Wait for all threads
        for (Thread thread : updateThreads) {
            thread.join(5000);
        }
        for (Thread thread : readThreads) {
            thread.join(5000);
        }

        // Verify final state
        assertEquals(100, entry.getChildren().size());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  9. github.com/google/guava

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

          return;
    }
    TimedWaiterThread thread = new TimedWaiterThread(new AbstractFuture<Object>() {}, 2, SECONDS);
    thread.start();
    thread.awaitWaiting();
    Thread.class.getMethod("suspend").invoke(thread);
    // Sleep for enough time to add 1500 milliseconds of overwait to the get() call.
    long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime);
    Thread.sleep(toWaitMillis);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  10. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackTest.java 

            Thread[] threads = new Thread[10];
        for (int i = 0; i < threads.length; i++) {
            threads[i] = new Thread(() -> {
                for (int j = 0; j < 100; j++) {
                    callback.store(new DataStoreParams(), new HashMap<>());
                }
            });
        }

        // Start all threads
        for (Thread thread : threads) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  11. github.com/square/okhttp

    okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Lockable.kt 

      }
}

internal inline fun Lockable.assertLockNotHeld() {
  if (assertionsEnabled && Thread.holdsLock(this)) {
    throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
  }
}

internal inline fun Lockable.assertLockHeld() {
  if (assertionsEnabled && !Thread.holdsLock(this)) {
    throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
  }
}
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 2.1K bytes
    - Viewed (0)
Back to top