Class ThreadPools

  • public class ThreadPools
    extends java.lang.Object
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.util.concurrent.ExecutorService getWorkerPool()
      Return an ExecutorService that uses the "worker" thread-pool.
      static java.util.concurrent.ScheduledExecutorService newScheduledPool​(java.lang.String namePrefix, int poolSize)
      Create a new ScheduledExecutorService with the given name and pool size.
      static java.util.concurrent.ExecutorService newWorkerPool​(java.lang.String namePrefix)  
      static java.util.concurrent.ExecutorService newWorkerPool​(java.lang.String namePrefix, int poolSize)  
      • Methods inherited from class java.lang.Object

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


        public static final java.lang.String WORKER_THREAD_POOL_SIZE_PROP
        Use WORKER_THREAD_POOL_SIZE instead; will be removed in 2.0.0

        public static final int WORKER_THREAD_POOL_SIZE
    • Method Detail

      • getWorkerPool

        public static java.util.concurrent.ExecutorService getWorkerPool()
        Return an ExecutorService that uses the "worker" thread-pool.

        The size of the worker pool limits the number of tasks concurrently reading manifests in the base table implementation across all concurrent planning operations.

        The size of this thread-pool is controlled by the Java system property iceberg.worker.num-threads.

        an ExecutorService that uses the worker pool
      • newWorkerPool

        public static java.util.concurrent.ExecutorService newWorkerPool​(java.lang.String namePrefix)
      • newWorkerPool

        public static java.util.concurrent.ExecutorService newWorkerPool​(java.lang.String namePrefix,
                                                                         int poolSize)
      • newScheduledPool

        public static java.util.concurrent.ScheduledExecutorService newScheduledPool​(java.lang.String namePrefix,
                                                                                     int poolSize)
        Create a new ScheduledExecutorService with the given name and pool size.

        Threads used by this service will be daemon threads.

        namePrefix - a base name for threads in the executor service's thread pool
        poolSize - max number of threads to use
        an executor service