RFC: custom thread pool

[killme2008]

RPC: custom thread pool

Right now, jraft use global thread pool to execute callback closures or send log entries as below:

• sofa-jraft/jraft-core/src/main/java/com/alipay/sofa/jraft/rpc/impl/core/DefaultRaftClientService.java

  Line 63 in 4f9f779

  private static final FixedThreadsExecutorGroup APPEND_ENTRIES_EXECUTORS = DefaultFixedThreadsExecutorGroupFactory.INSTANCE

• sofa-jraft/jraft-core/src/main/java/com/alipay/sofa/jraft/util/Utils.java

  Line 108 in 4f9f779

  private static ThreadPoolExecutor CLOSURE_EXECUTOR = ThreadPoolUtil

The users can't change the thread pool behaviour by themself except setting enviroment variable such as -Djraft.closure.threadpool.size.max=xxx etc. And when using multi raft group in one java process, the global thread pool can't provide any isolations between groups and make the service not robust enough.

So i think we can provide a way to let users custom thread pool for every raft group just like StorageOptionsFactory. If the users doesn't provide a custom thread pool, we use the global one as before.

• Main goals:
  • Let user custom closure execution and sending entries thread pools
  • Provides isolation between raft groups in one java process.

[shihuili1218]

hi, i want to perform this task

[killme2008]

@farawayliu Sure! Feel free to try it.

[shihuili1218]

i have finished send AppendEntries, i have a question, why shutdown programs can't share CLOSURE_EXECUTOR?
#855

[shihuili1218]

i have finished send AppendEntries, i have a question, why shutdown programs can't share CLOSURE_EXECUTOR? #855

hah, i misunderstood the meaning of CLOSURE_EXECUTOR

[shihuili1218]

@killme2008 hi, i have completed this task, please review. #855

[killme2008]

@farawayliu Cool, i will review it today.