Class Pools


  • public final class Pools
    extends java.lang.Object
    Pools
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private static java.util.concurrent.ScheduledThreadPoolExecutor poolExecutor  
      private static java.util.concurrent.atomic.AtomicInteger poolIndex  
      private static java.util.Map<Configuration,​Pool> poolMap  
    • Constructor Summary

      Constructors 
      Constructor Description
      Pools()  
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void close()
      Close all pools.
      static void close​(java.lang.String poolName)
      Closing a pool with name defined in url.
      static void remove​(Pool pool)
      Remove pool.
      static Pool retrievePool​(Configuration conf)
      Get existing pool for a configuration.
      private static void shutdownExecutor()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • poolIndex

        private static final java.util.concurrent.atomic.AtomicInteger poolIndex
      • poolExecutor

        private static java.util.concurrent.ScheduledThreadPoolExecutor poolExecutor
    • Constructor Detail

      • Pools

        public Pools()
    • Method Detail

      • retrievePool

        public static Pool retrievePool​(Configuration conf)
        Get existing pool for a configuration. Create it if it doesn't exist.
        Parameters:
        conf - configuration parser
        Returns:
        pool
      • remove

        public static void remove​(Pool pool)
        Remove pool.
        Parameters:
        pool - pool to remove
      • close

        public static void close()
        Close all pools.
      • close

        public static void close​(java.lang.String poolName)
        Closing a pool with name defined in url.
        Parameters:
        poolName - the option "poolName" value
      • shutdownExecutor

        private static void shutdownExecutor()