Class ExecutorKit

java.lang.Object

com.iohao.net.common.kit.concurrent.ExecutorKit

public class ExecutorKit
extends Object

Thread executor factory utilities.

Author:

渔民小镇

date:

2021-12-20

Constructor Summary

Constructors

Constructor	Description
ExecutorKit()

Method Summary

Modifier and Type	Method	Description
ThreadFactory	createSigleThreadFactory(@NonNull String name)	Create a single-named daemon thread factory.
ThreadFactory	createThreadFactory(@NonNull String namePrefix, boolean daemon)	Create a thread factory.
ThreadFactory	createThreadFactory(String namePrefix)	Create a thread factory.
ExecutorService	newCacheThreadPool(String namePrefix)	Create a cached thread pool.
ExecutorService	newCacheThreadPool(ThreadFactory threadFactory)	Create a cached thread pool.
ExecutorService	newFixedThreadPool(int corePoolSize, String namePrefix)	Create a fixed-size thread pool.
ExecutorService	newFixedThreadPool(int corePoolSize, ThreadFactory threadFactory)	Create a fixed-size thread pool.
ScheduledExecutorService	newScheduled(int corePoolSize, String namePrefix)	Create a scheduled executor with the specified pool size.
ScheduledExecutorService	newScheduled(int corePoolSize, ThreadFactory threadFactory)	Create a scheduled executor with the specified pool size.
ScheduledExecutorService	newSingleScheduled(String namePrefix)	Create a single-thread scheduled executor.
ScheduledExecutorService	newSingleScheduled(ThreadFactory threadFactory)	Create a single-thread scheduled executor.
ExecutorService	newSingleThreadExecutor(String namePrefix)	Create a single-thread executor.
ExecutorService	newSingleThreadExecutor(ThreadFactory threadFactory)	Create a single-thread executor.
ExecutorService	newVirtualExecutor(String name)	Create a virtual thread executor.
ExecutorService	newVirtualExecutor(String name, int start)	Create a virtual thread executor.
ExecutorService	newVirtualExecutor(ThreadFactory factory)	Create a virtual thread executor.

Methods inherited from class Object

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

Constructor Details

ExecutorKit

public ExecutorKit()

Method Details

newVirtualExecutor

public ExecutorService newVirtualExecutor(String name)

Create a virtual thread executor.

Parameters:

name - thread name prefix

Returns:

the virtual thread executor

newVirtualExecutor

public ExecutorService newVirtualExecutor(String name,
 int start)

Create a virtual thread executor.

Parameters:

name - thread name prefix

start - starting value for the thread name counter

Returns:

the virtual thread executor

newVirtualExecutor

public ExecutorService newVirtualExecutor(ThreadFactory factory)

Create a virtual thread executor.

Parameters:

factory - thread factory for virtual threads

Returns:

the virtual thread executor

newSingleThreadExecutor

public ExecutorService newSingleThreadExecutor(String namePrefix)

Create a single-thread executor.

Parameters:

namePrefix - thread name prefix

Returns:

the single-thread executor

newSingleThreadExecutor

public ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory)

Create a single-thread executor.

Parameters:

threadFactory - thread factory

Returns:

the single-thread executor

newCacheThreadPool

public ExecutorService newCacheThreadPool(String namePrefix)

Create a cached thread pool.

Parameters:

namePrefix - thread name prefix

Returns:

the cached thread pool executor

newCacheThreadPool

public ExecutorService newCacheThreadPool(ThreadFactory threadFactory)

Create a cached thread pool.

Parameters:

threadFactory - thread factory

Returns:

the cached thread pool executor

newFixedThreadPool

public ExecutorService newFixedThreadPool(int corePoolSize,
 ThreadFactory threadFactory)

Create a fixed-size thread pool.

Parameters:

corePoolSize - pool size

threadFactory - thread factory

Returns:

the fixed-size thread pool executor

newFixedThreadPool

public ExecutorService newFixedThreadPool(int corePoolSize,
 String namePrefix)

Create a fixed-size thread pool.

Parameters:

corePoolSize - pool size

namePrefix - thread name prefix

Returns:

the fixed-size thread pool executor

newSingleScheduled

public ScheduledExecutorService newSingleScheduled(ThreadFactory threadFactory)

Create a single-thread scheduled executor.

Parameters:

threadFactory - thread factory

Returns:

the single-thread scheduled executor

newSingleScheduled

public ScheduledExecutorService newSingleScheduled(String namePrefix)

Create a single-thread scheduled executor.

Parameters:

namePrefix - thread name prefix

Returns:

the single-thread scheduled executor

newScheduled

public ScheduledExecutorService newScheduled(int corePoolSize,
 String namePrefix)

Create a scheduled executor with the specified pool size.

Parameters:

corePoolSize - pool size

namePrefix - thread name prefix

Returns:

the scheduled executor

newScheduled

public ScheduledExecutorService newScheduled(int corePoolSize,
 ThreadFactory threadFactory)

Create a scheduled executor with the specified pool size.

Parameters:

corePoolSize - pool size

threadFactory - thread factory

Returns:

the scheduled executor

createThreadFactory

public ThreadFactory createThreadFactory(String namePrefix)

Create a thread factory. Daemon is true by default.

Parameters:

namePrefix - thread name prefix

Returns:

the thread factory

createThreadFactory

public ThreadFactory createThreadFactory(@NonNull String namePrefix,
 boolean daemon)

Create a thread factory.

Parameters:

namePrefix - thread name prefix

daemon - whether threads are daemon threads

Returns:

the thread factory

createSigleThreadFactory

public ThreadFactory createSigleThreadFactory(@NonNull String name)

Create a single-named daemon thread factory.

Parameters:

name - the fixed thread name

Returns:

the thread factory