Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 81 for Interrupter (0.04 sec)

  1. docs/changelogs/changelog_1x.md

       following a redirect from a POST to a GET.
     * Implement basic support for `Thread.interrupt()`. OkHttp now checks
       for an interruption before doing a blocking call. If it is interrupted,
       it throws an `InterruptedIOException`.
    
    ## Version 1.5.2
    
    _2014-03-17_
    
     * Fix bug where deleting a file that was absent from the `HttpResponseCache`
       caused an IOException.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

             * Interrupted exceptions are caught and logged at debug level.
             */
            public void awaitTermination() {
                try {
                    join();
                } catch (final InterruptedException e) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Interrupted.", e);
                    }
                }
            }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/rdma/RdmaErrorHandler.java

                        return true;
                    }
    
                } catch (InterruptedException e) {
                    log.debug("RDMA recovery interrupted");
                    Thread.currentThread().interrupt();
                    break;
                } catch (Exception recoveryError) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/TestPlatform.java

          throw new AssertionError(e);
        }
      }
    
      static void verifyThreadWasNotInterrupted() {
        assertFalse(Thread.currentThread().isInterrupted());
      }
    
      static void clearInterrupt() {
        Thread.interrupted();
      }
    
      /**
       * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long,
       * TimeUnit)} overload in order to test that method.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/netbios/NameServiceClientImpl.java

        }
    
        private static void joinThread(final Thread thread) {
            try {
                thread.join();
            } catch (final InterruptedException e) {
                log.warn("Thread join interrupted", e);
                // Restore interrupted status
                Thread.currentThread().interrupt();
            }
        }
    
        private static boolean isAllDigits(final String hostname) {
            for (int i = 0; i < hostname.length(); i++) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 38.5K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

            if (parentThread != null) {
                try {
                    parentThread.join(millis);
                } catch (final InterruptedException e) {
                    logger.warn("Interrupted job at {}", parentThread.getName());
                }
            }
        }
    
        /**
         * Cleans up the crawled data for a given session.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/exception/UserRoleLoginExceptionTest.java

            thread1.start();
            thread2.start();
    
            try {
                thread1.join();
                thread2.join();
            } catch (InterruptedException e) {
                fail("Thread interrupted");
            }
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

        Thread.currentThread().interrupt();
        try {
          assertEquals("foo", getUnchecked(immediateFuture("foo")));
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

        Thread.currentThread().interrupt();
        try {
          assertEquals("foo", getUnchecked(immediateFuture("foo")));
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java

         * This method extracts the host from the URL and enforces a delay based on the configured
         * delayMillisBeforeProcessing parameter.
         *
         * @throws InterruptedRuntimeException if the thread is interrupted during the delay
         * @throws CrawlerSystemException if an error occurs while processing the URL
         */
        @Override
        protected void delayBeforeProcessing() {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.2K bytes
    - Viewed (0)
Back to top