com.jn.langx.util.concurrent

类 Threads

java.lang.Object

com.jn.langx.util.concurrent.Threads

public class Threads
extends Object

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	Threads.NamePredicate A predicate implementation which matches a thread or threadgroup name.
static interface	Threads.ThreadGroupPredicate A predicate for selecting threadgroups.
static class	Threads.ThreadIdPredicate A predicate implementation which matches a thread id.
static interface	Threads.ThreadPredicate A predicate for selecting threads.

字段概要

字段

限定符和类型	字段和说明
static com.jn.langx.util.concurrent.Threads.AlwaysTruePredicate	ALWAYS_TRUE_PREDICATE Predicate which always returns true.

方法概要

限定符和类型	方法和说明
static Thread	findThreadById(long threadId) Finds the active thread with the specified id.
static Thread	findThreadById(long threadId, String threadGroupName) Finds the active thread with the specified id if it belongs to a thread group with the specified group name.
static Thread	findThreadById(long threadId, ThreadGroup threadGroup) Finds the active thread with the specified id if it belongs to the specified thread group.
static Collection<ThreadGroup>	findThreadGroups(ThreadGroup group, boolean recurse, Threads.ThreadGroupPredicate predicate) Select all active threadgroups which match the given predicate and which is a subgroup of the given thread group (or one of its subgroups).
static Collection<ThreadGroup>	findThreadGroups(Threads.ThreadGroupPredicate predicate) Select all active threadgroups which match the given predicate.
static Collection<ThreadGroup>	findThreadGroupsByName(String threadGroupName) Finds active thread groups with the specified group name.
static Collection<Thread>	findThreads(ThreadGroup group, boolean recurse, Threads.ThreadPredicate predicate) Select all active threads which match the given predicate and which belongs to the given thread group (or one of its subgroups).
static Collection<Thread>	findThreads(Threads.ThreadPredicate predicate) Select all active threads which match the given predicate.
static Collection<Thread>	findThreadsByName(String threadName) Finds active threads with the specified name.
static Collection<Thread>	findThreadsByName(String threadName, String threadGroupName) Finds active threads with the specified name if they belong to a thread group with the specified group name.
static Collection<Thread>	findThreadsByName(String threadName, ThreadGroup threadGroup) Finds active threads with the specified name if they belong to a specified thread group.
static Collection<ThreadGroup>	getAllThreadGroups() Gets all active thread groups excluding the system thread group (A thread group is active if it has been not destroyed).
static Collection<Thread>	getAllThreads() Gets all active threads (A thread is active if it has been started and has not yet died).
static int	getAvailableThreadNum(float blockRate) 获取需要创建线程数 线程分工原则： 计算密集型尽量少创建线程，多分段处理; IO密集型尽量多创建线程
static ThreadGroup	getSystemThreadGroup() Gets the system thread group (sometimes also referred as "root thread group").

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

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

字段详细资料

ALWAYS_TRUE_PREDICATE

public static final com.jn.langx.util.concurrent.Threads.AlwaysTruePredicate ALWAYS_TRUE_PREDICATE

Predicate which always returns true.

方法详细资料

getAvailableThreadNum

public static int getAvailableThreadNum(float blockRate)

获取需要创建线程数

线程分工原则：
计算密集型尽量少创建线程，多分段处理;
IO密集型尽量多创建线程

参数:

blockRate - 阻塞率，小数，取值范围：[0,1) ,即0到1之间包含0，不包含1

findThreadById

public static Thread findThreadById(long threadId,
                                    ThreadGroup threadGroup)

Finds the active thread with the specified id if it belongs to the specified thread group.

参数:

threadId - The thread id

threadGroup - The thread group

返回:

The thread which belongs to a specified thread group and the thread's id match the specified id. null is returned if no such thread exists

抛出:

IllegalArgumentException - if the specified id is zero or negative or the group is null

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreadById

public static Thread findThreadById(long threadId,
                                    String threadGroupName)

Finds the active thread with the specified id if it belongs to a thread group with the specified group name.

参数:

threadId - The thread id

threadGroupName - The thread group name

返回:

The threads which belongs to a thread group with the specified group name and the thread's id match the specified id. null is returned if no such thread exists

抛出:

IllegalArgumentException - if the specified id is zero or negative or the group name is null

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreadsByName

public static Collection<Thread> findThreadsByName(String threadName,
                                                   ThreadGroup threadGroup)

Finds active threads with the specified name if they belong to a specified thread group.

参数:

threadName - The thread name

threadGroup - The thread group

返回:

The threads which belongs to a thread group and the thread's name match the specified name, An empty collection is returned if no such thread exists. The collection returned is always unmodifiable.

抛出:

IllegalArgumentException - if the specified thread name or group is null

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreadsByName

public static Collection<Thread> findThreadsByName(String threadName,
                                                   String threadGroupName)

Finds active threads with the specified name if they belong to a thread group with the specified group name.

参数:

threadName - The thread name

threadGroupName - The thread group name

返回:

The threads which belongs to a thread group with the specified group name and the thread's name match the specified name, An empty collection is returned if no such thread exists. The collection returned is always unmodifiable.

抛出:

IllegalArgumentException - if the specified thread name or group name is null

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreadGroupsByName

public static Collection<ThreadGroup> findThreadGroupsByName(String threadGroupName)

Finds active thread groups with the specified group name.

参数:

threadGroupName - The thread group name

返回:

the thread groups with the specified group name or an empty collection if no such thread group exists. The collection returned is always unmodifiable.

抛出:

IllegalArgumentException - if group name is null

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

getAllThreadGroups

public static Collection<ThreadGroup> getAllThreadGroups()

Gets all active thread groups excluding the system thread group (A thread group is active if it has been not destroyed).

返回:

all thread groups excluding the system thread group. The collection returned is always unmodifiable.

抛出:

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

getSystemThreadGroup

public static ThreadGroup getSystemThreadGroup()

Gets the system thread group (sometimes also referred as "root thread group").

返回:

the system thread group

抛出:

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

getAllThreads

public static Collection<Thread> getAllThreads()

Gets all active threads (A thread is active if it has been started and has not yet died).

返回:

all active threads. The collection returned is always unmodifiable.

抛出:

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreadsByName

public static Collection<Thread> findThreadsByName(String threadName)

Finds active threads with the specified name.

参数:

threadName - The thread name

返回:

The threads with the specified name or an empty collection if no such thread exists. The collection returned is always unmodifiable.

抛出:

IllegalArgumentException - if the specified name is null

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreadById

public static Thread findThreadById(long threadId)

Finds the active thread with the specified id.

参数:

threadId - The thread id

返回:

The thread with the specified id or null if no such thread exists

抛出:

IllegalArgumentException - if the specified id is zero or negative

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreads

public static Collection<Thread> findThreads(Threads.ThreadPredicate predicate)

Select all active threads which match the given predicate.

参数:

predicate - the predicate

返回:

An unmodifiable Collection of active threads matching the given predicate

抛出:

IllegalArgumentException - if the predicate is null

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreadGroups

public static Collection<ThreadGroup> findThreadGroups(Threads.ThreadGroupPredicate predicate)

Select all active threadgroups which match the given predicate.

参数:

predicate - the predicate

返回:

An unmodifiable Collection of active threadgroups matching the given predicate

抛出:

IllegalArgumentException - if the predicate is null

SecurityException - if the current thread cannot access the system thread group

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreads

public static Collection<Thread> findThreads(ThreadGroup group,
                                             boolean recurse,
                                             Threads.ThreadPredicate predicate)

Select all active threads which match the given predicate and which belongs to the given thread group (or one of its subgroups).

参数:

group - the thread group

recurse - if true then evaluate the predicate recursively on all threads in all subgroups of the given group

predicate - the predicate

返回:

An unmodifiable Collection of active threads which match the given predicate and which belongs to the given thread group

抛出:

IllegalArgumentException - if the given group or predicate is null

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group

findThreadGroups

public static Collection<ThreadGroup> findThreadGroups(ThreadGroup group,
                                                       boolean recurse,
                                                       Threads.ThreadGroupPredicate predicate)

Select all active threadgroups which match the given predicate and which is a subgroup of the given thread group (or one of its subgroups).

参数:

group - the thread group

recurse - if true then evaluate the predicate recursively on all threadgroups in all subgroups of the given group

predicate - the predicate

返回:

An unmodifiable Collection of active threadgroups which match the given predicate and which is a subgroup of the given thread group

抛出:

IllegalArgumentException - if the given group or predicate is null

SecurityException - if the current thread cannot modify thread groups from this thread's thread group up to the system thread group