com.antchain.unionsdk.utils

类 ExecutorUtils

java.lang.Object

com.antchain.unionsdk.utils.ExecutorUtils

public class ExecutorUtils
extends Object

构造器概要

构造器

构造器和说明
ExecutorUtils()

方法概要

限定符和类型	方法和说明
static void	deletePoolMap(Integer hashCode)
static int	getDefaultThreads()
static com.google.common.util.concurrent.ListeningExecutorService	getListeningExecutorService(ExecutorService executorService)
static com.google.common.util.concurrent.ListeningExecutorService	getListeningExecutorService(int nThreads, String name, int maxPendingTasks)
static com.google.common.util.concurrent.ListeningExecutorService	getListeningExecutorService(int nThreads, String name, int maxPendingTasks, boolean flag)
static com.google.common.util.concurrent.ListeningExecutorService	getListeningExecutorService(int nThreads, ThreadFactory threadFactory, int maxPendingTasks)
static com.google.common.util.concurrent.ListeningExecutorService	getListeningExecutorService(int nThreads, ThreadFactory threadFactory, int maxPendingTasks, boolean flag)
static com.google.common.util.concurrent.ListeningExecutorService	getListeningExecutorService(String name, int maxPendingTasks)
static ThreadFactory	getNamedThreadFactory(String name)
static ThreadFactory	getNamedThreadFactory(String name, boolean isDaemon)
static Map<Integer,ThreadPoolExecutor>	getPoolMap()
static PriorityThreadPoolExecutor	getPriorityThreadPoolExecutor(int corePoolSize, String name, int maxPendingTasks)
static ScheduledExecutorService	getScheduledExecutorService(int corePoolSize, ThreadFactory threadFactory)
static ScheduledExecutorService	getScheduledExecutorService(String name)
static ScheduledExecutorService	getScheduledExecutorService(String name, int corePoolSize)

从类继承的方法 java.lang.Object

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

构造器详细资料

ExecutorUtils

public ExecutorUtils()

方法详细资料

getNamedThreadFactory

public static ThreadFactory getNamedThreadFactory(String name)

getNamedThreadFactory

public static ThreadFactory getNamedThreadFactory(String name,
                                                  boolean isDaemon)

getScheduledExecutorService

public static ScheduledExecutorService getScheduledExecutorService(String name)

getScheduledExecutorService

public static ScheduledExecutorService getScheduledExecutorService(String name,
                                                                   int corePoolSize)

getScheduledExecutorService

public static ScheduledExecutorService getScheduledExecutorService(int corePoolSize,
                                                                   ThreadFactory threadFactory)

getListeningExecutorService

public static com.google.common.util.concurrent.ListeningExecutorService getListeningExecutorService(String name,
                                                                                                     int maxPendingTasks)

getListeningExecutorService

public static com.google.common.util.concurrent.ListeningExecutorService getListeningExecutorService(int nThreads,
                                                                                                     String name,
                                                                                                     int maxPendingTasks)

getListeningExecutorService

public static com.google.common.util.concurrent.ListeningExecutorService getListeningExecutorService(int nThreads,
                                                                                                     String name,
                                                                                                     int maxPendingTasks,
                                                                                                     boolean flag)

getListeningExecutorService

public static com.google.common.util.concurrent.ListeningExecutorService getListeningExecutorService(int nThreads,
                                                                                                     ThreadFactory threadFactory,
                                                                                                     int maxPendingTasks,
                                                                                                     boolean flag)

getListeningExecutorService

public static com.google.common.util.concurrent.ListeningExecutorService getListeningExecutorService(int nThreads,
                                                                                                     ThreadFactory threadFactory,
                                                                                                     int maxPendingTasks)

getListeningExecutorService

public static com.google.common.util.concurrent.ListeningExecutorService getListeningExecutorService(ExecutorService executorService)

getDefaultThreads

public static int getDefaultThreads()

getPriorityThreadPoolExecutor

public static PriorityThreadPoolExecutor getPriorityThreadPoolExecutor(int corePoolSize,
                                                                       String name,
                                                                       int maxPendingTasks)

deletePoolMap

public static void deletePoolMap(Integer hashCode)

getPoolMap

public static Map<Integer,ThreadPoolExecutor> getPoolMap()