Package | Description |
---|---|
cn.orionsec.kit.lang.define.thread |
Modifier and Type | Method and Description |
---|---|
ExecutorBuilder |
ExecutorBuilder.allowCoreThreadTimeout()
设置线程执行超时后回收线程
|
ExecutorBuilder |
ExecutorBuilder.allowCoreThreadTimeout(boolean allowCoreThreadTimeout)
设置线程执行超时后是否回收线程
|
ExecutorBuilder |
ExecutorBuilder.corePoolSize(int corePoolSize)
设置核心池大小 默认0
|
static ExecutorBuilder |
ExecutorBuilder.create()
创建 ExecutorBuilder
|
ExecutorBuilder |
ExecutorBuilder.keepAliveTime(long keepAliveTime)
设置线程存活时间 (ms)
当池中线程多于核心大小时 多出的线程保留的时长
|
ExecutorBuilder |
ExecutorBuilder.keepAliveTime(long keepAliveTime,
TimeUnit unit)
设置线程存活时间
即当池中线程多于核心大小时 多出的线程保留的时长
|
ExecutorBuilder |
ExecutorBuilder.maxPoolSize(int maxPoolSize)
设置最大池大小 (允许同时执行的最大线程数)
|
ExecutorBuilder |
ExecutorBuilder.namedThreadFactory(String threadPrefix)
设置线程工厂
|
ExecutorBuilder |
ExecutorBuilder.preStartAllCoreThreads()
预开启所有的核心线程
|
ExecutorBuilder |
ExecutorBuilder.preStartAllCoreThreads(boolean preStartAllCoreThreads)
设置是否预开启所有的核心线程
|
ExecutorBuilder |
ExecutorBuilder.rejectHandler(RejectedExecutionHandler rejectHandler)
设置当线程阻塞 (block) 异常处理器
- 线程池和工作队列已满
|
ExecutorBuilder |
ExecutorBuilder.threadFactory(ThreadFactory threadFactory)
设置线程工厂
|
ExecutorBuilder |
ExecutorBuilder.useArrayBlockingQueue(int capacity)
使用 ArrayBlockingQueue 做为工作队列
|
ExecutorBuilder |
ExecutorBuilder.useLinkedBlockingQueue()
使用 LinkedBlockingQueue 做为工作队列
|
ExecutorBuilder |
ExecutorBuilder.useLinkedBlockingQueue(int capacity)
使用 LinkedBlockingQueue 做为工作队列
|
ExecutorBuilder |
ExecutorBuilder.useSynchronousQueue()
使用 SynchronousQueue 做为工作队列 (非公平策略)
|
ExecutorBuilder |
ExecutorBuilder.useSynchronousQueue(boolean fair)
使用 SynchronousQueue 做为工作队列
|
ExecutorBuilder |
ExecutorBuilder.workQueue(BlockingQueue<Runnable> workQueue)
设置工作队列
SynchronousQueue 它将任务直接提交给线程而不保持它们, 当运行线程小于 maxPoolSize 时会创建新线程, 否则触发异常策略
LinkedBlockingQueue 默认无界队列, 当运行线程大于 corePoolSize 时始终放入此队列, 此时 maximumPoolSize 无效
当构造LinkedBlockingQueue对象时传入参数, 变为有界队列, 队列满时, 运行线程小于 maxPoolSize 时会创建新线程, 否则触发异常策略
ArrayBlockingQueue 有界队列, 相对无界队列有利于控制队列大小, 队列满时, 运行线程小于maxPoolSize时会创建新线程, 否则触发异常策略
|
Copyright © 2024. All rights reserved.