org.infinispan.Cache.containsKey()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(230)

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

Cache.containsKey介绍

暂无

代码示例

代码示例来源：origin: wildfly/wildfly

@Override
public boolean containsBean(I id) {
  return this.cache.containsKey(this.beanFactory.createKey(id));
}

代码示例来源：origin: apiman/apiman

/**
 * @see java.util.Map#containsKey(java.lang.Object)
 */
@Override
public boolean containsKey(Object key) {
  return cache.containsKey(key);
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
  public boolean isSatisfied() throws Exception {
   return cache1.containsKey(magicKey) && cache2.containsKey(magicKey);
  }
});

代码示例来源：origin: org.infinispan/infinispan-core

public void testLocksOnEvictNonexistent() throws Exception {
 LockTestData tl = lockTestData;
 Cache<String, String> cache = tl.cache;
 TransactionManager tm = tl.tm;
 assert !cache.containsKey("k") : "Should not exist";
 tm.begin();
 cache.evict("k");
 assertNotLocked("k");
 tm.commit();
 assert !cache.containsKey("k") : "Should not exist";
 assertNoLocks();
}

代码示例来源：origin: org.infinispan/infinispan-query

@Override
  public void call() {
   Cache<Integer, Person> cache = cm.getCache();
   CacheListener cacheListener = new CacheListener();
   cache.addListener(cacheListener);
   assertTrue(cache.containsKey(1));
   assertTrue(cache.containsKey(2));
   assertEquals(cacheListener.numberOfPassivations(), 0);
   assertEquals(cacheListener.numberOfActivations(), 0);
   assertFalse(luceneIndexTracker.indexChanged());
  }
});

代码示例来源：origin: org.infinispan/infinispan-core

public void testRemoveViaComputeOnEvictedEntry() throws Exception {
 Cache<String, String> testCache = cacheManager.getCache(CACHE_NAME);
 for (int i = 0; i < EVICTION_MAX_ENTRIES + 1; i++) {
   testCache.put("key" + i, "value" + i);
 }
 String evictedKey = evictionListener.getEvictedKey();
 assertTrue(isEntryInStore(evictedKey));
 testCache.compute(evictedKey, (k ,v) -> null);
 assertFalse(testCache.containsKey(evictedKey));
 assertFalse(isEntryInStore(evictedKey));
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testRemovalOfEvictedEntry() throws Exception {
 Cache<String, String> testCache = cacheManager.getCache(CACHE_NAME);
 for (int i = 0; i < EVICTION_MAX_ENTRIES + 1; i++) {
   testCache.put("key" + i, "value" + i);
 }
 String evictedKey = evictionListener.getEvictedKey();
 assertTrue(isEntryInStore(evictedKey));
 testCache.remove(evictedKey);
 assertFalse(testCache.containsKey(evictedKey));
 assertNull(testCache.get(evictedKey));
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testMultipleIdenticalPutForExternalReadCalls() {
 final Cache<String, String> cache1 = cache(0, CACHE_NAME);
 final Cache<String, String> cache2 = cache(1, CACHE_NAME);
 cache1.putForExternalRead(key, value);
 // wait for command the finish executing asynchronously
 eventually(() -> cache1.containsKey(key) && cache2.containsKey(key));
 cache1.putForExternalRead(key, value2);
 assertEquals(value, cache1.get(key));
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testIntIterator() {
 Cache<Integer, String> cache = getCache(0);
 testIntOperation(() -> {
   PrimitiveIterator.OfInt iterator = createStream(cache.entrySet()).mapToInt(toInt).iterator();
   AtomicInteger count = new AtomicInteger();
   iterator.forEachRemaining((int e) -> {
    assertTrue(cache.containsKey(e));
    count.addAndGet(e);
   });
   return count.get();
 }, cache);
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testLongIterator() {
 Cache<Long, String> cache = getCache(0);
 testLongOperation(() -> {
   PrimitiveIterator.OfLong iterator = createStream(cache.entrySet()).mapToLong(toLong).iterator();
   AtomicLong count = new AtomicLong();
   iterator.forEachRemaining((long e) -> {
    assertTrue(cache.containsKey(e));
    count.addAndGet(e);
   });
   return count.get();
 }, cache);
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testIntToArray() {
 Cache<Integer, String> cache = getCache(0);
 int range = 10;
 // First populate the cache with a bunch of values
 IntStream.range(0, range).boxed().forEach(i -> cache.put(i, i + "-value"));
 assertEquals(range, cache.size());
 CacheSet<Map.Entry<Integer, String>> entrySet = cache.entrySet();
 int[] array = createStream(entrySet).mapToInt(toInt).toArray();
 assertEquals(cache.size(), array.length);
 Spliterator.OfInt spliterator = Spliterators.spliterator(array, Spliterator.DISTINCT);
 StreamSupport.intStream(spliterator, true).forEach(e -> assertTrue(cache.containsKey(e)));
}

代码示例来源：origin: org.infinispan/infinispan-cli-interpreter

public void testDangling() throws Exception {
 Interpreter interpreter = getInterpreter();
 String sessionId = interpreter.createSessionId("default");
 interpreter.execute(sessionId, "begin; put 'a' 'a';");
 assertNull(cache.getAdvancedCache().getTransactionManager().getTransaction());
 assertFalse(cache.containsKey("a"));
 interpreter.execute(sessionId, "start; put 'a' 'a';");
 assertNull(cache.getAdvancedCache().getBatchContainer().getBatchTransaction());
 assertFalse(cache.containsKey("a"));
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testEvictWithMarshalledValueKey() {
 Cache<Object, Object> cache1 = cache(0, "replSync");
 cache(1, "replSync");
 Pojo pojo = new Pojo();
 cache1.put(pojo, pojo);
 cache1.evict(pojo);
 assertTrue(!cache1.containsKey(pojo));
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testExpirationMaxIdleInOps() throws Exception {
 for (int i = 0; i < SIZE; i++) {
   cache.put("key-" + i, "value-" + i,-1, null, 1, TimeUnit.MILLISECONDS);
 }
 timeService.advance(2);
 for (int i = 0; i < SIZE; i++) {
   assertFalse(cache.containsKey("key-" + 1));
   assertNull(cache.get("key-" + i));
   assertNull(cache.remove("key-" + i));
 }
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testExpirationLifespanInOps() throws Exception {
 for (int i = 0; i < SIZE; i++) {
   cache.put("key-" + i, "value-" + i, 1, TimeUnit.MILLISECONDS);
 }
 timeService.advance(2);
 for (int i = 0; i < SIZE; i++) {
   assertFalse(cache.containsKey("key-" + 1));
   assertNull(cache.get("key-" + i));
   assertNull(cache.remove("key-" + i));
 }
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testDoubleIterator() {
 Cache<Double, String> cache = getCache(0);
 testDoubleOperation(() -> {
   PrimitiveIterator.OfDouble iterator = createStream(cache.entrySet()).mapToDouble(toDouble).iterator();
   DoubleSummaryStatistics doubleSummaryStatistics = new DoubleSummaryStatistics();
   iterator.forEachRemaining((double e) -> {
    assertTrue(cache.containsKey(e));
    doubleSummaryStatistics.accept(e);
   });
   return doubleSummaryStatistics;
 }, cache);
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testLongToArray() {
 Cache<Long, String> cache = getCache(0);
 int range = 10;
 // First populate the cache with a bunch of values
 LongStream.range(0, range).boxed().forEach(i -> cache.put(i, i + "-value"));
 assertEquals(range, cache.size());
 CacheSet<Map.Entry<Long, String>> entrySet = cache.entrySet();
 long[] array = createStream(entrySet).mapToLong(toLong).toArray();
 assertEquals(cache.size(), array.length);
 Spliterator.OfLong spliterator = Spliterators.spliterator(array, Spliterator.DISTINCT);
 StreamSupport.longStream(spliterator, true).forEach(e -> assertTrue(cache.containsKey(e)));
}

代码示例来源：origin: org.infinispan/infinispan-server-hotrod

public void testPutOnDefaultCache(Method m) {
   TestResponse resp = client().execute(0xA0, (byte) 0x01, "", k(m), 0, 0, v(m), 0, (byte) 1, 0);
   assertStatus(resp, Success);
   assertHotRodEquals(cacheManager, ANOTHER_CACHE, k(m), v(m));
   assertFalse(cacheManager.getCache().containsKey(k(m)));
  }
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testDoubleToArray() {
 Cache<Double, String> cache = getCache(0);
 int range = 10;
 // First populate the cache with a bunch of values
 DoubleStream.iterate(0.0, d -> d + .5).limit(10).boxed().forEach(i -> cache.put(i, i + "-value"));
 assertEquals(range, cache.size());
 CacheSet<Map.Entry<Double, String>> entrySet = cache.entrySet();
 double[] array = createStream(entrySet).mapToDouble(toDouble).toArray();
 assertEquals(cache.size(), array.length);
 Spliterator.OfDouble spliterator = Spliterators.spliterator(array, Spliterator.DISTINCT);
 StreamSupport.doubleStream(spliterator, true).forEach(e -> assertTrue(cache.containsKey(e)));
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testEvictInBatch() throws Exception {
   cache().put("myKey", "myValue");

   cache().getAdvancedCache().startBatch();
   //this should execute non-transactionally despite the batch transaction and should not fail as in https://issues.jboss.org/browse/ISPN-2845
   cache().evict("myKey");
   cache().getAdvancedCache().endBatch(true);

   assertFalse(cache().containsKey("myKey"));
  }
}

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

Cache

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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