- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for CrawlingParameterUtil (0.14 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/CrawlingParameterUtil.java
import org.codelibs.fess.crawler.entity.UrlQueue; import org.codelibs.fess.crawler.service.DataService; import org.codelibs.fess.crawler.service.UrlQueueService; /** * @author shinsuke * */ public final class CrawlingParameterUtil { private static final ThreadLocal<UrlQueue<?>> URL_QUEUE_THREAD_LOCAL = new ThreadLocal<>(); private static final ThreadLocal<CrawlerContext> ROBOT_CONTEXT_THREAD_LOCAL = new ThreadLocal<>();
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
public void test_delayBeforeProcessing() { // 同時実行数 final int numTasks = 100; // インターバル final Long waittime = 100L; CrawlingParameterUtil.setUrlQueue(new UrlQueueImpl()); final UrlQueue q = CrawlingParameterUtil.getUrlQueue(); for (int i = 0; i < numTasks; i++) { q.setUrl("http://example.com"); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3.2K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java
protected void processResult(final UrlQueue<?> urlQueue, final ResponseData responseData, final ResultData resultData) { final CrawlerContext crawlerContext = CrawlingParameterUtil.getCrawlerContext(); final UrlQueueService<UrlQueue<?>> urlQueueService = CrawlingParameterUtil.getUrlQueueService(); if (!urlQueueService.visited(urlQueue)) { if (checkAccessCount(crawlerContext)) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java
import org.codelibs.core.lang.SystemUtil; import org.codelibs.fess.crawler.entity.UrlQueue; import org.codelibs.fess.crawler.exception.CrawlerSystemException; import org.codelibs.fess.crawler.util.CrawlingParameterUtil; public class HostIntervalController extends DefaultIntervalController { private final ConcurrentMap<String, AtomicLong> lastTimes = new ConcurrentHashMap<>(); public HostIntervalController() { }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
import org.codelibs.fess.crawler.helper.impl.MimeTypeHelperImpl; import org.codelibs.fess.crawler.service.impl.UrlFilterServiceImpl; import org.codelibs.fess.crawler.util.CrawlerWebServer; import org.codelibs.fess.crawler.util.CrawlingParameterUtil; import org.dbflute.utflute.core.PlainTestCase; /** * @author shinsuke * */ public class HcHttpClientTest extends PlainTestCase { public HcHttpClient httpClient;
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu May 09 09:28:25 UTC 2024 - 8.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/transformer/FessTransformer.java
import org.codelibs.fess.crawler.entity.AccessResult; import org.codelibs.fess.crawler.entity.AccessResultData; import org.codelibs.fess.crawler.entity.UrlQueue; import org.codelibs.fess.crawler.util.CrawlingParameterUtil; import org.codelibs.fess.crawler.util.FieldConfigs; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.util.ComponentUtil; public interface FessTransformer {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 9.5K bytes - Viewed (0)