org.apache.shardingsphere.data.pipeline.core.execute

类 ExecuteEngine

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.execute.ExecuteEngine

public final class ExecuteEngine
extends Object

Executor engine.

构造器概要

构造器

构造器和说明
ExecuteEngine()

方法概要

限定符和类型	方法和说明
static ExecuteEngine	newCachedThreadInstance(String threadName) Create task execute engine instance with cached thread pool.
static ExecuteEngine	newFixedThreadInstance(int threadNumber, String threadName) Create task execute engine instance with fixed thread pool.
CompletableFuture<?>	submit(LifecycleExecutor lifecycleExecutor, ExecuteCallback executeCallback) Submit a LifecycleExecutor with callback ExecuteCallback to execute.
CompletableFuture<?>	submitAll(Collection<? extends LifecycleExecutor> lifecycleExecutors, ExecuteCallback executeCallback) Submit a collection of LifecycleExecutor with callback ExecuteCallback to execute.

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

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

构造器详细资料

ExecuteEngine

public ExecuteEngine()

方法详细资料

newCachedThreadInstance

public static ExecuteEngine newCachedThreadInstance(String threadName)

Create task execute engine instance with cached thread pool.

参数:

threadName - thread name

返回:

task execute engine instance

newFixedThreadInstance

public static ExecuteEngine newFixedThreadInstance(int threadNumber,
                                                   String threadName)

Create task execute engine instance with fixed thread pool.

参数:

threadNumber - thread number

threadName - thread name

返回:

task execute engine instance

submit

public CompletableFuture<?> submit(LifecycleExecutor lifecycleExecutor,
                                   ExecuteCallback executeCallback)

Submit a LifecycleExecutor with callback ExecuteCallback to execute.

参数:

lifecycleExecutor - lifecycle executor

executeCallback - execute callback

返回:

execute future

submitAll

public CompletableFuture<?> submitAll(Collection<? extends LifecycleExecutor> lifecycleExecutors,
                                      ExecuteCallback executeCallback)

Submit a collection of LifecycleExecutor with callback ExecuteCallback to execute.

参数:

lifecycleExecutors - lifecycle executor

executeCallback - execute callback

返回:

execute future of all