util/concurrent/ThreadPoolExecutor.java

83  * corePoolSize (see {@link #getCorePoolSize}) and
87  * if fewer than corePoolSize threads are running, a new thread is
91  * is full.  By setting corePoolSize and maximumPoolSize the same, you
126  * <dd>If the pool currently has more than corePoolSize threads,
136  * applies only when there are more than corePoolSize threads, but
148  * <li>If fewer than corePoolSize threads are running, the Executor
152  * <li>If corePoolSize or more threads are running, the Executor
179  * corePoolSize threads are busy. Thus, no more than corePoolSize
524      * Threads use this timeout when there are more than corePoolSize
542     private volatile int corePoolSize;
886      * than corePoolSize threads (in which case we always start one),
891      * @param core if true use corePoolSize as bound, else
913                     wc >= (core ? corePoolSize : maximumPoolSize))
991      * corePoolSize workers are running or queue is non-empty but
1015                 int min = allowCoreThreadTimeOut ? 0 : corePoolSize;
1035      *    {@code allowCoreThreadTimeOut || workerCount > corePoolSize})
1058             boolean timed = allowCoreThreadTimeOut || wc > corePoolSize;
1177      * @param corePoolSize the number of threads to keep in the pool, even
1189      *         {@code corePoolSize < 0}<br>
1192      *         {@code maximumPoolSize < corePoolSize}
1195     public ThreadPoolExecutor(int corePoolSize,
1200         this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
1209      * @param corePoolSize the number of threads to keep in the pool, even
1223      *         {@code corePoolSize < 0}<br>
1226      *         {@code maximumPoolSize < corePoolSize}
1230     public ThreadPoolExecutor(int corePoolSize,
1236         this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
1245      * @param corePoolSize the number of threads to keep in the pool, even
1259      *         {@code corePoolSize < 0}<br>
1262      *         {@code maximumPoolSize < corePoolSize}
1266     public ThreadPoolExecutor(int corePoolSize,
1272         this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
1280      * @param corePoolSize the number of threads to keep in the pool, even
1296      *         {@code corePoolSize < 0}<br>
1299      *         {@code maximumPoolSize < corePoolSize}
1303     public ThreadPoolExecutor(int corePoolSize,
1310         if (corePoolSize < 0 ||
1312             maximumPoolSize < corePoolSize ||
1320         this.corePoolSize = corePoolSize;
1348          * 1. If fewer than corePoolSize threads are running, try to
1366         if (workerCountOf(c) < corePoolSize) {
1566      * @param corePoolSize the new core size
1567      * @throws IllegalArgumentException if {@code corePoolSize < 0}
1568      *         or {@code corePoolSize} is greater than the {@linkplain
1572     public void setCorePoolSize(int corePoolSize) {
1573         if (corePoolSize < 0 || maximumPoolSize < corePoolSize)
1575         int delta = corePoolSize - this.corePoolSize;
1576         this.corePoolSize = corePoolSize;
1577         if (workerCountOf(ctl.get()) > corePoolSize)
1599         return corePoolSize;
1611         return workerCountOf(ctl.get()) < corePoolSize &&
1617      * thread is started even if corePoolSize is 0.
1621         if (wc < corePoolSize)
1698         if (maximumPoolSize <= 0 || maximumPoolSize < corePoolSize)