org.infinispan.counter.api.WeakCounter.add()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-27 11:17:05 30 4

/**
* Decrements the counter.
*/
default CompletableFuture<Void> decrement() {
 return add(-1L);
}

/**
* Increments the counter.
*/
default CompletableFuture<Void> increment() {
 return add(1L);
}

/**
* @see WeakCounter#add(long)
*/
@Override
public void add(long delta) {
 awaitCounterOperation(counter.add(delta));
}

void counterAddAndGet(HotRodHeader header, Subject subject, String counterName, long value) {
 applyCounter(header, counterName,
    (h, counter) -> counter.addAndGet(value).whenComplete((value1, throwable) -> longResultHandler(h, value1, throwable)),
    (h, counter) -> counter.add(value).whenComplete((value2, throwable1) -> longResultHandler(h, 0L, throwable1)));
}

@Override
public void add(WeakCounter counter, long delta, long result) {
 awaitCounterOperation(counter.add(delta));
}

counter3.add(5).thenAccept(aVoid -> System.out.println("Adding 5 to counter-3 completed!")).get();

counter3.add(5).thenAccept(aVoid -> System.out.println("Adding 5 to counter-3 completed!")).get();

private void addToWeakCounter(String name, long delta) {
 awaitCounterOperation(counterManager(0).getWeakCounter(name).add(delta));
}

public void testSingleConcurrencyLevel() throws ExecutionException, InterruptedException {
 final CounterManager counterManager = EmbeddedCounterManagerFactory.asCounterManager(manager(0));
 final String counterName = "c1-counter";
 counterManager.defineCounter(counterName,
    CounterConfiguration.builder(CounterType.WEAK).concurrencyLevel(1).build());
 WeakCounter wc = counterManager.getWeakCounter(counterName);
 wc.add(2).get();
 assertEquals(2, wc.getValue());
}

30 4 0

• infinispan - Infinispan 提供什么样的数据库支持？

  我不想使用 Infinispan 作为我的数据源。提供什么样的数据库支持？是否需要 Hibernate 二级缓存？ 最佳答案 Infinispan 可以配置持久缓存加载器，并且在支持的选项中，支持基于

• infinispan - infinispan 10.1.8 更新后 : class file for org. infinispan.factories.scopes.Scopes not found

  我刚刚尝试将我的应用程序更新到 Infinspan 10.1.8.Final。我通过 build.gradle 中的此依赖项将 Infinispan 用作 2 级休眠 (5.4.18.Final) 缓

• infinispan - 使用 infinispan 在运行时获取 TTL

  我正在使用 Infinispan 缓存。有没有办法在运行时获取条目的 TTL(或 lifepsan)？我看到界面CacheEntry作为 getLifespan() API，但我看不到如何获取 Cac

• infinispan - org.infinispan.util.concurrent.TimeoutException : Replication timeout for "node-name"

  我们有三个服务必须位于集群中。因此，我们使用 Infinispan 来集群节点并在这些服务之间共享数据。成功重新启动后，有时我会遇到异常，并收到另一节点中左侧节点的“ View 已更改”事件。实际上所

• java - 获取意外元素 '{urn:infinispan:config:7.0}infinispan' 遇到

  我有以下 infinispan xml 并得到解析异常。javax.xml.stream.XMLStreamException:[行，列] 处的 ParseError:[3,36]消息:遇到意外元素“

• java - org.infinispan.jmx.JmxDomainConflictException : Domain already registered org. infinispan 异常？

  我已将我的应用程序部署为 tomcat 6 服务上的 myApp1。由于一些要求，我复制了myApp1并粘贴到webapp下作为myApp2。现在我重新启动了tomcat并点击 myApp1 的网址。

• java - infinispan 缓存服务器过期失败

  我使用 infinispan-5.1.6.FINAL 作为远程缓存服务器和热棒协议(protocol)来访问它。但发现它没有按预期工作，即按照下面的配置，在 1ms 后不会驱逐键的缓存值

• docker - Infinispan 复制缓存的多个客户端可以共享同一个持久文件存储吗？

  交叉张贴在 https://developer.jboss.org/thread/279735 假设我们有多个 docker 容器(每个都有 java webapps，所以本质上是多个 JVM)，每个

• java - Infinispan:类已更改且反序列化不起作用

  我有一个使用 Infinispan 6.0.1.Final 的 Spring Boot 应用程序。我有两个类 A 和 B。B 扩展了 A。并且我有一个存储 B 类型对象的缓存。现在，我做了一个小更改，

• java - Infinispan 软索引文件存储问题

  在 jgroups 自动选择集群中对大约 180,000,000 条记录进行索引，一切正常(我索引和查询数据，结果似乎有效)，但在每次启动和关闭时我都会遇到此类错误。这是我必须担心的实验模式造成的吗？

• java - Infinispan:ClusterCacheLoader不支持预加载

  我们需要一个重新启动的持久缓存。主要目标是在启动时预加载尽可能多的数据。 因此要求是:​​ 从磁盘存储预加载 从已使用热缓存运行的邻居节点预加载 看起来 Infinispan 可能是一个合适的选择，但

• java - infinispan 文件存储大小与数据大小不成比例

  我编写了一个小型 infinispan 缓存 PoC(代码如下)来尝试评估 infinispan 性能。在运行它时，我发现对于我的配置 infinispan 显然不会从磁盘中清除缓存条目的旧副本，导致

• java - Infinispan 远程延迟锁定

  我们使用 Infinispan 4.0 作为我们的缓存提供程序(我知道它有点过时，因为版本 9 是最新的)。话虽如此，我在阅读文档时有点困惑: Infinispan, by default, acqu

• infinispan - infinispan缓存中evict()的含义

  根据 infinispan 的文档:http://docs.jboss.org/infinispan/5.0/apidocs/ evict() API 不会从调用它的缓存存储上的集群中的任何其他缓存存

• java - 如何在全局配置中设置传输以定义集群缓存 - infinispan

  尝试在 thorntail project-defaults.yaml 上配置缓存，但是在尝试在 wildfly 上启动或部署时遇到以下问题。 错误必须在全局配置中设置传输才能定义集群缓存。 不确定我

• java - Infinispan 不会将缓存实体删除复制到非协调器节点

  环境 嵌入 Infinispan 9.4.18 3 个节点以复制模式缓存 RocksDB 存储(或其他，无关紧要) 重现步骤 创建基于 TCP 的集群 创建缓存 将实体添加到缓存 检查实体是否存储在每

• java - Infinispan 从数据库表预加载数据

  如何将数据预加载到infinispan本地缓存？我有一个预先存在的应用程序表，其中包含键值对。我希望 infinispan 缓存表中的数据，当我读/写数据到缓存时，我希望基础表保持同步。 infini

• java - Infinispan 缓存初始化失败

  我使用 JBoss 6.4 EAP 和 Infinispan 6。 org.infinispan infinispan-core 6.0.2.G1.Final 我有

• jboss - Infinispan 集群同步问题

  我们使用具有 6 个实例的 JBoss 集群 (EAP 6.4.10)，并大量使用捆绑的 Infinispan 5.2.11 来处理不同的内存网格用例。然而，它们中的大多数是分布式缓存(实际上是复制的

• java - Infinispan，版本化操作返回不正确的结果

  我们计划在客户端服务器模式下使用 Infinispan。该架构有许多客户端(客户端 1、客户端 2 等)和分布式 infinispan 网络。 我们需要定期更新缓存中的数据，比如每5小时更新一次。所有