org.ehcache.config.builders.ResourcePoolsBuilder.newResourcePoolsBuilder()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(92)

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

ResourcePoolsBuilder.newResourcePoolsBuilder介绍

[英]Creates a new ResourcePoolsBuilder.
[中]创建一个新的ResourcePoolsBuilder。

代码示例

代码示例来源:origin: ehcache/ehcache3

@Parameters
public static Collection<Object[]> data() {
 return asList(new Object[][] {
  { newResourcePoolsBuilder().heap(100, ENTRIES) },
  { newResourcePoolsBuilder().offheap(5, MB) },
  { newResourcePoolsBuilder().disk(10, MB) },
  { newResourcePoolsBuilder().heap(100, ENTRIES).offheap(5, MB) },
  { newResourcePoolsBuilder().heap(100, ENTRIES).disk(10, MB) },
  { newResourcePoolsBuilder().heap(100, ENTRIES).offheap(5, MB).disk(10, MB) },
 });
}

代码示例来源:origin: ehcache/ehcache3

private ResourcePools buildResourcePools(Comparable<Long> capacityConstraint) {
 if (capacityConstraint == null) {
  return newResourcePoolsBuilder().heap(Long.MAX_VALUE, EntryUnit.ENTRIES).build();
 } else {
  return newResourcePoolsBuilder().heap((Long)capacityConstraint, EntryUnit.ENTRIES).build();
 }
}

代码示例来源:origin: ehcache/ehcache3

private ResourcePools buildResourcePools(Comparable<Long> capacityConstraint) {
 if (capacityConstraint == null) {
  return newResourcePoolsBuilder().heap(Long.MAX_VALUE, EntryUnit.ENTRIES).build();
 } else {
  return newResourcePoolsBuilder().heap((Long)capacityConstraint, EntryUnit.ENTRIES).build();
 }
}

代码示例来源:origin: ehcache/ehcache3

private ResourcePools buildResourcePools(Comparable<Long> capacityConstraint) {
 if (capacityConstraint == null) {
  capacityConstraint = 10L;
 }
 return newResourcePoolsBuilder().heap((Long)capacityConstraint, MemoryUnit.MB).build();
}

代码示例来源:origin: ehcache/ehcache3

@Parameterized.Parameters
public static ResourcePoolsBuilder[] data() {
 return new ResourcePoolsBuilder[]{
     ResourcePoolsBuilder.newResourcePoolsBuilder()
         .with(clusteredDedicated("primary-server-resource", 1, MemoryUnit.MB)),
     ResourcePoolsBuilder.newResourcePoolsBuilder()
         .heap(10, EntryUnit.ENTRIES)
         .with(clusteredDedicated("primary-server-resource", 1, MemoryUnit.MB))
 };
}

代码示例来源:origin: ehcache/ehcache3

private <K, V> Store.Configuration<K, V> getDedicatedStoreConfig(
  String targetResource, DefaultSerializationProvider serializationProvider, Class<K> keyType, Class<V> valueType)
  throws org.ehcache.spi.serialization.UnsupportedTypeException {
 return new StoreConfigurationImpl<>(
  CacheConfigurationBuilder.newCacheConfigurationBuilder(keyType, valueType,
   ResourcePoolsBuilder.newResourcePoolsBuilder()
    .with(ClusteredResourcePoolBuilder.clusteredDedicated(targetResource, 8, MemoryUnit.MB)))
   .build(),
  StoreEventSourceConfiguration.DEFAULT_DISPATCHER_CONCURRENCY,
  serializationProvider.createKeySerializer(keyType, getClass().getClassLoader()),
  serializationProvider.createValueSerializer(valueType, getClass().getClassLoader()));
}

代码示例来源:origin: ehcache/ehcache3

private FileBasedPersistenceContext getPersistenceContext() {
 try {
  CacheConfiguration<?, ?> cacheConfiguration = mock(CacheConfiguration.class);
  when(cacheConfiguration.getResourcePools()).thenReturn(newResourcePoolsBuilder().disk(1, MB, false).build());
  PersistenceSpaceIdentifier<?> space = diskResourceService.getPersistenceSpaceIdentifier("cache", cacheConfiguration);
  return diskResourceService.createPersistenceContextWithin(space, "store");
 } catch (CachePersistenceException e) {
  throw new AssertionError(e);
 }
}

代码示例来源:origin: ehcache/ehcache3

private <K, V> Store.Configuration<K, V> getDedicatedStoreConfig(
  String targetResource, DefaultSerializationProvider serializationProvider, Class<K> keyType, Class<V> valueType)
  throws org.ehcache.spi.serialization.UnsupportedTypeException {
 return new StoreConfigurationImpl<>(
  CacheConfigurationBuilder.newCacheConfigurationBuilder(keyType, valueType,
   ResourcePoolsBuilder.newResourcePoolsBuilder()
    .with(ClusteredResourcePoolBuilder.clusteredDedicated(targetResource, 8, MemoryUnit.MB)))
   .build(),
  StoreEventSourceConfiguration.DEFAULT_DISPATCHER_CONCURRENCY,
  serializationProvider.createKeySerializer(keyType, getClass().getClassLoader()),
  serializationProvider.createValueSerializer(valueType, getClass().getClassLoader()));
}

代码示例来源:origin: ehcache/ehcache3

@Override
protected void updateStoreCapacity(OnHeapStore<?, ?> store, int newCapacity) {
 CacheConfigurationChangeListener listener = store.getConfigurationChangeListeners().get(0);
 listener.cacheConfigurationChange(new CacheConfigurationChangeEvent(CacheConfigurationProperty.UPDATE_SIZE,
   newResourcePoolsBuilder().heap(100, EntryUnit.ENTRIES).build(),
   newResourcePoolsBuilder().heap(newCapacity, EntryUnit.ENTRIES).build()));
}

代码示例来源:origin: ben-manes/caffeine

public Ehcache3Policy(Config config) {
 policyStats = new PolicyStats("product.Ehcache3");
 BasicSettings settings = new BasicSettings(config);
 CacheManager cacheManager = CacheManagerBuilder.newCacheManagerBuilder().build(true);
 cache = cacheManager.createCache("ehcache3",
   CacheConfigurationBuilder.newCacheConfigurationBuilder(Object.class, Object.class,
     ResourcePoolsBuilder.newResourcePoolsBuilder()
       .heap(settings.maximumSize(), EntryUnit.ENTRIES))
     .build());
 maximumSize = settings.maximumSize();
}

代码示例来源:origin: ehcache/ehcache3

private void testSerializerWithByRefHeapCache(Serializer<Long> serializer) throws Exception {
 CacheManagerBuilder<CacheManager> cmBuilder =
  newCacheManagerBuilder()
   .withCache("heapByRefCache",
    newCacheConfigurationBuilder(Long.class, Person.class, newResourcePoolsBuilder().heap(10, EntryUnit.ENTRIES))
     .withKeySerializer(serializer)
   );
 cmBuilder.build(true);
}

代码示例来源:origin: ehcache/ehcache3

private void testSerializerWithOffheapCache(Serializer<Long> serializer) throws Exception {
 CacheManagerBuilder<CacheManager> cmBuilder =
  newCacheManagerBuilder()
   .withCache("offheapCache",
    newCacheConfigurationBuilder(Long.class, Person.class, newResourcePoolsBuilder().offheap(2, MemoryUnit.MB))
     .withKeySerializer(serializer)
   );
 cmBuilder.build(true);
}

代码示例来源:origin: ehcache/ehcache3

private void testSerializerWithHeapOffheapCache(Serializer<Long> serializer) throws Exception {
 CacheManagerBuilder<CacheManager> cmBuilder =
  newCacheManagerBuilder()
   .withCache("heapOffheapCache",
    newCacheConfigurationBuilder(Long.class, Person.class, newResourcePoolsBuilder().heap(10, EntryUnit.ENTRIES).offheap(2, MemoryUnit.MB))
     .withKeySerializer(serializer)
   );
 cmBuilder.build(true);
}

代码示例来源:origin: ehcache/ehcache3

@Test
public void persistentCacheManager() throws Exception {
 // tag::persistentCacheManager[]
 PersistentCacheManager persistentCacheManager = CacheManagerBuilder.newCacheManagerBuilder() // <1>
  .with(CacheManagerBuilder.persistence(new File(getStoragePath(), "myData"))) // <2>
  .withCache("persistent-cache", CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class,
   ResourcePoolsBuilder.newResourcePoolsBuilder().disk(10, MemoryUnit.MB, true)) // <3>
  )
  .build(true);
 persistentCacheManager.close();
 // end::persistentCacheManager[]
}

代码示例来源:origin: ehcache/ehcache3

@Test
public void testClusteredDedicatedResourcePoolUpdation() throws Exception {
 expectedException.expect(UnsupportedOperationException.class);
 expectedException.expectMessage("Updating CLUSTERED resource is not supported");
 dedicatedCache.getRuntimeConfiguration().updateResourcePools(
  ResourcePoolsBuilder.newResourcePoolsBuilder()
   .with(ClusteredResourcePoolBuilder.clusteredDedicated("primary-server-resource", 8, MemoryUnit.MB))
   .build()
 );
}

代码示例来源:origin: ehcache/ehcache3

public static void testByteSizedOnHeapInOsgi() {
  CacheManager cacheManager = CacheManagerBuilder.newCacheManagerBuilder()
   .withCache("myCache", newCacheConfigurationBuilder(Long.class, String.class, newResourcePoolsBuilder().heap(10, MemoryUnit.KB))
    .build())
   .build(true);
  Cache<Long, String> cache = cacheManager.getCache("myCache", Long.class, String.class);
  cache.put(42L, "I am out of heap!!");
  cache.get(42L);
 }
}

代码示例来源:origin: ehcache/ehcache3

private PersistentCacheManager createCacheManager() {
 CacheManagerBuilder<PersistentCacheManager> clusteredCacheManagerBuilder =
  newCacheManagerBuilder()
   .with(cluster(CLUSTER.getConnectionURI().resolve(CACHE_MANAGER_NAME)).autoCreate())
   .withCache(CACHE_NAME, newCacheConfigurationBuilder(Long.class, String.class,
    ResourcePoolsBuilder.newResourcePoolsBuilder().heap(100, EntryUnit.ENTRIES)
     .with(ClusteredResourcePoolBuilder.clusteredDedicated("primary-server-resource", 2, MemoryUnit.MB)))
    .add(new ClusteredStoreConfiguration(Consistency.STRONG)));
 return clusteredCacheManagerBuilder.build(true);
}

代码示例来源:origin: ehcache/ehcache3

private void initCacheManager(File file) {
 persistentCacheManager = CacheManagerBuilder.newCacheManagerBuilder()
   .with(new CacheManagerPersistenceConfiguration(file))
   .withCache(PERSISTENT_CACHE, CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class,
     newResourcePoolsBuilder()
       .heap(10, EntryUnit.ENTRIES)
       .disk(10L, MemoryUnit.MB, true))
     .build())
   .build(true);
}

代码示例来源:origin: ehcache/ehcache3

public static void testProgrammaticClusteredCache(OsgiTestUtils.Cluster cluster) throws Throwable {
 try (PersistentCacheManager cacheManager = newCacheManagerBuilder()
  .with(cluster(cluster.getConnectionUri()).autoCreate())
  .withCache("clustered-cache", newCacheConfigurationBuilder(Long.class, String.class,
   newResourcePoolsBuilder().with(clusteredDedicated("main", 2, MemoryUnit.MB))))
  .build(true)) {
  final Cache<Long, String> cache = cacheManager.getCache("clustered-cache", Long.class, String.class);
  cache.put(1L, "value");
  assertThat(cache.get(1L), is("value"));
 }
}

代码示例来源:origin: ehcache/ehcache3

public static void testOffHeapInOsgi() {
 CacheManager cacheManager = CacheManagerBuilder.newCacheManagerBuilder()
  .withCache("myCache", newCacheConfigurationBuilder(Long.class, String.class, newResourcePoolsBuilder().heap(10, EntryUnit.ENTRIES).offheap(10, MemoryUnit.MB))
   .build())
  .build(true);
 Cache<Long, String> cache = cacheManager.getCache("myCache", Long.class, String.class);
 cache.put(42L, "I am out of heap!!");
 cache.get(42L);
}

相关文章