- Sort Score
- Result 10 results
- Languages All
Results 411 - 420 of 534 for 1000m (0.03 sec)
-
src/main/java/org/codelibs/fess/app/web/admin/wizard/AdminWizardAction.java
if (StringUtil.isBlank(configName)) { configName = StringUtils.abbreviate(configPath, 30); } // normalize final StringBuilder buf = new StringBuilder(1000); for (int i = 0; i < configPath.length(); i++) { final char c = configPath.charAt(i); if (c == '\\') { buf.append('/'); } else if (c == ' ') {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 12.7K bytes - Viewed (0) -
fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
final String sessionId2 = crawler2.execute(); assertNotSame(sessionId1, sessionId2); assertNotSame(crawler1.crawlerContext, crawler2.crawlerContext); Thread.sleep(1000); assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus()); assertEquals(CrawlerStatus.RUNNING, crawler2.crawlerContext.getStatus()); crawler1.awaitTermination();
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 11.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
} protected void runTestProfiled() throws Throwable { long t0 = System.nanoTime(); try { super.runTest(); } finally { long elapsedMillis = (System.nanoTime() - t0) / (1000L * 1000L); if (elapsedMillis >= profileThreshold) System.out.printf("%n%s: %d%n", toString(), elapsedMillis); } } // /** // * Runs all JSR166 unit tests using junit.textui.TestRunner
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 37.9K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/admin/general/admin_general.jsp
value="${f:h(crawlingThreadCount)}" class="form-control" min="1" max="1000"> </div> </div> <div class="form-group row">
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jan 16 12:54:35 UTC 2023 - 39.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ListenableFuture<?> future = executor.submit(incrementTask); assertTrue(future.isDone()); assertListenerRunImmediately(future); assertEquals(1, threadLocalCount.get().intValue()); otherThread.join(1000); assertEquals(Thread.State.TERMINATED, otherThread.getState()); Throwable throwable = throwableFromOtherThread.get(); assertNull( "Throwable from other thread: "
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 28.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
List<StringCatcher> catchers = Lists.newCopyOnWriteArrayList(); List<Future<?>> futures = Lists.newArrayList(); ExecutorService executor = Executors.newFixedThreadPool(10); int numberOfCatchers = 10000; for (int i = 0; i < numberOfCatchers; i++) { futures.add(executor.submit(new Registrator(bus, catchers))); } for (int i = 0; i < numberOfCatchers; i++) { futures.get(i).get(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 15:16:45 UTC 2024 - 11.2K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java
break; } catch (final Exception e) { logger.warn("[{}] {}", i + i, e.getMessage()); } ThreadUtil.sleep(1000L); } } private void setupMinioClient(String bucketName, String endpoint) throws Exception {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 13.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.9K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
@Resource protected OpenSearchDataService dataService; protected Map<String, QueueHolder> sessionCache = new ConcurrentHashMap<>(); protected int pollingFetchSize = 1000; protected int maxCrawlingQueueSize = 100; public OpenSearchUrlQueueService(final OpenSearchCrawlerConfig crawlerConfig) { index = crawlerConfig.getQueueIndex();
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/taglib/FessFunctions.java
Pattern.compile("[A-Z0-9._%+-]+@[A-Z0-9.-]+\\.[A-Z]{2,6}", Pattern.CASE_INSENSITIVE); private static LoadingCache<String, Long> resourceHashCache = CacheBuilder.newBuilder().maximumSize(1000).expireAfterWrite(10, TimeUnit.MINUTES).build(new CacheLoader<String, Long>() { @Override public Long load(final String key) throws Exception { try {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 16.9K bytes - Viewed (0)