Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for Poulter (0.06 sec)

  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)
  2. android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java

              if (newValue == 0) {
                // Just CASed to 0; remove the entry to clean up the map. If the removal fails,
                // another thread has already replaced it with a new counter, which is fine.
                countMap.remove(element, existingCounter);
              }
              return oldValue;
            }
          } else {
            return 0;
          }
        }
      }
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/reflect/ClassPathTest.java

            ClassPath.getClassPathEntry(new File("/home/build/outer.jar"), "file:/usr/test/dep.jar")
                .toURI());
        assertEquals(
            new File("/home/build/a.jar").toURI(),
            ClassPath.getClassPathEntry(new File("/home/build/outer.jar"), "a.jar").toURI());
        assertEquals(
            new File("/home/build/x/y/z").toURI(),
            ClassPath.getClassPathEntry(new File("/home/build/outer.jar"), "x/y/z").toURI());
        assertEquals(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 23K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/job/CrawlJob.java

                        }
                        counter.incrementAndGet();
                    } else if (logger.isDebugEnabled()) {
                        logger.debug("Scheduled job is not running: id={}", scheduledJob.getId());
                    }
                }
            });
            return counter.get();
        }
    
        /**
         * Executes the crawler process in a separate JVM.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/reflect/ClassPathTest.java

            ClassPath.getClassPathEntry(new File("/home/build/outer.jar"), "file:/usr/test/dep.jar")
                .toURI());
        assertEquals(
            new File("/home/build/a.jar").toURI(),
            ClassPath.getClassPathEntry(new File("/home/build/outer.jar"), "a.jar").toURI());
        assertEquals(
            new File("/home/build/x/y/z").toURI(),
            ClassPath.getClassPathEntry(new File("/home/build/outer.jar"), "x/y/z").toURI());
        assertEquals(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 25.7K bytes
    - Viewed (0)
  6. 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)
  7. src/main/java/org/codelibs/fess/helper/CrawlingConfigHelper.java

        /**
         * Map storing crawling configurations by session ID.
         */
        protected final Map<String, CrawlingConfig> crawlingConfigMap = new ConcurrentHashMap<>();
    
        /**
         * Counter for generating unique session identifiers.
         */
        protected int count = 1;
    
        /**
         * Cache for storing crawling configurations to improve performance.
         */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 19.5K bytes
    - Viewed (1)
  8. src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java

         * Creates a new instance with default values.
         */
        public IndexUpdateCallbackImpl() {
            // Default constructor
        }
    
        /** Atomic counter for the number of documents processed */
        protected AtomicLong documentSize = new AtomicLong(0);
    
        /** Total execution time for all operations */
        protected volatile long executeTime = 0;
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/ldap/LdapManager.java

                return context;
            }
    
            /**
             * Increments the counter.
             */
            public void inc() {
                counter++;
            }
    
            @Override
            public void close() {
                if (counter > 1) {
                    counter--;
                } else {
                    try {
                        if (context != null) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 86.3K bytes
    - Viewed (0)
  10. CLAUDE.md

    Execution context and configuration.
    
    **Important Fields**:
    ```java
    String sessionId                // Format: yyyyMMddHHmmssSSS
    volatile CrawlerStatus status   // DONE, RUNNING
    AtomicLong accessCount          // Thread-safe counter
    int numOfThread = 10            // Crawler threads
    int maxDepth = -1               // Max depth (-1 = unlimited)
    long maxAccessCount = 0         // Max URLs (0 = unlimited)
    ```
    
    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