com.baidu.brpc.utils

Class ThreadPool

java.lang.Object

com.baidu.brpc.utils.ThreadPool

public final class ThreadPool
extends Object

Since ExecutorService is a bit slow, we have to invent some wheels here.

NOT implement the Executor interface unless we see the necessity

Author:

Zhangyi Chen (chenzhangyi01@baidu.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThreadPool.StatInfo

Constructor Summary

Constructors

Constructor and Description
ThreadPool(int initialThreadNum, ThreadFactory threadFactory)
ThreadPool(int initialThreadNum, ThreadFactory threadFactory, int queueSize)

Method Summary

Modifier and Type	Method and Description
ThreadPool.StatInfo	getStatInfo()
boolean	isStopped()
void	join()
void	stop()
boolean	submit(Runnable task)
long	submit(Runnable[] tasks, int offset, int len)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPool

public ThreadPool(int initialThreadNum,
                  ThreadFactory threadFactory)

ThreadPool

public ThreadPool(int initialThreadNum,
                  ThreadFactory threadFactory,
                  int queueSize)

Method Detail

stop

public void stop()

join

public void join()

submit

public boolean submit(Runnable task)

submit

public long submit(Runnable[] tasks,
                   int offset,
                   int len)

getStatInfo

public ThreadPool.StatInfo getStatInfo()

isStopped

public boolean isStopped()