|
Lines 49-54
Link Here
|
| 49 |
|
49 |
|
| 50 |
protected String name; |
50 |
protected String name; |
| 51 |
|
51 |
|
|
|
52 |
protected boolean prestartminSpareThreads = false; |
| 53 |
|
| 52 |
private LifecycleSupport lifecycle = new LifecycleSupport(this); |
54 |
private LifecycleSupport lifecycle = new LifecycleSupport(this); |
| 53 |
// ---------------------------------------------- Constructors |
55 |
// ---------------------------------------------- Constructors |
| 54 |
public StandardThreadExecutor() { |
56 |
public StandardThreadExecutor() { |
|
Lines 64-69
Link Here
|
| 64 |
TaskThreadFactory tf = new TaskThreadFactory(namePrefix); |
66 |
TaskThreadFactory tf = new TaskThreadFactory(namePrefix); |
| 65 |
lifecycle.fireLifecycleEvent(START_EVENT, null); |
67 |
lifecycle.fireLifecycleEvent(START_EVENT, null); |
| 66 |
executor = new ThreadPoolExecutor(getMinSpareThreads(), getMaxThreads(), maxIdleTime, TimeUnit.MILLISECONDS,taskqueue, tf); |
68 |
executor = new ThreadPoolExecutor(getMinSpareThreads(), getMaxThreads(), maxIdleTime, TimeUnit.MILLISECONDS,taskqueue, tf); |
|
|
69 |
if (prestartminSpareThreads) { |
| 70 |
executor.prestartAllCoreThreads(); |
| 71 |
} |
| 67 |
taskqueue.setParent( (ThreadPoolExecutor) executor); |
72 |
taskqueue.setParent( (ThreadPoolExecutor) executor); |
| 68 |
lifecycle.fireLifecycleEvent(AFTER_START_EVENT, null); |
73 |
lifecycle.fireLifecycleEvent(AFTER_START_EVENT, null); |
| 69 |
} |
74 |
} |
|
Lines 116-121
Link Here
|
| 116 |
return name; |
121 |
return name; |
| 117 |
} |
122 |
} |
| 118 |
|
123 |
|
|
|
124 |
public boolean isPrestartminSpareThreads() { |
| 125 |
|
| 126 |
return prestartminSpareThreads; |
| 127 |
} |
| 119 |
public void setThreadPriority(int threadPriority) { |
128 |
public void setThreadPriority(int threadPriority) { |
| 120 |
this.threadPriority = threadPriority; |
129 |
this.threadPriority = threadPriority; |
| 121 |
} |
130 |
} |
|
Lines 143-148
Link Here
|
| 143 |
public void setName(String name) { |
152 |
public void setName(String name) { |
| 144 |
this.name = name; |
153 |
this.name = name; |
| 145 |
} |
154 |
} |
|
|
155 |
|
| 156 |
public void setPrestartminSpareThreads(boolean prestartminSpareThreads) { |
| 157 |
this.prestartminSpareThreads = prestartminSpareThreads; |
| 158 |
} |
| 146 |
|
159 |
|
| 147 |
/** |
160 |
/** |
| 148 |
* Add a LifecycleEvent listener to this component. |
161 |
* Add a LifecycleEvent listener to this component. |