Package org.infinispan.extendedstats.container

Class ConcurrentGlobalContainer

java.lang.Object
org.infinispan.extendedstats.container.ConcurrentGlobalContainer
public final class ConcurrentGlobalContainer extends Object
Thread safe cache statistics that allows multiple writers and reader at the same time.
Since:
5.2
Author:
Pedro Ruivo

  • Constructor Details

    • ConcurrentGlobalContainer

      public ConcurrentGlobalContainer(TimeService timeService)

  • Method Details

    • add

      public final void add(ExtendedStatistic stat, double value, boolean local)

    • merge

      public final void merge(double[] toMerge, boolean local)

    • getSnapshot

      public final StatisticsSnapshot getSnapshot()

    • reset

      public final void reset()

    • getLocalIndex

      public static int getLocalIndex(ExtendedStatistic stat)

    • getRemoteIndex

      public static int getRemoteIndex(ExtendedStatistic stat)

    • queue

      public final BlockingQueue<?> queue()
      Returns:
      TEST ONLY!!

    • flushing

      public final AtomicBoolean flushing()
      Returns:
      TEST ONLY!!

    • isReset

      public final boolean isReset()
      Returns:
      TEST ONLY!!

    • dumpTo

      public final void dumpTo(PrintWriter writer)