java.lang.Object java.util.concurrent.Executors
public class Executors
此包中所定义的 Executor
、ExecutorService
、ScheduledExecutorService
、ThreadFactory
和 Callable
类的工厂和实用方法。此类支持以下各种方法:
ExecutorService
的方法。 ScheduledExecutorService
的方法。 ThreadFactory
的方法,它可将新创建的线程设置为已知的状态。 Callable
的方法,这样可将其用于需要 Callable 的执行方法中。
方法摘要 | ||
---|---|---|
static Callable<Object> |
callable(PrivilegedAction<?> action) 返回 Callable 对象,调用它时可运行给定特权的操作并返回其结果。 |
|
static Callable<Object> |
callable(PrivilegedExceptionAction<?> action) 返回 Callable 对象,调用它时可运行给定特权的异常操作并返回其结果。 |
|
static Callable<Object> |
callable(Runnable task) 返回 Callable 对象,调用它时可运行给定的任务并返回 null。 |
|
static
|
callable(Runnable task, T result) 返回 Callable 对象,调用它时可运行给定的任务并返回给定的结果。 |
|
static ThreadFactory |
defaultThreadFactory() 返回用于创建新线程的默认线程工厂。 |
|
static ExecutorService |
newCachedThreadPool() 创建一个可根据需要创建新线程的线程池,但是在以前构造的线程可用时将重用它们。 |
|
static ExecutorService |
newCachedThreadPool(ThreadFactory threadFactory) 创建一个可根据需要创建新线程的线程池,但是在以前构造的线程可用时将重用它们,并在需要时使用提供的 ThreadFactory 创建新线程。 |
|
static ExecutorService |
newFixedThreadPool(int nThreads) 创建一个可重用固定线程数的线程池,以共享的无界队列方式来运行这些线程。 |
|
static ExecutorService |
newFixedThreadPool(int nThreads, ThreadFactory threadFactory) 创建一个可重用固定线程数的线程池,以共享的无界队列方式来运行这些线程,在需要时使用提供的 ThreadFactory 创建新线程。 |
|
static ScheduledExecutorService |
newScheduledThreadPool(int corePoolSize) 创建一个线程池,它可安排在给定延迟后运行命令或者定期地执行。 |
|
static ScheduledExecutorService |
newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory) 创建一个线程池,它可安排在给定延迟后运行命令或者定期地执行。 |
|
static ExecutorService |
newSingleThreadExecutor() 创建一个使用单个 worker 线程的 Executor,以无界队列方式来运行该线程。 |
|
static ExecutorService |
newSingleThreadExecutor(ThreadFactory threadFactory) 创建一个使用单个 worker 线程的 Executor,以无界队列方式来运行该线程,并在需要时使用提供的 ThreadFactory 创建新线程。 |
|
static ScheduledExecutorService |
newSingleThreadScheduledExecutor() 创建一个单线程执行程序,它可安排在给定延迟后运行命令或者定期地执行。 |
|
static ScheduledExecutorService |
newSingleThreadScheduledExecutor(ThreadFactory threadFactory) 创建一个单线程执行程序,它可安排在给定延迟后运行命令或者定期地执行。 |
|
static
|
privilegedCallable(Callable<T> callable) 返回 Callable 对象,调用它时可在当前的访问控制上下文中执行给定的 callable 对象。 |
|
static
|
privilegedCallableUsingCurrentClassLoader(Callable<T> callable) 返回 Callable 对象,调用它时可在当前的访问控制上下文中,使用当前上下文类加载器作为上下文类加载器来执行给定的 callable 对象。 |
|
static ThreadFactory |
privilegedThreadFactory() 返回用于创建新线程的线程工厂,这些新线程与当前线程具有相同的权限。 |
|
static ExecutorService |
unconfigurableExecutorService(ExecutorService executor) 返回一个将所有已定义的 ExecutorService 方法委托给指定执行程序的对象,但是使用强制转换可能无法访问其他方法。 |
|
static ScheduledExecutorService |
unconfigurableScheduledExecutorService(ScheduledExecutorService executor) 返回一个将所有已定义的 ExecutorService 方法委托给指定执行程序的对象,但是使用强制转换可能无法访问其他方法。 |
从类 java.lang.Object 继承的方法 |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
方法详细信息 |
---|
public static ExecutorService newFixedThreadPool(int nThreads)
关闭
之前,池中的线程将一直存在。
nThreads
- 池中的线程数
IllegalArgumentException
- 如果
nThreads <= 0
public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory)
关闭
之前,池中的线程将一直存在。
nThreads
- 池中的线程数
threadFactory
- 创建新线程时使用的工厂
NullPointerException
- 如果 threadFactory 为 null
IllegalArgumentException
- 如果
nThreads <= 0
public static ExecutorService newSingleThreadExecutor()
public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory)
threadFactory
- 创建新线程时使用的工厂
NullPointerException
- 如果 threadFactory 为 null
public static ExecutorService newCachedThreadPool()
ThreadPoolExecutor
构造方法创建具有类似属性但细节不同(例如超时参数)的线程池。
public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory)
threadFactory
- 创建新线程时使用的工厂
NullPointerException
- 如果 threadFactory 为 null
public static ScheduledExecutorService newSingleThreadScheduledExecutor()
public static ScheduledExecutorService newSingleThreadScheduledExecutor(ThreadFactory threadFactory)
threadFactory
- 创建新线程时使用的工厂
NullPointerException
- 如果 threadFactory 为 null
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
corePoolSize
- 池中所保存的线程数,即使线程是空闲的也包括在内。
NullPointerException
- 如果 threadFactory 为 null
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory)
corePoolSize
- 池中所保存的线程数,即使线程是空闲的也包括在内
threadFactory
- 执行程序创建新线程时使用的工厂
IllegalArgumentException
- 如果
corePoolSize < 0
NullPointerException
- 如果 threadFactory 为 null
public static ExecutorService unconfigurableExecutorService(ExecutorService executor)
ExecutorService
方法委托给指定执行程序的对象,但是使用强制转换可能无法访问其他方法。这提供了一种可安全地“冻结”配置并且不允许调整给定具体实现的方法。
executor
- 底层实现
NullPointerException
- 如果 executor 为 null
public static ScheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor)
ExecutorService
方法委托给指定执行程序的对象,但是使用强制转换可能无法访问其他方法。这提供了一种可安全地“冻结”配置并且不允许调整给定具体实现的方法。
executor
- 底层实现
NullPointerException
- 如果 executor 为 null
public static ThreadFactory defaultThreadFactory()
ThreadGroup
中 Executor 使用的所有新线程。如果有
SecurityManager
,则它使用
System.getSecurityManager()
组来调用此
defaultThreadFactory 方法,其他情况则使用线程组。每个新线程都作为非守护程序而创建,并且具有设置为
Thread.NORM_PRIORITY 中较小者的优先级以及线程组中允许的最大优先级。新线程具有可通过
pool-N-thread-M 的
Thread.getName()
来访问的名称,其中
N 是此工厂的序列号,
M 是此工厂所创建线程的序列号。
public static ThreadFactory privilegedThreadFactory()
defaultThreadFactory()
相同设置的线程,新线程的 AccessControlContext 和 contextClassLoader 的其他设置与调用此
privilegedThreadFactory 方法的线程相同。可以在
AccessController.doPrivileged(java.security.PrivilegedAction
)
操作中创建一个新
privilegedThreadFactory,设置当前线程的访问控制上下文,以便创建具有该操作中保持的所选权限的线程。
注意,虽然运行在此类线程中的任务具有与当前线程相同的访问控制和类加载器,但是它们无需具有相同的 ThreadLocal
或 InheritableThreadLocal
值。如有必要,使用 ThreadPoolExecutor.beforeExecute(java.lang.Thread, java.lang.Runnable)
在 ThreadPoolExecutor
子类中运行任何任务前,可以设置或重置线程局部变量的特定值。另外,如果必须初始化 worker 线程,以具有与某些其他指定线程相同的 InheritableThreadLocal 设置,则可以在线程等待和服务创建请求的环境中创建自定义的 ThreadFactory,而不是继承其值。
AccessControlException
- 如果当前访问控制上下文没有获取和设置上下文类加载器的权限。
public static <T> Callable<T> callable(Runnable task, T result)
Callable
对象,调用它时可运行给定的任务并返回给定的结果。这在把需要
Callable 的方法应用到其他无结果的操作时很有用。
task
- 要运行的任务
result
- 返回的结果
NullPointerException
- 如果 task 为 null
public static Callable<Object> callable(Runnable task)
Callable
对象,调用它时可运行给定的任务并返回
null。
task
- 要运行的任务
NullPointerException
- 如果 task 为 null
public static Callable<Object> callable(PrivilegedAction<?> action)
Callable
对象,调用它时可运行给定特权的操作并返回其结果。
action
- 要运行的特权操作
NullPointerException
- 如果 action 为 null
public static Callable<Object> callable(PrivilegedExceptionAction<?> action)
Callable
对象,调用它时可运行给定特权的异常操作并返回其结果。
action
- 要运行的特权异常操作
NullPointerException
- 如果 action 为 null
public static <T> Callable<T> privilegedCallable(Callable<T> callable)
Callable
对象,调用它时可在当前的访问控制上下文中执行给定的
callable 对象。通常应该在
AccessController.doPrivileged(java.security.PrivilegedAction
)
操作中调用此方法,以便创建 callable 对象,并且如有可能,则在该操作中保持的所选权限设置下执行此对象;如果无法调用,则抛出相关的
AccessControlException
。
callable
- 底层任务
NullPointerException
- 如果 callable 为 null
public static <T> Callable<T> privilegedCallableUsingCurrentClassLoader(Callable<T> callable)
Callable
对象,调用它时可在当前的访问控制上下文中,使用当前上下文类加载器作为上下文类加载器来执行给定的
callable 对象。通常应该在
AccessController.doPrivileged(java.security.PrivilegedAction
)
操作中调用此方法,以创建 callable 对象,并且如有可能,则在该操作中保持的所选权限设置下执行此对象;如果无法调用,则抛出相关的
AccessControlException
。
callable
- 底层任务
NullPointerException
- 如果 callable 为 null
AccessControlException
- 如果当前的访问控制上下文没有设置和获得上下文类加载器的权限。