Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 131 for AtomicInteger (0.11 seconds)

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

        assertThat(stats.loadExceptionCount()).isEqualTo(1);
        assertThat(stats.hitCount()).isEqualTo(0);
      }
    
      public void testReloadAfterFailure() throws ExecutionException {
        AtomicInteger count = new AtomicInteger();
        Exception e = new IllegalStateException("exception to trigger failure on first load()");
        CacheLoader<Integer, String> failOnceFunction =
            new CacheLoader<Integer, String>() {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 91K bytes
    - Click Count (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java

         */
        protected String sessionId;
    
        /**
         * Atomic counter for tracking active crawler threads without lock contention.
         */
        protected final AtomicInteger activeThreadCount = new AtomicInteger(0);
    
        /**
         * Atomic counter for tracking the number of accesses made.
         */
        protected AtomicLong accessCount = new AtomicLong(0);
    
        /**
         * Current status of the crawler.
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Dec 31 09:07:38 GMT 2025
    - 9K bytes
    - Click Count (0)
  3. guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

        private final Class<T> interfaceType;
        private final Method method;
        private final @Nullable Object[] passedArgs;
        private final @Nullable Object returnValue;
        private final AtomicInteger called = new AtomicInteger();
    
        InteractionTester(Class<T> interfaceType, Method method) {
          this.interfaceType = interfaceType;
          this.method = method;
          this.passedArgs = getParameterValues(method);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/util/SearchEngineUtilTest.java

            // Note: In a real test environment, this would require proper SearchEngineClient setup
            // For now, we test that the method signature is correct and can be called
    
            AtomicInteger callbackCount = new AtomicInteger(0);
    
            try {
                // This will likely fail due to missing SearchEngineClient setup,
                // but we can verify the method signature and basic functionality
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/helper/CrawlingConfigHelperTest.java

            assertEquals("name", fieldSortBuilderList.get(1).getFieldName());
        }
    
        @Test
        public void test_getExcludedUrlList() {
            final AtomicInteger errorCount = new AtomicInteger(0);
            final DynamicProperties systemProperties = ComponentUtil.getSystemProperties();
            final FailureUrlCB cb = new FailureUrlCB();
            ComponentUtil.register(new FailureUrlBhv() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 35.3K bytes
    - Click Count (0)
  6. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

    import java.util.Comparator;
    import java.util.List;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.CopyOnWriteArrayList;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.LongAdder;
    import java.util.function.Predicate;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.Constants;
    import org.apache.maven.api.ProtoSession;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jul 18 17:30:19 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

        private volatile boolean isComplete;
        private volatile boolean hasChanges;
        private DirectoryCacheScope scope;
        private long maxAge;
    
        private final AtomicInteger inconsistencyCount = new AtomicInteger(0);
    
        /**
         * Create a new directory cache entry
         *
         * @param path the directory path
         * @param key the lease key
         * @param scope the cache scope
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 02:21:31 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  8. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

            // Poll concurrently
            final CountDownLatch startLatch = new CountDownLatch(1);
            final CountDownLatch doneLatch = new CountDownLatch(numThreads);
            final AtomicInteger totalPolled = new AtomicInteger(0);
            final List<String> allUrls = new ArrayList<>();
    
            for (int i = 0; i < numThreads; i++) {
                new Thread(() -> {
                    try {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Jan 14 23:48:16 GMT 2026
    - 14.5K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

       */
      // We use an anonymous class to be sure that we generate two methods (bridge and original).
      @SuppressWarnings("AnonymousToLambda")
      public void testRegistrationWithBridgeMethod() {
        AtomicInteger calls = new AtomicInteger();
        bus.register(
            new Callback<String>() {
              @Subscribe
              @Override
              public void call(String s) {
                calls.incrementAndGet();
              }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/eventbus/EventBusTest.java

       */
      // We use an anonymous class to be sure that we generate two methods (bridge and original).
      @SuppressWarnings("AnonymousToLambda")
      public void testRegistrationWithBridgeMethod() {
        AtomicInteger calls = new AtomicInteger();
        bus.register(
            new Callback<String>() {
              @Subscribe
              @Override
              public void call(String s) {
                calls.incrementAndGet();
              }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 11.6K bytes
    - Click Count (0)
Back to Top