Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for awaitTermination (0.08 sec)

  1. README.md

    // Execute concurrently
    crawler1.setBackground(true);
    crawler2.setBackground(true);
    
    String sessionId1 = crawler1.execute();
    String sessionId2 = crawler2.execute();
    
    crawler1.awaitTermination();
    crawler2.awaitTermination();
    ```
    
    ### Custom Interval Control
    
    ```java
    // Configure politeness policy
    container.singleton("intervalController", DefaultIntervalController.class, controller -> {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  2. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus());
                assertEquals(CrawlerStatus.RUNNING, crawler2.crawlerContext.getStatus());
    
                crawler1.awaitTermination();
                crawler2.awaitTermination();
    
                assertEquals(maxCount, dataService.getCount(sessionId1));
                assertEquals(maxCount, dataService.getCount(sessionId2));
    
                UrlQueue urlQueue;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

            parentThread.start();
            if (!background) {
                awaitTermination();
            }
            return crawlerContext.sessionId;
        }
    
        /**
         * Waits for the crawling process to terminate indefinitely.
         */
        public void awaitTermination() {
            awaitTermination(0);
        }
    
        /**
         * Waits for the crawling process to terminate for a specified duration.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                    }
                    Thread.sleep(50);
                }
                assertEquals(CrawlerStatus.RUNNING, crawler2.crawlerContext.getStatus());
    
                crawler1.awaitTermination();
                crawler2.awaitTermination();
    
                assertEquals(maxCount, dataService.getCount(sessionId1));
                assertEquals(maxCount, dataService.getCount(sessionId2));
    
                UrlQueue urlQueue;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus());
                assertEquals(CrawlerStatus.RUNNING, crawler2.crawlerContext.getStatus());
    
                crawler1.awaitTermination();
                crawler2.awaitTermination();
    
                assertEquals(maxCount, dataService.getCount(sessionId1));
                assertEquals(maxCount, dataService.getCount(sessionId2));
    
                UrlQueue urlQueue;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 19.1K bytes
    - Viewed (0)
Back to top