Threads (orion-kit 2.0.1 API)

java.lang.Object
- cn.orionsec.kit.lang.utils.Threads

```
public class Threads
extends Object
```
线程工具类

Since:

2020/2/24 18:13

Version:

1.0.0

Author:

Jiahang Li

Field Summary

Fields
Modifier and Type Field and Description

static ExecutorService CACHE_EXECUTOR
全局线程池

static ExecutorService GLOBAL_EXECUTOR
Threads 线程池

Fields
Modifier and Type	Field and Description
`static ExecutorService`	`CACHE_EXECUTOR` 全局线程池
`static ExecutorService`	`GLOBAL_EXECUTOR` Threads 线程池

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static void`	`blockRun(Collection<? extends Runnable> rs, ExecutorService pool)` 阻塞运行线程
`static void`	`blockRun(Runnable r, CountDownLatch c, ExecutorService pool)` 阻塞运行线程
`static void`	`blockRun(Runnable r, int count, ExecutorService pool)` 阻塞运行线程
`static <V> Future<V>`	`call(Callable<V> c)`
`static <V> Future<V>`	`call(Callable<V> c, ExecutorService pool)` 执行线程
`static <V> List<Future<V>>`	`call(Collection<? extends Callable<V>> cs, ExecutorService pool)` 执行线程
`static Tuple`	`collect(Callable<?>... tasks)` 多线程执行任务并且收集结果
`static <V> List<Future<V>>`	`concurrent(Callable<V> c, ExecutorService pool, CountDownLatch cd)` 并发多次单个线程线程池的最大线程数必须大于等于并发次数
`static <V> List<Future<V>>`	`concurrent(Callable<V> c, ExecutorService pool, CyclicBarrier cb)` 并发多次单个线程线程池的最大线程数必须大于等于并发次数
`static <V> List<Future<V>>`	`concurrent(Callable<V> c, int count, ExecutorService pool)` 并发多次单个线程线程池的最大线程数必须大于等于并发次数
`static void`	`concurrent(Runnable r, ExecutorService pool, CountDownLatch cd)` 并发多次单个线程线程池的最大线程数必须大于等于并发次数
`static void`	`concurrent(Runnable r, ExecutorService pool, CyclicBarrier cb)` 并发多次单个线程线程池的最大线程数必须大于等于并发次数
`static CyclicBarrier`	`concurrent(Runnable r, int count, ExecutorService pool)` 并发多次单个线程线程池的最大线程数必须大于等于并发次数
`static <V> List<Future<V>>`	`concurrentCallable(Collection<? extends Callable<V>> cs, ExecutorService pool)` 并发多个线程线程池的最大线程数必须大于等于并发次数
`static void`	`concurrentRunnable(Collection<? extends Runnable> rs, ExecutorService pool)` 并发多个线程线程池的最大线程数必须大于等于并发次数
`static ExecutorService`	`newThreadPool(int core, int max, int keepMilli, BlockingQueue<Runnable> workQueue, String prefix)` 创建线程池
`static ExecutorService`	`newThreadPool(int core, int max, int keepMilli, BlockingQueue<Runnable> workQueue, String prefix, RejectedExecutionHandler handler)` 创建线程池
`static void`	`shutdownPool(ExecutorService pool, int shutdownTimeout)` 关闭线程池
`static void`	`shutdownPool(ExecutorService pool, int shutdownTimeout, int shutdownNowTimeout)` 关闭线程池
`static void`	`shutdownPool(ExecutorService pool, int shutdownTimeout, int shutdownNowTimeout, TimeUnit timeUnit)` 关闭线程池
`static void`	`shutdownPool(ExecutorService pool, int shutdownTimeout, TimeUnit timeUnit)` 关闭线程池
`static void`	`shutdownPoolNow(ExecutorService pool, int timeout)` 立即关闭线程池
`static void`	`shutdownPoolNow(ExecutorService pool, int timeout, TimeUnit timeUnit)` 立即关闭线程池
`static void`	`sleep(long millis)`
`static void`	`sleep(long duration, TimeUnit unit)` 线程休眠
`static void`	`start(Collection<Runnable> rs, ExecutorService pool)` 执行线程
`static void`	`start(Runnable r)`
`static void`	`start(Runnable r, ExecutorService pool)` 执行线程

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

GLOBAL_EXECUTOR

public static final ExecutorService GLOBAL_EXECUTOR

Threads 线程池

CACHE_EXECUTOR

public static final ExecutorService CACHE_EXECUTOR

全局线程池

Method Detail

start
```
public static void start(Runnable r)
```

start

public static void start(Runnable r,
                         ExecutorService pool)

执行线程

Parameters:: r - ignore; pool - 线程池

start

public static void start(Collection<Runnable> rs,
                         ExecutorService pool)

执行线程

Parameters:: rs - 线程; pool - 线程池

call

public static <V> Future<V> call(Callable<V> c)

call

public static <V> Future<V> call(Callable<V> c,
                                 ExecutorService pool)

执行线程

Parameters:: c - ignore; pool - 线程池
Returns:: Future

call

public static <V> List<Future<V>> call(Collection<? extends Callable<V>> cs,
                                       ExecutorService pool)

执行线程

Parameters:: cs - ignore; pool - 线程池
Returns:: Future

sleep

public static void sleep(long millis)

sleep

public static void sleep(long duration,
                         TimeUnit unit)

线程休眠

Parameters:: duration - 时间; unit - 时间单位

collect
```
public static Tuple collect(Callable<?>... tasks)
```
多线程执行任务并且收集结果

Parameters:

tasks - 任务

Returns:

元组

blockRun

public static void blockRun(Runnable r,
                            int count,
                            ExecutorService pool)
                     throws InterruptedException

阻塞运行线程

Parameters:: r - 线程; count - 执行次数; pool - 线程池
Throws:: InterruptedException - InterruptedException

blockRun

public static void blockRun(Runnable r,
                            CountDownLatch c,
                            ExecutorService pool)
                     throws InterruptedException

阻塞运行线程

Parameters:: r - 线程; c - 闭锁; pool - 线程池
Throws:: InterruptedException - InterruptedException

blockRun

public static void blockRun(Collection<? extends Runnable> rs,
                            ExecutorService pool)
                     throws InterruptedException

阻塞运行线程

Parameters:: rs - 线程; pool - 线程池
Throws:: InterruptedException - InterruptedException

concurrent

public static CyclicBarrier concurrent(Runnable r,
                                       int count,
                                       ExecutorService pool)

并发多次单个线程

线程池的最大线程数必须大于等于并发次数

Parameters:: r - runnable; count - 并发次数; pool - 线程池
Returns:: 屏障

concurrent

public static void concurrent(Runnable r,
                              ExecutorService pool,
                              CyclicBarrier cb)

并发多次单个线程

线程池的最大线程数必须大于等于并发次数

Parameters:: r - runnable; pool - 线程池; cb - 屏障

concurrent

public static void concurrent(Runnable r,
                              ExecutorService pool,
                              CountDownLatch cd)

并发多次单个线程

线程池的最大线程数必须大于等于并发次数

Parameters:: r - runnable; pool - 线程池; cd - 闭锁

concurrent

public static <V> List<Future<V>> concurrent(Callable<V> c,
                                             int count,
                                             ExecutorService pool)

并发多次单个线程

线程池的最大线程数必须大于等于并发次数

Parameters:: c - callable; count - 并发次数; pool - 线程池
Returns:: Future

concurrent

public static <V> List<Future<V>> concurrent(Callable<V> c,
                                             ExecutorService pool,
                                             CyclicBarrier cb)

并发多次单个线程

线程池的最大线程数必须大于等于并发次数

Parameters:: c - callable; pool - 线程池; cb - 屏障
Returns:: Future

concurrent

public static <V> List<Future<V>> concurrent(Callable<V> c,
                                             ExecutorService pool,
                                             CountDownLatch cd)

并发多次单个线程

线程池的最大线程数必须大于等于并发次数

Parameters:: c - callable; pool - 线程池; cd - 闭锁
Returns:: Future

concurrentRunnable

public static void concurrentRunnable(Collection<? extends Runnable> rs,
                                      ExecutorService pool)

并发多个线程

线程池的最大线程数必须大于等于并发次数

Parameters:: rs - 线程; pool - 线程池

concurrentCallable

public static <V> List<Future<V>> concurrentCallable(Collection<? extends Callable<V>> cs,
                                                     ExecutorService pool)

并发多个线程

线程池的最大线程数必须大于等于并发次数

Parameters:: cs - 线程; pool - 线程池
Returns:: Future

shutdownPool

public static void shutdownPool(ExecutorService pool,
                                int shutdownTimeout)

关闭线程池

Parameters:: pool - 线程池; shutdownTimeout - 终止时间

shutdownPool

public static void shutdownPool(ExecutorService pool,
                                int shutdownTimeout,
                                TimeUnit timeUnit)

关闭线程池

Parameters:: pool - 线程池; shutdownTimeout - 终止时间; timeUnit - 时间单位

shutdownPool
```
public static void shutdownPool(ExecutorService pool,
                                int shutdownTimeout,
                                int shutdownNowTimeout)
```
关闭线程池

Parameters:

pool - 线程池

shutdownTimeout - 终止时间

shutdownNowTimeout - 如果调用终止超时, 取消队列中的Pending的任务, 中断阻塞的时间

shutdownPool

public static void shutdownPool(ExecutorService pool,
                                int shutdownTimeout,
                                int shutdownNowTimeout,
                                TimeUnit timeUnit)

关闭线程池

Parameters:: pool - 线程池; shutdownTimeout - 终止时间; shutdownNowTimeout - 如果调用终止超时, 取消队列中的Pending的任务, 中断阻塞的时间; timeUnit - 时间单位

shutdownPoolNow
```
public static void shutdownPoolNow(ExecutorService pool,
                                   int timeout)
```
立即关闭线程池

Parameters:

pool - 线程池

timeout - 取消队列中的Pending的任务, 中断阻塞的时间毫秒

shutdownPoolNow

public static void shutdownPoolNow(ExecutorService pool,
                                   int timeout,
                                   TimeUnit timeUnit)

立即关闭线程池

Parameters:: pool - 线程池; timeout - 取消队列中的Pending的任务, 中断阻塞的时间; timeUnit - 时间单位

newThreadPool

public static ExecutorService newThreadPool(int core,
                                            int max,
                                            int keepMilli,
                                            BlockingQueue<Runnable> workQueue,
                                            String prefix)

创建线程池

Parameters:: core - 核心线程数量; max - 最大线程数; keepMilli - 空闲线程等待时间; workQueue - 任务队列; prefix - 线程前缀
Returns:: 线程池

newThreadPool

public static ExecutorService newThreadPool(int core,
                                            int max,
                                            int keepMilli,
                                            BlockingQueue<Runnable> workQueue,
                                            String prefix,
                                            RejectedExecutionHandler handler)

创建线程池

Parameters:: core - 核心线程数量; max - 最大线程数; keepMilli - 空闲线程等待时间; workQueue - 任务队列; prefix - 线程前缀; handler - 任务队列已满时的拒绝策略
Returns:: 线程池

Class Threads

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

GLOBAL_EXECUTOR

CACHE_EXECUTOR

Method Detail

start

start

start

call

call

call

sleep

sleep

collect

blockRun

blockRun

blockRun

concurrent

concurrent

concurrent

concurrent

concurrent

concurrent

concurrentRunnable

concurrentCallable

shutdownPool

shutdownPool

shutdownPool

shutdownPool

shutdownPoolNow

shutdownPoolNow

newThreadPool

newThreadPool