com.gitee.baa.thread

类 RunnerUtils

java.lang.Object

com.gitee.baa.thread.RunnerUtils

public class RunnerUtils
extends Object

多线程执行工具

从以下版本开始:

2011-5-18

嵌套类概要

嵌套类

限定符和类型	类和说明
(专用程序包) static class	RunnerUtils.Monitor

字段概要

字段

限定符和类型	字段和说明
private static ThreadPoolExecutor	executor
private static ScheduledThreadPoolExecutor	scheduledExecutor

构造器概要

构造器

构造器和说明
RunnerUtils()

方法概要

限定符和类型	方法和说明
private static void	initExecutor()
private static void	initScheduledExecutor()
private static void	printException(Runnable r, Throwable t) 输出任务异常堆栈 线程池默认捕获了所有异常，通常通过feture.get()能获取到异常，如果调用者没有主动获取异常，那么此异常则被吃掉了。
static ScheduledFuture<?>	schedule(Runnable task, long delay)
static ScheduledFuture<?>	schedule(Runnable task, long initialDelay, long delay) 周期性调度一个任务
static void	shutdown() 关闭线程池，并等待线程池中所有任务执行完毕
static void	shutdownNow() 立即关闭线程池，不等待线程池中所有任务执行完毕
static <V> Future<V>	submit(Callable<V> task) 异步执行一个任务
static Future<?>	submit(Runnable task) 异步执行一个任务

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

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

字段详细资料

executor

private static volatile ThreadPoolExecutor executor

scheduledExecutor

private static volatile ScheduledThreadPoolExecutor scheduledExecutor

构造器详细资料

RunnerUtils

public RunnerUtils()

方法详细资料

initExecutor

private static void initExecutor()

initScheduledExecutor

private static void initScheduledExecutor()

printException

private static void printException(Runnable r,
                                   Throwable t)

输出任务异常堆栈

线程池默认捕获了所有异常，通常通过feture.get()能获取到异常，如果调用者没有主动获取异常，那么此异常则被吃掉了。

参数:

r - 任务名称

t - 异常堆栈

schedule

public static ScheduledFuture<?> schedule(Runnable task,
                                          long initialDelay,
                                          long delay)

周期性调度一个任务

参数:

task - 任务

initialDelay - 初始延时（毫秒）

delay - 周期延时（毫秒）

schedule

public static ScheduledFuture<?> schedule(Runnable task,
                                          long delay)

shutdown

public static void shutdown()

关闭线程池，并等待线程池中所有任务执行完毕

shutdownNow

public static void shutdownNow()

立即关闭线程池，不等待线程池中所有任务执行完毕

submit

public static <V> Future<V> submit(Callable<V> task)

异步执行一个任务

参数:

task - 任务

返回:

任务结果

submit

public static Future<?> submit(Runnable task)

异步执行一个任务

参数:

task - 任务