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

WeakCounter.sync介绍

[英]It returns a synchronous weak counter for this instance.
[中]

代码示例

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

public WeakTestCounter(WeakCounter counter) {
 this.counter = counter;
 this.syncCounter = counter.sync();
}

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

@Override
  protected ModelNode invoke(CounterManager counterManager, ModelNode operation) {
    final String counterName = counterName(operation);
    final String counterType = counterType(operation);
    if (counterManager.isDefined(counterName)) {
      boolean isStrongCounter = ModelKeys.STRONG_COUNTER.equals(counterType);
      if (isStrongCounter) {
        StrongCounter strongCounter = counterManager.getStrongCounter(counterName);
        strongCounter.sync().reset();
      } else {
        WeakCounter weakCounter = counterManager.getWeakCounter(counterName);
        weakCounter.sync().reset();
      }
    }
    return new ModelNode();
  }
}

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

@Override
  protected ModelNode invoke(CounterManager counterManager, ModelNode operation) {
    final String counterName = counterName(operation);
    final String counterType = counterType(operation);
    if (counterManager.isDefined(counterName)) {
      boolean isStrongCounter = ModelKeys.STRONG_COUNTER.equals(counterType);
      if (isStrongCounter) {
        StrongCounter strongCounter = counterManager.getStrongCounter(counterName);
        strongCounter.sync().incrementAndGet();
      } else {
        WeakCounter weakCounter = counterManager.getWeakCounter(counterName);
        weakCounter.sync().increment();
      }
    }
    return new ModelNode();
  }
}

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

@Override
  protected ModelNode invoke(CounterManager counterManager, ModelNode operation) {
    final String counterName = counterName(operation);
    final String counterType = counterType(operation);
    if (counterManager.isDefined(counterName)) {
      boolean isStrongCounter = ModelKeys.STRONG_COUNTER.equals(counterType);
      if (isStrongCounter) {
        StrongCounter strongCounter = counterManager.getStrongCounter(counterName);
        strongCounter.sync().decrementAndGet();
      } else {
        WeakCounter weakCounter = counterManager.getWeakCounter(counterName);
        weakCounter.sync().decrement();
      }
    }
    return new ModelNode();
  }
}

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

@Override
protected void executeRuntimeStep(OperationContext context, ModelNode operation) {
  final ModelNode result = new ModelNode();
  final PathAddress address = PathAddress.pathAddress(operation.require(OP_ADDR));
  final String cacheContainerName = address.getElement(CACHE_CONTAINER_INDEX).getValue();
  final String counterType = address.getElement(COUNTER_INDEX).getKey();
  final String counterName = address.getElement(COUNTER_INDEX).getValue();
  final ServiceController<?> controller = context.getServiceRegistry(false)
      .getService(CacheContainerServiceName.CACHE_CONTAINER.getServiceName(cacheContainerName));
  Long value;
  if (controller != null) {
    DefaultCacheContainer cacheManager = (DefaultCacheContainer) controller.getValue();
    CounterManager counterManager = EmbeddedCounterManagerFactory.asCounterManager(cacheManager);
    if (ModelKeys.STRONG_COUNTER.equals(counterType)) {
      StrongCounter sc = counterManager.getStrongCounter(counterName);
      value = sc.sync().getValue();
    } else {
      WeakCounter wc = counterManager.getWeakCounter(counterName);
      value = wc.sync().getValue();
    }
    result.set(value);
  }
  context.getResult().set(result);
}

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

private void incrementCounter(CounterManager counterManager) {
  switch (type) {
   case UNBOUNDED_STRONG:
   case BOUNDED_STRONG:
     counterManager.getStrongCounter(name).sync().incrementAndGet();
     break;
   case WEAK:
     counterManager.getWeakCounter(name).sync().increment();
     break;
  }
}

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

@Test
public void testCounters() {
 CounterManager counterManager = RemoteCounterManagerFactory.asCounterManager(remoteCacheManager);
 counterManager.defineCounter("c1", CounterConfiguration.builder(CounterType.BOUNDED_STRONG)
    .upperBound(10)
    .initialValue(1)
    .build());
 counterManager.defineCounter("c2", CounterConfiguration.builder(CounterType.WEAK)
    .initialValue(5)
    .build());
 SyncStrongCounter c1 = counterManager.getStrongCounter("c1").sync();
 SyncWeakCounter c2 = counterManager.getWeakCounter("c2").sync();
 assertEquals(1, c1.getValue());
 assertEquals(5, c2.getValue());
}