Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for incrementAndGet (0.1 sec)

  1. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

            while ((region = availableSendRegions.poll()) != null) {
                region.close();
                totalReleased.incrementAndGet();
            }
    
            while ((region = availableReceiveRegions.poll()) != null) {
                region.close();
                totalReleased.incrementAndGet();
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java

        }
    
        /**
         * Grant a send credit
         */
        public void grantSendCredit() {
            sendCredits.incrementAndGet();
        }
    
        /**
         * Grant a receive credit
         */
        public void grantReceiveCredit() {
            receiveCredits.incrementAndGet();
        }
    
        /**
         * Get number of available send credits
         *
         * @return available send credits
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java

              @Override
              public Object load(Object key) {
                loadCount.incrementAndGet();
                return new Object();
              }
    
              @Override
              public ListenableFuture<Object> reload(Object key, Object oldValue) {
                reloadCount.incrementAndGet();
                return immediateFuture(new Object());
              }
    
              @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/job/JobExecutorTest.java

            AtomicInteger counter1 = new AtomicInteger(0);
            AtomicInteger counter2 = new AtomicInteger(0);
    
            executor1.addShutdownListener(() -> counter1.incrementAndGet());
            executor2.addShutdownListener(() -> counter2.incrementAndGet());
    
            executor1.shutdown();
            assertEquals(1, counter1.get());
            assertEquals(0, counter2.get());
    
            executor2.shutdown();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java

        EventBus bus = new EventBus();
        bus.register(
            new Object() {
              @Subscribe
              public void accept(String str) {
                holder.set(str);
                deliveries.incrementAndGet();
              }
            });
    
        String EVENT = "Hello!";
        bus.post(EVENT);
    
        assertEquals("Only one event should be delivered.", 1, deliveries.get());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java

        EventBus bus = new EventBus();
        bus.register(
            new Object() {
              @Subscribe
              public void accept(String str) {
                holder.set(str);
                deliveries.incrementAndGet();
              }
            });
    
        String EVENT = "Hello!";
        bus.post(EVENT);
    
        assertEquals("Only one event should be delivered.", 1, deliveries.get());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/TestingRemovalListeners.java

        private final AtomicInteger count = new AtomicInteger();
        private volatile RemovalNotification<K, V> lastNotification;
    
        @Override
        public void onRemoval(RemovalNotification<K, V> notification) {
          count.incrementAndGet();
          lastNotification = notification;
        }
    
        public int getCount() {
          return count.get();
        }
    
        public K getLastEvictedKey() {
          return lastNotification.getKey();
        }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

                        long delta = random.nextInt(deltaRange);
                        int behavior = random.nextInt(10);
                        switch (behavior) {
                          case 0:
                            map.incrementAndGet(key);
                            threadSum++;
                            break;
                          case 1:
                            map.decrementAndGet(key);
                            threadSum--;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java

                .build(
                    new CacheLoader<Integer, Integer>() {
                      @Override
                      public Integer load(Integer from) {
                        return (int) misses.incrementAndGet();
                      }
                    });
    
        // To start, fill up the cache.
        // Each miss both increments the counter and causes the map to grow by one,
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/helper/AbstractConfigHelperTest.java

            private final AtomicInteger loadCallCount = new AtomicInteger(0);
            private LoadCallback loadCallback = () -> 0;
    
            @Override
            public int load() {
                loadCallCount.incrementAndGet();
                return loadCallback.call();
            }
    
            public void setLoadCallback(LoadCallback callback) {
                this.loadCallback = callback;
            }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 00:03:47 UTC 2025
    - 4.7K bytes
    - Viewed (0)
Back to top