Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for interrupted (0.03 sec)

  1. 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)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

        }
    
        /**
         * Stops the crawling process.
         * Sets the crawler status to DONE and interrupts all crawler threads.
         */
        public void stop() {
            crawlerContext.setStatus(CrawlerStatus.DONE);
            try {
                if (crawlerThreadGroup != null) {
                    crawlerThreadGroup.interrupt();
                }
            } catch (final Exception e) {
                // ignore
            }
        }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java

     * It is used to interrupt a running thread when a timeout occurs.
     * The class provides methods to interrupt the thread and stop the timeout target.
     *
     * <p>
     * The class uses a logger to log debug messages.
     * It also uses an AtomicBoolean to track whether the thread is running.
     * </p>
     *
     * <p>
     * The expired method is called when a timeout occurs.
     * It interrupts the running thread up to a maximum number of times.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  4. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

                                crawlerContext.incrementAndGetAccessCount();
                            }
                        } catch (InterruptedException e) {
                            Thread.currentThread().interrupt();
                        } finally {
                            endLatch.countDown();
                        }
                    }
                });
            }
    
            startLatch.countDown();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                        break;
                    }
                }
                assertEquals(CrawlerStatus.RUNNING, crawler.crawlerContext.getStatus());
                crawler.awaitTermination();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  6. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                        break;
                    }
                }
                assertEquals(CrawlerStatus.RUNNING, crawler.crawlerContext.getStatus());
                crawler.awaitTermination();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

                throw new CrawlerSystemException("Process terminated.", e);
            } finally {
                if (mt != null) {
                    mt.setFinished(true);
                    try {
                        mt.interrupt();
                    } catch (final Exception e) {}
                }
                if (currentProcess != null) {
                    try {
                        currentProcess.destroy();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 16K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

                try {
                    QueryLog queryLog = queryLogReader.read();
                    while (queryLog != null) {
                        if (Thread.currentThread().isInterrupted()) {
                            break;
                        }
                        queryLogs.add(queryLog);
                        queryLog = queryLogReader.read();
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/PdfExtractor.java

                task.start();
                task.join(timeout);
                if (!done.get()) {
                    for (int i = 0; i < 100 && !done.get(); i++) {
                        task.interrupt();
                        ThreadUtil.sleep(100L);
                    }
                    throw new ExtractException("PDFBox process cannot finish in " + timeout + " sec.");
                }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 12.7K bytes
    - Viewed (0)
Back to top