- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for CrawlerThread (0.21 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
import org.codelibs.fess.crawler.service.UrlQueueService; import org.codelibs.fess.crawler.util.CrawlingParameterUtil; /** * @author shinsuke * */ public class CrawlerThread implements Runnable { @Resource protected UrlQueueService<UrlQueue<?>> urlQueueService; @Resource protected DataService<AccessResult<?>> dataService; @Resource
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 15.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
for (int i = 0; i < crawlerContext.getNumOfThread(); i++) { final CrawlerThread crawlerThread = crawlerContainer.getComponent("crawlerThread"); crawlerThread.setCrawlerContext(crawlerContext); crawlerThread.setClientFactory(clientFactory); threads[i] = new Thread(crawlerThreadGroup, crawlerThread, "Crawler-" + crawlerContext.sessionId + "-" + Integer.toString(i + 1));
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 7.9K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/crawler/FessCrawlerThreadTest.java
public void test_getClientRuleList() { FessCrawlerThread crawlerThread = new FessCrawlerThread(); List<Pair<String, Pattern>> list = crawlerThread.getClientRuleList(null); assertEquals(0, list.size()); list = crawlerThread.getClientRuleList(""); assertEquals(0, list.size()); list = crawlerThread.getClientRuleList(" "); assertEquals(0, list.size());
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 24.1K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
manager.addRule(container.getComponent("fileRule")); }).prototype("accessResult", AccessResultImpl.class).prototype("urlQueue", UrlQueueImpl.class) .prototype("crawlerThread", CrawlerThread.class).prototype("crawler", Crawler.class) .prototype("urlFilterService", UrlFilterServiceImpl.class).prototype("urlQueueService", UrlQueueServiceImpl.class)
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 18K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
while (startedCrawlerNum < dataCrawlingThreadList.size()) { // Force to stop crawl if (systemHelper.isForceStop()) { for (final DataCrawlingThread crawlerThread : dataCrawlingThreadList) { crawlerThread.stopCrawling(); } break; } if (activeCrawlerNum < multiprocessCrawlingCount) { // start crawling
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java
import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.util.ComponentUtil; import org.codelibs.fess.util.DocumentUtil; public class FessCrawlerThread extends CrawlerThread { private static final Logger logger = LogManager.getLogger(FessCrawlerThread.class); protected static final String CRAWLER_CLIENTS = "crawlerClients";
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14.6K bytes - Viewed (0)