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

ResourcePoolsBuilder.with介绍

[英]Add the ResourcePool of ResourceType in the returned builder.
[中]在返回的生成器中添加ResourceType的ResourcePool。

代码示例

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

/**
 * Convenience method to add a {@link org.ehcache.config.ResourceType.Core#HEAP heap} pool.
 *
 * @param size the pool size
 * @param unit the pool size unit
 * @return a new builder with the added pool
 *
 * @throws IllegalArgumentException if the set of resource pools already contains a heap resource
 */
public ResourcePoolsBuilder heap(long size, ResourceUnit unit) {
 return with(ResourceType.Core.HEAP, size, unit, false);
}

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

/**
 * Convenience method to add an {@link org.ehcache.config.ResourceType.Core#OFFHEAP offheap} pool.
 *
 * @param size the pool size
 * @param unit the pool size unit
 * @return a new builder with the added pool
 *
 * @throws IllegalArgumentException if the set of resource pools already contains an offheap resource
 */
public ResourcePoolsBuilder offheap(long size, MemoryUnit unit) {
 return with(ResourceType.Core.OFFHEAP, size, unit, false);
}

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

/**
 * Convenience method to add a {@link org.ehcache.config.ResourceType.Core#DISK disk} pool specifying persistence.
 *
 * @param size the pool size
 * @param unit the pool size unit
 * @param persistent if the pool is persistent or not
 * @return a new builder with the added pool
 *
 * @throws IllegalArgumentException if the set of resource pools already contains a disk resource
 */
public ResourcePoolsBuilder disk(long size, MemoryUnit unit, boolean persistent) {
 return with(ResourceType.Core.DISK, size, unit, persistent);
}

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

/**
 * Convenience method to get a builder from an existing {@link ResourcePools}.
 *
 * @param pools the resource pools to build from
 * @return a new builder with configuration matching the provided resource pools
 */
public static ResourcePoolsBuilder newResourcePoolsBuilder(ResourcePools pools) {
 ResourcePoolsBuilder poolsBuilder = new ResourcePoolsBuilder();
 for (ResourceType<?> currentResourceType : pools.getResourceTypeSet()) {
  poolsBuilder = poolsBuilder.with(pools.getPoolForResource(currentResourceType));
 }
 return poolsBuilder;
}

代码示例来源：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> getSharedStoreConfig(
  String targetPool, 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.clusteredShared(targetPool)))
   .build(),
  StoreEventSourceConfiguration.DEFAULT_DISPATCHER_CONCURRENCY,
  serializationProvider.createKeySerializer(keyType, getClass().getClassLoader()),
  serializationProvider.createValueSerializer(valueType, getClass().getClassLoader()));
}

代码示例来源：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 <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

@Test
public void testPreExistingWith() throws Exception {
 ResourcePoolsBuilder builder = ResourcePoolsBuilder.newResourcePoolsBuilder();
 builder = builder.heap(8, MemoryUnit.MB);
 try {
  builder.with(new SizedResourcePoolImpl<>(HEAP, 16, MemoryUnit.MB, false));
  fail("Expecting IllegalArgumentException");
 } catch (IllegalArgumentException e) {
  assertThat(e.getMessage(),
    Matchers.containsString("Can not add 'Pool {16 MB heap}'; configuration already contains 'Pool {8 MB heap}'"));
 }
}

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

@Test
public void testSingleTier() {
 // tag::clusteredOnly[]
 CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class, // <1>
  ResourcePoolsBuilder.newResourcePoolsBuilder()
   .with(ClusteredResourcePoolBuilder.clusteredDedicated(2, MemoryUnit.GB))); // <2>
 // end::clusteredOnly[]
}

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

@Override
 Cache<Long, String> runTask() throws Exception {
  return cacheManager.createCache("simple-cache",
    CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class,
      ResourcePoolsBuilder.newResourcePoolsBuilder()
        .with(ClusteredResourcePoolBuilder.clusteredDedicated(4, MemoryUnit.MB))));
 }
})

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

private CacheManagerBuilder<PersistentCacheManager> getPersistentCacheManagerCacheManagerBuilder(DedicatedClusteredResourcePool resourcePool) {
 ClusteringServiceConfigurationBuilder clusteringServiceConfigurationBuilder = ClusteringServiceConfigurationBuilder.cluster(CLUSTER.getConnectionURI().resolve("/crud-cm"));
 ServerSideConfigurationBuilder serverSideConfigurationBuilder = clusteringServiceConfigurationBuilder.autoCreate()
  .defaultServerResource("primary-server-resource");
 return CacheManagerBuilder.newCacheManagerBuilder()
  .with(serverSideConfigurationBuilder)
  .withCache("test-cache", CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class,
   ResourcePoolsBuilder.newResourcePoolsBuilder()
    .with(resourcePool)
  ).add(new ClusteredStoreConfiguration(Consistency.EVENTUAL)));
}

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

@Test
 public void testClusteredSharedResourcePoolUpdation() throws Exception {
  expectedException.expect(UnsupportedOperationException.class);
  expectedException.expectMessage("Updating CLUSTERED resource is not supported");
  sharedCache.getRuntimeConfiguration().updateResourcePools(
   ResourcePoolsBuilder.newResourcePoolsBuilder()
    .with(ClusteredResourcePoolBuilder.clusteredShared("resource-pool-a"))
    .build()
  );
 }
}

代码示例来源：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

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 CacheConfiguration<Long, String> getCacheConfiguration(TestCacheLoaderWriter loaderWriter) {
 return newCacheConfigurationBuilder(Long.class, String.class,
     ResourcePoolsBuilder
         .newResourcePoolsBuilder().heap(10, EntryUnit.ENTRIES).offheap(1, MemoryUnit.MB)
         .with(ClusteredResourcePoolBuilder.clusteredDedicated("primary-server-resource", 2, MemoryUnit.MB)))
     .withLoaderWriter(loaderWriter)
     .withResilienceStrategy(new ThrowingResilienceStrategy<>())
     .build();
}

代码示例来源：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

private CacheConfiguration<Long, String> getCacheConfig() {
 return CacheConfigurationBuilder
     .newCacheConfigurationBuilder(Long.class, String.class,
         ResourcePoolsBuilder
             .heap(20)
             .with(ClusteredResourcePoolBuilder.clusteredDedicated("primary-server-resource", 2, MemoryUnit.MB)))
     .withLoaderWriter(new TestCacheLoaderWriter(sor))
     .add(ClusteredStoreConfigurationBuilder.withConsistency(cacheConsistency))
     .withResilienceStrategy(new ThrowingResilienceStrategy<>())
     .build();
}

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

@Test
public void testCreateDestroyCreate() throws Exception {
 PersistentCacheManager cacheManager = newCacheManagerBuilder().with(cluster(CLUSTER_URI).autoCreate()
  .defaultServerResource("primary-server-resource"))
  .withCache("my-cache", newCacheConfigurationBuilder(Long.class, String.class, heap(10).with(ClusteredResourcePoolBuilder
   .clusteredDedicated(2, MemoryUnit.MB))))
  .build(true);
 cacheManager.close();
 cacheManager.destroy();
 cacheManager.init();
}

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

private CacheManagerBuilder<PersistentCacheManager> cacheManagerBuilder(ExpiryPolicy<Object, Object> expiry) {
 return newCacheManagerBuilder()
   .using(statisticsService)
   .using(new TimeSourceConfiguration(timeSource))
   .with(cluster(CLUSTER_URI).autoCreate())
   .withCache(CLUSTERED_CACHE, newCacheConfigurationBuilder(Long.class, String.class,
     ResourcePoolsBuilder.newResourcePoolsBuilder()
       .heap(10, EntryUnit.ENTRIES)
       .offheap(6, MemoryUnit.MB)
       .with(ClusteredResourcePoolBuilder.clusteredDedicated("primary-server-resource", 8, MemoryUnit.MB)))
      .withExpiry(expiry)
     .add(ClusteredStoreConfigurationBuilder.withConsistency(Consistency.STRONG)));
}