Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 74 for countIn (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top