类 TaskQueue<R extends >
-
- <E>
-
- <E>
-
- <>
-
- com.alibaba.dubbo.common.threadpool.support.eager.TaskQueue<R>
-
- 所有已实现的接口:
,
<>
,<>
,<>
,<>
public class TaskQueue<R extends > extends <>
TaskQueue in the EagerThreadPoolExecutor It offer a task if the executor's submittedTaskCount less than currentPoolThreadSize or the currentPoolThreadSize more than executor's maximumPoolSize. That can make the executor create new worker when the task num is bigger than corePoolSize but less than maximumPoolSize.- 另请参阅:
- 序列化表格
-
-
构造器概要
构造器 构造器 说明 TaskQueue(int capacity)
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 boolean
runnable)
boolean
o, long timeout, unit)
retry offer taskvoid
setExecutor(EagerThreadPoolExecutor exec)
-
-
-
方法详细资料
-
setExecutor
public void setExecutor(EagerThreadPoolExecutor exec)
-
offer
public boolean offer( runnable)
- 指定者:
在接口中
<>
- 指定者:
在接口中
<>
- 覆盖:
在类中
<>
-
retryOffer
public boolean retryOffer( o, long timeout, unit) throws
retry offer task- 参数:
o
- task- 返回:
- offer success or not
- 抛出:
- if executor is terminated.
-
-