com.yomahub.liteflow.thread

Class ExecutorHelper

java.lang.Object

com.yomahub.liteflow.thread.ExecutorHelper

public class ExecutorHelper
extends Object

线程池工具类

Author:

Bryan.Zhang, jason

Method Summary

Modifier and Type	Method and Description
ExecutorService	buildExecutorService(Condition condition, Integer slotIndex, ConditionTypeEnum type) 构建执行器服务
ExecutorService	buildMainExecutor()
ExecutorService	buildMainExecutor(String clazz)
ExecutorService	buildWhenExecutor()
ExecutorService	buildWhenExecutor(String clazz)
ExecutorService	buildWhenExecutorWithHash(String hash)
ExecutorService	buildWhenExecutorWithHash(String clazz, String hash)
void	clearExecutorServiceMap()
boolean	isEnabledVirtualThreads()
static ExecutorHelper	loadInstance()
void	shutdownAwaitTermination(ExecutorService pool)
void	shutdownAwaitTermination(ExecutorService pool, long timeout) 关闭ExecutorService的线程管理者

Methods inherited from class java.lang.Object

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

Method Detail

loadInstance

public static ExecutorHelper loadInstance()

shutdownAwaitTermination

public void shutdownAwaitTermination(ExecutorService pool)

Parameters:

pool - 需要关闭的线程组.

shutdownAwaitTermination

public void shutdownAwaitTermination(ExecutorService pool,
                                     long timeout)

关闭ExecutorService的线程管理者

Parameters:

pool - 需要关闭的管理者

timeout - 等待时间

buildWhenExecutor

public ExecutorService buildWhenExecutor()

buildWhenExecutor

public ExecutorService buildWhenExecutor(String clazz)

buildWhenExecutorWithHash

public ExecutorService buildWhenExecutorWithHash(String hash)

buildWhenExecutorWithHash

public ExecutorService buildWhenExecutorWithHash(String clazz,
                                                 String hash)

buildMainExecutor

public ExecutorService buildMainExecutor()

buildMainExecutor

public ExecutorService buildMainExecutor(String clazz)

clearExecutorServiceMap

public void clearExecutorServiceMap()

buildExecutorService

public ExecutorService buildExecutorService(Condition condition,
                                            Integer slotIndex,
                                            ConditionTypeEnum type)

构建执行器服务

Parameters:

condition - 条件对象（Loop或When条件）

slotIndex - 槽索引

type - condition类型

Returns:

ExecutorService

isEnabledVirtualThreads

public boolean isEnabledVirtualThreads()