- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for awaitTermination (0.08 sec)
-
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) -
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) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
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) -
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)