Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 21 for RemovalNotification (0.32 sec)

  1. guava/src/com/google/common/cache/RemovalListeners.java

       */
      public static <K, V> RemovalListener<K, V> asynchronous(
          RemovalListener<K, V> listener, Executor executor) {
        checkNotNull(listener);
        checkNotNull(executor);
        return (RemovalNotification<K, V> notification) ->
            executor.execute(() -> listener.onRemoval(notification));
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Oct 01 16:02:17 UTC 2021
    - 1.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/cache/RemovalListeners.java

       */
      public static <K, V> RemovalListener<K, V> asynchronous(
          RemovalListener<K, V> listener, Executor executor) {
        checkNotNull(listener);
        checkNotNull(executor);
        return (RemovalNotification<K, V> notification) ->
            executor.execute(() -> listener.onRemoval(notification));
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Oct 01 16:02:17 UTC 2021
    - 1.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

        // contain the computed value (b -> b), since the clear() happened before the computation
        // completed.
        assertEquals(1, listener.size());
        RemovalNotification<String, String> notification = listener.remove();
        assertEquals("a", notification.getKey());
        assertEquals("a", notification.getValue());
        assertEquals(1, cache.size());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Oct 03 20:10:02 UTC 2023
    - 23.2K bytes
    - Viewed (0)
  4. guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java

      private long currentTimeNanos() {
        return ticker.read();
      }
    
      private void alertListenerIfPresent(K key, V value, RemovalCause cause) {
        if (removalListener != null) {
          removalListener.onRemoval(RemovalNotification.create(key, value, cause));
        }
      }
    
      @SuppressWarnings("GoodTime") // timestamps as numeric primitives
      private V load(K key) throws ExecutionException {
        long startTime = ticker.read();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 27 19:19:19 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/CacheBuilderGwtTest.java

        final int[] stats = new int[4];
    
        RemovalListener<Integer, Integer> countingListener =
            new RemovalListener<Integer, Integer>() {
              @Override
              public void onRemoval(RemovalNotification<Integer, Integer> notification) {
                switch (notification.getCause()) {
                  case EXPIRED:
                    stats[0]++;
                    break;
                  case EXPLICIT:
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 15K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/CacheBuilderGwtTest.java

        final int[] stats = new int[4];
    
        RemovalListener<Integer, Integer> countingListener =
            new RemovalListener<Integer, Integer>() {
              @Override
              public void onRemoval(RemovalNotification<Integer, Integer> notification) {
                switch (notification.getCause()) {
                  case EXPIRED:
                    stats[0]++;
                    break;
                  case EXPLICIT:
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Aug 05 17:21:46 UTC 2022
    - 15.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

        RemovalListener<Integer, AtomicInteger> removalListener =
            new RemovalListener<Integer, AtomicInteger>() {
              @Override
              public void onRemoval(RemovalNotification<Integer, AtomicInteger> notification) {
                if (notification.wasEvicted()) {
                  evictionCount.incrementAndGet();
                  totalSum.addAndGet(notification.getValue().get());
                }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Aug 05 17:21:46 UTC 2022
    - 18.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/cache/LocalCache.java

          totalWeight -= weight;
          if (cause.wasEvicted()) {
            statsCounter.recordEviction();
          }
          if (map.removalNotificationQueue != DISCARDING_QUEUE) {
            RemovalNotification<K, V> notification = RemovalNotification.create(key, value, cause);
            map.removalNotificationQueue.offer(notification);
          }
        }
    
        /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 143.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/cache/LocalCache.java

          totalWeight -= weight;
          if (cause.wasEvicted()) {
            statsCounter.recordEviction();
          }
          if (map.removalNotificationQueue != DISCARDING_QUEUE) {
            RemovalNotification<K, V> notification = RemovalNotification.create(key, value, cause);
            map.removalNotificationQueue.offer(notification);
          }
        }
    
        /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/cache/CacheBuilder.java

              return new SimpleStatsCounter();
            }
          };
    
      enum NullListener implements RemovalListener<Object, Object> {
        INSTANCE;
    
        @Override
        public void onRemoval(RemovalNotification<Object, Object> notification) {}
      }
    
      enum OneWeigher implements Weigher<Object, Object> {
        INSTANCE;
    
        @Override
        public int weigh(Object key, Object value) {
          return 1;
        }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 15 16:12:13 UTC 2024
    - 44.8K bytes
    - Viewed (0)
Back to top