本文整理了Java中org.ehcache.config.builders.ResourcePoolsBuilder.newResourcePoolsBuilder
方法的一些代码示例,展示了ResourcePoolsBuilder.newResourcePoolsBuilder
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ResourcePoolsBuilder.newResourcePoolsBuilder
方法的具体详情如下:
包路径:org.ehcache.config.builders.ResourcePoolsBuilder
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!