com.baidu.brpc.thread

Class BrpcThreadPoolManager

java.lang.Object

com.baidu.brpc.thread.BrpcThreadPoolManager

public class BrpcThreadPoolManager
extends Object

Constructor Summary

Constructors

Constructor and Description
BrpcThreadPoolManager()

Method Summary

Modifier and Type	Method and Description
protected io.netty.channel.EventLoopGroup	createClientIoThreadPool(int threadNum, String namePrefix, int ioEventType)
static BrpcThreadPoolManager	getInstance()
io.netty.channel.EventLoopGroup	getOrCreateClientIoThreadPool(String serviceName, boolean isSharing, int threadNum, int ioEventType)
ThreadPool	getOrCreateClientWorkThreadPool(String serviceName, boolean isSharing, int threadNum)
protected String	internalServiceName(String serviceName)
void	stopAll()
void	stopServiceThreadPool(String serviceName)

Methods inherited from class java.lang.Object

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

Constructor Detail

BrpcThreadPoolManager

public BrpcThreadPoolManager()

Method Detail

getInstance

public static BrpcThreadPoolManager getInstance()

getOrCreateClientIoThreadPool

public io.netty.channel.EventLoopGroup getOrCreateClientIoThreadPool(String serviceName,
                                                                     boolean isSharing,
                                                                     int threadNum,
                                                                     int ioEventType)

createClientIoThreadPool

protected io.netty.channel.EventLoopGroup createClientIoThreadPool(int threadNum,
                                                                   String namePrefix,
                                                                   int ioEventType)

getOrCreateClientWorkThreadPool

public ThreadPool getOrCreateClientWorkThreadPool(String serviceName,
                                                  boolean isSharing,
                                                  int threadNum)

internalServiceName

protected String internalServiceName(String serviceName)

stopAll

public void stopAll()

stopServiceThreadPool

public void stopServiceThreadPool(String serviceName)