Package org.jgroups.tests.perf

Class ProgrammaticUPerf.Invoker

  • All Implemented Interfaces:
    java.lang.Runnable
    Enclosing class:
    ProgrammaticUPerf
    private class ProgrammaticUPerf.Invoker
extends java.lang.Thread

    • Nested Class Summary

      • Nested classes/interfaces inherited from class java.lang.Thread

        java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

    • Constructor Summary

      Constructors 
      Constructor Description
      Invoker​(java.util.Collection<Address> dests, java.util.concurrent.CountDownLatch latch)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      AverageMinMax avgGets()  
      AverageMinMax avgPuts()  
      void cancel()  
      private void pickAnycastTargets​(java.util.List<Address> anycast_targets)  
      private Address pickTarget()  
      void run()  

      • Methods inherited from class java.lang.Thread

        activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

      • Methods inherited from class java.lang.Object

        equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    • Field Detail

      • dests

        private final java.util.List<Address> dests

      • latch

        private final java.util.concurrent.CountDownLatch latch

      • targets

        private final java.util.List<Address> targets

      • running

        private volatile boolean running

    • Constructor Detail

      • Invoker

        public Invoker​(java.util.Collection<Address> dests,
               java.util.concurrent.CountDownLatch latch)

    • Method Detail

      • cancel

        public void cancel()

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
        Overrides:
        run in class java.lang.Thread

      • pickTarget

        private Address pickTarget()

      • pickAnycastTargets

        private void pickAnycastTargets​(java.util.List<Address> anycast_targets)