Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 878 for reread (0.04 seconds)

  1. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        // isn't currently executing this task.
        Runnable currentRunner = get();
        if (currentRunner instanceof Thread) {
          Blocker blocker = new Blocker(this);
          blocker.setOwner(Thread.currentThread());
          if (compareAndSet(currentRunner, blocker)) {
            // Thread.interrupt can throw arbitrary exceptions due to the nio InterruptibleChannel API
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 10K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt

    package okhttp3.internal.concurrent
    
    import assertk.assertThat
    import assertk.assertions.isCloseTo
    import assertk.assertions.isEmpty
    import assertk.assertions.isEqualTo
    import assertk.assertions.isTrue
    import java.lang.Thread.UncaughtExceptionHandler
    import java.util.concurrent.LinkedBlockingDeque
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.TimeUnit
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Tag
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 3.5K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        assertThat(Thread.interrupted()).isTrue();
      }
    
      public void testInterrupt_doesNotInterruptSubsequentTask() throws Exception {
        // Run a task that interrupts its thread (i.e. this thread).
        e.execute(
            new Runnable() {
              @Override
              public void run() {
                Thread.currentThread().interrupt();
              }
            });
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/base/internal/Finalizer.java

            logger.log(
                Level.INFO, "Failed to create a thread without inherited thread-local values", t);
          }
        }
        if (thread == null) {
          thread = new Thread((ThreadGroup) null, finalizer, threadName);
        }
        thread.setDaemon(true);
    
        try {
          if (inheritableThreadLocals != null) {
            inheritableThreadLocals.set(thread, null);
          }
        } catch (Throwable t) {
          logger.log(
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 9.3K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
      /** Interrupts the current thread after sleeping for the specified delay. */
      static void requestInterruptIn(long time, TimeUnit unit) {
        checkNotNull(unit);
        Thread interruptee = Thread.currentThread();
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Aug 10 19:54:19 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  6. android/guava-tests/benchmark/com/google/common/base/StringsRepeatBenchmark.java

    /**
     * Microbenchmark for {@link com.google.common.base.Strings#repeat}
     *
     * @author Mike Cripps
     */
    @NullUnmarked
    public class StringsRepeatBenchmark {
      @Param({"1", "5", "25", "125"})
      int count;
    
      @Param({"1", "10"})
      int length;
    
      private String originalString;
    
      @BeforeExperiment
      @SuppressWarnings("InlineMeInliner") // String.repeat unavailable under Java 8
      void setUp() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  7. src/main/resources/fess_label_en.properties

    labels.clear_crawler_index_button=Delete Crawler Index
    labels.diagnostic_logs=Diagnostics
    labels.download_diagnostic_logs_button=Download Logs
    labels.reload_doc_index=Reload Document Index
    labels.reload_doc_index_button=Reload
    labels.plugin_title=Plugin
    labels.plugin_list_name=Plugin List
    labels.plugin_type=Type
    labels.plugin_name=Name
    labels.plugin_version=Version
    labels.plugin_delete=Delete
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sat Dec 13 02:21:17 GMT 2025
    - 44K bytes
    - Click Count (0)
  8. README.md

        service.setPort(9200);
    });
    ```
    
    ## Performance Tuning
    
    ### Thread Configuration
    
    ```java
    // Optimize thread pool settings
    crawler.crawlerContext.setNumOfThread(20);           // Number of crawler threads
    crawler.crawlerContext.setMaxThreadCheckCount(50);   // Thread monitoring frequency
    ```
    
    ### Connection Pool Tuning
    
    ```java
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Aug 31 05:32:52 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

                mojos.put(Thread.currentThread(), mojoDescriptor);
                boolean aggregator = mojoDescriptor.isAggregator();
                acquiredAggregatorLock = aggregator ? aggregatorLock.writeLock() : aggregatorLock.readLock();
                acquiredProjectLock = getProjectLock(session);
                if (!acquiredAggregatorLock.tryLock()) {
                    Thread owner = aggregatorLock.getOwner();
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Jun 12 14:55:55 GMT 2025
    - 21K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/core/lang/ThreadUtil.java

         *            the length of time to sleep in milliseconds
         * @throws InterruptedRuntimeException
         *             if any thread has interrupted the current thread.
         */
        public static void sleep(final long millis) {
            if (millis < 1L) {
                return;
            }
            try {
                Thread.sleep(millis);
            } catch (final InterruptedException e) {
                throw new InterruptedRuntimeException(e);
            }
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 2.3K bytes
    - Click Count (0)
Back to Top