com.google.common.cache.Cache.asMap()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(278)

本文整理了Java中com.google.common.cache.Cache.asMap()方法的一些代码示例，展示了Cache.asMap()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Cache.asMap()方法的具体详情如下：
包路径：com.google.common.cache.Cache
类名称：Cache
方法名：asMap

Cache.asMap介绍

[英]Returns a view of the entries stored in this cache as a thread-safe map. Modifications made to the map directly affect the cache.

Iterators from the returned map are at least weakly consistent: they are safe for concurrent use, but if the cache is modified (including by eviction) after the iterator is created, it is undefined which of the changes (if any) will be reflected in that iterator.
[中]作为线程安全映射返回存储在此缓存中的项的视图。对映射所做的修改直接影响缓存。
返回映射中的迭代器至少是弱一致的：它们对于并发使用是安全的，但是如果在创建迭代器之后修改了缓存（包括通过逐出），则未定义哪些更改（如果有的话）将反映在该迭代器中。

代码示例

代码示例来源：origin: google/guava

@Override
public ConcurrentMap<K, V> asMap() {
 return delegate().asMap();
}

代码示例来源：origin: google/guava

public void testAsMap() {
 when(mock.asMap()).thenReturn(null);
 assertNull(forward.asMap());
}

代码示例来源：origin: google/guava

static void checkEmpty(Cache<?, ?> cache) {
 assertEquals(0, cache.size());
 assertFalse(cache.asMap().containsKey(null));
 assertFalse(cache.asMap().containsKey(6));
 assertFalse(cache.asMap().containsValue(null));
 assertFalse(cache.asMap().containsValue(6));
 checkEmpty(cache.asMap());
}

代码示例来源：origin: google/guava

public void testInvalidate() {
 Cache<Integer, Integer> cache = CacheBuilder.newBuilder().build();
 cache.put(654, 2675);
 cache.put(2456, 56);
 cache.put(2, 15);
 cache.invalidate(654);
 assertFalse(cache.asMap().containsKey(654));
 assertTrue(cache.asMap().containsKey(2456));
 assertTrue(cache.asMap().containsKey(2));
}

代码示例来源：origin: google/guava

public void testValuesIsNotASet() {
 assertFalse(CacheBuilder.newBuilder().build().asMap().values() instanceof Set);
}

代码示例来源：origin: google/guava

public void testComputeIfAbsentEviction() {
 // b/80241237
 Cache<String, String> c = CacheBuilder.newBuilder().maximumSize(1).build();
 assertThat(c.asMap().computeIfAbsent("hash-1", k -> "")).isEqualTo("");
 assertThat(c.asMap().computeIfAbsent("hash-1", k -> "")).isEqualTo("");
 assertThat(c.asMap().computeIfAbsent("hash-1", k -> "")).isEqualTo("");
 assertThat(c.size()).isEqualTo(1);
 assertThat(c.asMap().computeIfAbsent("hash-2", k -> "")).isEqualTo("");
}

代码示例来源：origin: ReactiveX/RxJava

@Override
  public Map<Integer, Object> apply(final Consumer<Object> action) throws Exception {
    return CacheBuilder.newBuilder() //
        .expireAfterAccess(5, TimeUnit.SECONDS).removalListener(new RemovalListener<Object, Object>() {
          @Override
          public void onRemoval(RemovalNotification<Object, Object> notification) {
            try {
              action.accept(notification.getValue());
            } catch (Exception ex) {
              throw new RuntimeException(ex);
            }
          }
        }).ticker(testTicker) //
        .<Integer, Object>build().asMap();
  }
};

代码示例来源：origin: google/guava

public void testComputeIfAbsent_RemovalListener() {
 List<RemovalNotification<Object, Object>> notifications = new ArrayList<>();
 RemovalListener<Object, Object> removalListener =
   new RemovalListener<Object, Object>() {
    @Override
    public void onRemoval(RemovalNotification<Object, Object> notification) {
     notifications.add(notification);
    }
   };
 Cache<Object, Object> cache =
   CacheBuilder.newBuilder().removalListener(removalListener).build();
 cache.put("a", "b");
 cache.asMap().computeIfAbsent("a", k -> "c");
 assertTrue(notifications.toString(), notifications.isEmpty());
}

代码示例来源：origin: google/guava

public void testAsMapValues_iteratorRemove() {
  Cache<Integer, Integer> cache =
    CacheBuilder.newBuilder()
      .expireAfterWrite(1000, TimeUnit.MILLISECONDS)
      .ticker(fakeTicker)
      .build();

  cache.put(10, 20);
  Iterator<Integer> iterator = cache.asMap().values().iterator();
  iterator.next();
  iterator.remove();

  assertEquals(0, cache.size());
 }
}

代码示例来源：origin: google/guava

public void testComputeEviction() {
 // b/80241237
 Cache<String, String> c = CacheBuilder.newBuilder().maximumSize(1).build();
 assertThat(c.asMap().compute("hash-1", (k, v) -> "a")).isEqualTo("a");
 assertThat(c.asMap().compute("hash-1", (k, v) -> "b")).isEqualTo("b");
 assertThat(c.asMap().compute("hash-1", (k, v) -> "c")).isEqualTo("c");
 assertThat(c.size()).isEqualTo(1);
 assertThat(c.asMap().computeIfAbsent("hash-2", k -> "")).isEqualTo("");
}

代码示例来源：origin: google/guava

public void testAsMapKeySet_contains() {
 Cache<Integer, Integer> cache =
   CacheBuilder.newBuilder()
     .expireAfterWrite(1000, TimeUnit.MILLISECONDS)
     .ticker(fakeTicker)
     .build();
 cache.put(10, 20);
 fakeTicker.advance(500, TimeUnit.MILLISECONDS);
 cache.put(20, 22);
 cache.put(5, 10);
 fakeTicker.advance(501, TimeUnit.MILLISECONDS);
 assertTrue(cache.asMap().keySet().contains(20));
 assertTrue(cache.asMap().keySet().contains(5));
 assertFalse(cache.asMap().keySet().contains(10));
}

代码示例来源：origin: google/guava

public void testAsMapValues_contains() {
 Cache<Integer, Integer> cache =
   CacheBuilder.newBuilder()
     .expireAfterWrite(1000, TimeUnit.MILLISECONDS)
     .ticker(fakeTicker)
     .build();
 cache.put(10, 20);
 fakeTicker.advance(500, TimeUnit.MILLISECONDS);
 cache.put(20, 22);
 cache.put(5, 10);
 fakeTicker.advance(501, TimeUnit.MILLISECONDS);
 assertTrue(cache.asMap().values().contains(22));
 assertTrue(cache.asMap().values().contains(10));
 assertFalse(cache.asMap().values().contains(20));
}

代码示例来源：origin: google/guava

public void testPutAll() {
 Cache<Integer, Integer> cache = CacheBuilder.newBuilder().build();
 cache.putAll(ImmutableMap.of(10, 20, 30, 50, 60, 90));
 assertEquals(Integer.valueOf(20), cache.getIfPresent(10));
 assertEquals(Integer.valueOf(50), cache.getIfPresent(30));
 assertEquals(Integer.valueOf(90), cache.getIfPresent(60));
 cache.asMap().putAll(ImmutableMap.of(10, 50, 30, 20, 60, 70, 5, 5));
 assertEquals(Integer.valueOf(50), cache.getIfPresent(10));
 assertEquals(Integer.valueOf(20), cache.getIfPresent(30));
 assertEquals(Integer.valueOf(70), cache.getIfPresent(60));
 assertEquals(Integer.valueOf(5), cache.getIfPresent(5));
}

代码示例来源：origin: google/guava

public void testAsMap_containsKey() {
 Cache<Integer, Integer> cache =
   CacheBuilder.newBuilder()
     .expireAfterWrite(20000, TimeUnit.MILLISECONDS)
     .ticker(fakeTicker)
     .build();
 cache.put(654, 2675);
 fakeTicker.advance(10000, TimeUnit.MILLISECONDS);
 cache.put(2456, 56);
 cache.put(2, 15);
 fakeTicker.advance(10001, TimeUnit.MILLISECONDS);
 assertTrue(cache.asMap().containsKey(2));
 assertTrue(cache.asMap().containsKey(2456));
 assertFalse(cache.asMap().containsKey(654));
}

代码示例来源：origin: google/guava

public void testAsMapKeySet() {
 Cache<Integer, Integer> cache =
   CacheBuilder.newBuilder()
     .expireAfterWrite(1000, TimeUnit.MILLISECONDS)
     .ticker(fakeTicker)
     .build();
 cache.put(10, 20);
 fakeTicker.advance(500, TimeUnit.MILLISECONDS);
 cache.put(20, 22);
 cache.put(5, 10);
 fakeTicker.advance(501, TimeUnit.MILLISECONDS);
 Set<Integer> foundKeys = new HashSet<>(cache.asMap().keySet());
 assertEquals(ImmutableSet.of(20, 5), foundKeys);
}

代码示例来源：origin: google/guava

public void testComputeIfPresent() {
 cache.put(key, "1");
 // simultaneous update for same key, expect count successful updates
 doParallelCacheOp(
   count,
   n -> {
    cache.asMap().computeIfPresent(key, (k, v) -> v + delimiter + n);
   });
 assertEquals(1, cache.size());
 assertThat(cache.getIfPresent(key).split(delimiter)).hasLength(count + 1);
}

代码示例来源：origin: google/guava

public void testComputeIfAbsent() {
 // simultaneous insertion for same key, expect 1 winner
 doParallelCacheOp(
   count,
   n -> {
    cache.asMap().computeIfAbsent(key, k -> "value" + n);
   });
 assertEquals(1, cache.size());
}

代码示例来源：origin: google/guava

public void testComputeExceptionally() {
  try {
   doParallelCacheOp(count, n -> {
    cache.asMap().compute(key, (k, v) -> { throw new RuntimeException(); });
   });
   fail("Should not get here");
  } catch (RuntimeException ex) {
  }
 }
}

代码示例来源：origin: google/guava

public void testUpdates() {
 cache.put(key, "1");
 // simultaneous update for same key, some null, some non-null
 doParallelCacheOp(
   count,
   n -> {
    cache.asMap().compute(key, (k, v) -> n % 2 == 0 ? v + delimiter + n : null);
   });
 assertTrue(1 >= cache.size());
}

代码示例来源：origin: google/guava

public void testCompute() {
 cache.put(key, "1");
 // simultaneous deletion
 doParallelCacheOp(
   count,
   n -> {
    cache.asMap().compute(key, (k, v) -> null);
   });
 assertEquals(0, cache.size());
}

内容来源于网络，如有侵权，请联系作者删除！

Cache

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com