- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 74 for countIn (0.04 sec)
-
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
*/ @CanIgnoreReturnValue @Override public int setCount(E element, int count) { checkNotNull(element); checkNonnegative(count, "count"); while (true) { AtomicInteger existingCounter = safeGet(countMap, element); if (existingCounter == null) { if (count == 0) { return 0; } else {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Dec 08 22:42:14 UTC 2025 - 22.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlingConfigHelper.java
* Stores a crawling configuration in the session-based storage with a unique identifier. * The generated session count ID combines the session ID with an incrementing counter. * * @param sessionId the session identifier * @param crawlingConfig the crawling configuration to store * @return the unique session count ID that can be used to retrieve the stored configuration */Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 19.5K bytes - Viewed (1) -
guava-tests/test/com/google/common/primitives/ImmutableLongArrayTest.java
void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { builder.add(counter.getAndIncrement()); } }, ADD_ARRAY { @Override void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) { long[] array = new long[random.nextInt(10)]; for (int i = 0; i < array.length; i++) { array[i] = counter.getAndIncrement(); } builder.addAll(array);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 12 14:49:24 UTC 2025 - 20.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
final int count = searchLogHelper.getClickCount(url); doc.put(clickCountField, count); if (logger.isDebugEnabled()) { logger.debug("Updated click count: count={}, url={}", count, url); } } /** * Adds favorite count information to the document. * * @param doc the document to update
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 10.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
final int count = searchLogHelper.getClickCount(url); doc.put(fessConfig.getIndexFieldClickCount(), count); if (logger.isDebugEnabled()) { logger.debug("Click count: count={}, url={}", count, url); } } } /** * Adds a favorite count field to the document based on user favorite data.
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 32.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CsvExtractor.java
for (final char candidate : candidates) { final int count = countOccurrences(line, candidate); if (count > maxCount) { maxCount = count; bestDelimiter = candidate; } } if (logger.isDebugEnabled()) { logger.debug("Detected delimiter: '{}' (count: {})", bestDelimiter, maxCount); } return bestDelimiter;Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 12.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java
for (int i = 0; i < deltas.length; i++) { deltas[i] += taskDeltas[i]; } } List<Integer> actualCounts = transform(keys, multiset::count); assertEquals("Counts not as expected", Ints.asList(deltas), actualCounts); } finally { pool.shutdownNow(); } // Since we have access to the backing map, verify that there are no zeroes in the map
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Dec 08 22:42:14 UTC 2025 - 5.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
final int maxDepth = getMaxDepth(paramMap, dataMap); long counter = 0; final Deque<CrawlRequest> requestQueue = new LinkedList<>(); final Set<String> processedUrls = new HashSet<>(); requestQueue.offer(new CrawlRequest(url, 0)); while (!requestQueue.isEmpty() && (maxAccessCount < 0 || counter < maxAccessCount)) { final CrawlRequest crawlRequest = requestQueue.poll();
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 29.7K bytes - Viewed (3) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
} /** * Gets the count of currently running crawler jobs. * This method queries the scheduled jobs to count active crawler processes. * Used to enforce maximum concurrent crawler limits. * * @return the number of currently running crawler jobs */ protected int getRunningJobCount() { final AtomicInteger counter = new AtomicInteger(0);Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 19.6K bytes - Viewed (0) -
CLAUDE.md
context.setNumOfThread(10); // Concurrent threads ``` ### Accessing Results ```java DataService ds = container.getComponent("dataService"); // Count int count = ds.getCount(sessionId); // Get by URL AccessResult result = ds.getAccessResult(sessionId, url); // Iterate all ds.iterate(sessionId, accessResult -> { System.out.println(accessResult.getUrl());
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Fri Nov 28 17:31:34 UTC 2025 - 10.7K bytes - Viewed (0)