Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for Counter (0.04 sec)

  1. guava-tests/test/com/google/common/cache/AbstractCacheTest.java

      public void testSingleSimpleStats() {
        StatsCounter counter = new SimpleStatsCounter();
        for (int i = 0; i < 11; i++) {
          counter.recordHits(1);
        }
        for (int i = 0; i < 13; i++) {
          counter.recordLoadSuccess(i);
        }
        for (int i = 0; i < 17; i++) {
          counter.recordLoadException(i);
        }
        for (int i = 0; i < 23; i++) {
          counter.recordMisses(1);
        }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/io/MultiInputStreamTest.java

      }
    
      public void testOnlyOneOpen() throws Exception {
        ByteSource source = newByteSource(0, 50);
        int[] counter = new int[1];
        ByteSource checker =
            new ByteSource() {
              @Override
              public InputStream openStream() throws IOException {
                if (counter[0]++ != 0) {
                  throw new IllegalStateException("More than one source open");
                }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:44:53 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  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. android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java

      }
    
      public void testOnlyOneOpen() throws Exception {
        ByteSource source = newByteSource(0, 50);
        int[] counter = new int[1];
        ByteSource checker =
            new ByteSource() {
              @Override
              public InputStream openStream() throws IOException {
                if (counter[0]++ != 0) {
                  throw new IllegalStateException("More than one source open");
                }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:44:53 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/TempFileCreator.java

          @SuppressWarnings("GoodTime") // reading system time without TimeSource
          String baseName = System.currentTimeMillis() + "-";
    
          for (int counter = 0; counter < TEMP_DIR_ATTEMPTS; counter++) {
            File tempDir = new File(baseDir, baseName + counter);
            if (tempDir.mkdir()) {
              return tempDir;
            }
          }
          throw new IllegalStateException(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 29 18:50:14 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/base/SuppliersTest.java

        Supplier<Integer> nonThreadSafe =
            new Supplier<Integer>() {
              int counter = 0;
    
              @Override
              public Integer get() {
                int nextValue = counter + 1;
                Thread.yield();
                counter = nextValue;
                return counter;
              }
            };
    
        int numThreads = 10;
        int iterations = 1000;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/base/SuppliersTest.java

        Supplier<Integer> nonThreadSafe =
            new Supplier<Integer>() {
              int counter = 0;
    
              @Override
              public Integer get() {
                int nextValue = counter + 1;
                Thread.yield();
                counter = nextValue;
                return counter;
              }
            };
    
        int numThreads = 10;
        int iterations = 1000;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      }
    
      private static class Counter<N extends Number> {
        @Keep List<N> counts;
      }
    
      public void testWildcardCaptured_typeVariableDeclaresTypeBound_wildcardHasNoExplicitUpperBound()
          throws Exception {
        TypeToken<Counter<?>> type = new TypeToken<Counter<?>>() {};
        TypeToken<?> fieldType =
            type.resolveType(Counter.class.getDeclaredField("counts").getGenericType());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:44:53 UTC 2025
    - 89K bytes
    - Viewed (0)
Back to top