com.alipay.sofa.jraft.util

Class ThreadPoolsFactory

java.lang.Object

com.alipay.sofa.jraft.util.ThreadPoolsFactory

public class ThreadPoolsFactory
extends Object

ThreadPool based on Raft-Group isolation

Since:

1.3.12

Author:

tynan.liu

Constructor Summary

Constructors

Constructor and Description
ThreadPoolsFactory()

Method Summary

Modifier and Type	Method and Description
protected static ThreadPoolExecutor	getExecutor(String groupId)
static void	registerThreadPool(String groupId, ThreadPoolExecutor executor) You can specify the ThreadPoolExecutor yourself here
static Future<?>	runClosureInThread(String groupId, Closure done) Run closure with OK status in thread pool.
static Future<?>	runClosureInThread(String groupId, Closure done, Status status) Run closure with status in thread pool.
static Future<?>	runInThread(String groupId, Runnable runnable) Run a task in thread pool,returns the future object.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPoolsFactory

public ThreadPoolsFactory()

Method Detail

registerThreadPool

public static void registerThreadPool(String groupId,
                                      ThreadPoolExecutor executor)

You can specify the ThreadPoolExecutor yourself here

Parameters:

groupId - Raft-Group

executor - To specify ThreadPoolExecutor

getExecutor

@OnlyForTest
protected static ThreadPoolExecutor getExecutor(String groupId)

runInThread

public static Future<?> runInThread(String groupId,
                                    Runnable runnable)

Run a task in thread pool,returns the future object.

runClosureInThread

public static Future<?> runClosureInThread(String groupId,
                                           Closure done,
                                           Status status)

Run closure with status in thread pool.

runClosureInThread

public static Future<?> runClosureInThread(String groupId,
                                           Closure done)

Run closure with OK status in thread pool.