Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 171 for counters (0.06 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        queue.addListener(listener, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener, 1));
        queue.enqueue(incrementingEvent(counters, listener, 2));
        queue.enqueue(incrementingEvent(counters, listener, 3));
        queue.enqueue(incrementingEvent(counters, listener, 4));
        assertEquals(0, counters.size());
        queue.dispatch();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        queue.addListener(listener, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener, 1));
        queue.enqueue(incrementingEvent(counters, listener, 2));
        queue.enqueue(incrementingEvent(counters, listener, 3));
        queue.enqueue(incrementingEvent(counters, listener, 4));
        assertEquals(0, counters.size());
        queue.dispatch();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

         * and the counter returned by {@link #totalProblemsReported()} are not equal (latter is bigger than former).
         *
         * @return true if the problem collector has overflowed and some problems were not preserved
         */
        boolean problemsOverflow();
    
        /**
         * Reports a problem: always maintains the counters, but whether problem is preserved in memory, depends on
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jul 18 17:30:19 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/pager/RelatedContentPager.java

        public String createdTime;
    
        /** Version number for optimistic locking. */
        public String versionNo;
    
        /**
         * Clears all pagination state and filter parameters.
         * Resets pagination counters to default values and clears all filter fields.
         */
        public void clear() {
            allRecordCount = 0;
            allPageCount = 0;
            existPrePage = false;
            existNextPage = false;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/pager/ElevateWordPager.java

        public String createdTime;
    
        /** Search parameter: version number */
        public String versionNo;
    
        /**
         * Clears all pagination data and search parameters.
         * Resets counters, flags, and search form fields to their default values.
         */
        public void clear() {
            allRecordCount = 0;
            allPageCount = 0;
            existPrePage = false;
            existNextPage = false;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  6. src/test/java/jcifs/audit/SecurityAuditLoggerTest.java

            logger.resetStatistics();
    
            Map<EventType, Long> statsAfter = logger.getStatistics();
            // After reset, all counters should be 0
            for (Long count : statsAfter.values()) {
                assertEquals(Long.valueOf(0), count, "All statistics should be 0 after reset");
            }
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/audit/SecurityAuditLogger.java

            long currentWindow = System.currentTimeMillis() / rateLimitWindow;
            String windowKey = key + "_" + currentWindow;
    
            AtomicLong counter = rateLimitCounters.computeIfAbsent(windowKey, k -> new AtomicLong(0));
            long currentCount = counter.incrementAndGet();
    
            // Clean up old windows periodically
            if (currentCount == 1) {
                cleanupOldRateLimitCounters(currentWindow);
            }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * exception is thrown, this exception is used as the result of the output {@code Future}.
       *
       * <p>Usage example:
       *
       * {@snippet :
       * // Falling back to a zero counter in case an exception happens when processing the RPC to fetch
       * // counters.
       * ListenableFuture<Integer> faultTolerantFuture =
       *     fetchCounters().catching(FetchException.class, x -> 0, directExecutor());
       * }
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

        for (int i = 0; i < SIZE; i++) {
          aa.set(i, (double) COUNTDOWN);
        }
        Counter c1 = new Counter(aa);
        Counter c2 = new Counter(aa);
        Thread t1 = newStartedThread(c1);
        Thread t2 = newStartedThread(c2);
        awaitTermination(t1);
        awaitTermination(t2);
        assertEquals(SIZE * COUNTDOWN, c1.counts + c2.counts);
      }
    
      /** a deserialized serialized array holds same values */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactoryTest.java

        private CrawlerPooledObjectFactory<TestComponent> factory;
        private StandardCrawlerContainer container;
    
        @Override
        protected void setUp() throws Exception {
            super.setUp();
    
            // Reset counters before each test
            TestComponent.resetCounter();
            SingletonTestComponent.resetInstanceCount();
    
            // Initialize container with test components
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 19.3K bytes
    - Viewed (0)
Back to top