ct:表示当前线程池当中线程的个数 。
corePoolSize:线程池当中核心线程的个数,意义和上面谈到的JDK的线程池意义一致 。
maximumPoolSize:线程池当中最大的线程个数,意义和上面谈到的JDK的线程池意义一致 。
keepAliveTime 和 unit:和JDK线程池的参数意义一致 。
taskQueue:任务队列,用不保存提交的任务 。
policy:拒绝策略 , 主要有一下四种策略:
public enum RejectPolicy { ABORT, CALLER_RUN, DISCARD_OLDEST, DISCARD}
- workers:用于保存工作线程 。
- isStopped:线程池是否被关闭了 。
- useTimed:主要是用于表示是否使用上面的 keepAliveTime 和 unit , 如果使用就是在一定的时间内,如果没有从任务队列当中获取到任务,线程就从线程池退出 , 但是需要保证线程池当中最小的线程个数不小于 corePoolSize。
实现Runnable // 下面这个方法是向线程池提交任务 public void execute(Runnable runnable) throws InterruptedException { checkPoolState(); if (addWorker(runnable, false) // 如果能够加入新的线程执行任务 加入成功就直接返回 || !taskQueue.offer(runnable) // 如果 taskQueue.offer(runnable) 返回 false 说明提交任务失败 任务队列已经满了 || addWorker(runnable, true)) // 使用能够使用的最大的线程数 (maximumPoolSize) 看是否能够产生新的线程 return; // 如果任务队列满了而且不能够加入新的线程 则拒绝这个任务 if (!taskQueue.offer(runnable)) reject(runnable); }在上面的代码当中:
- checkPoolState函数是检查线程池的状态,当线程池被停下来之后就不能够在提交任务:
private void checkPoolState() { if (isStopped) { // 如果线程池已经停下来了,就不在向任务队列当中提交任务了 throw new RuntimeException("thread pool has been stopped, so quit submitting task"); } }
- addWorker函数是往线程池当中提交任务并且产生一个线程,并且这个线程执行的第一个任务就是传递的参数 。max表示线程的最大数目 , max == true 的时候表示使用 maximumPoolSize 否则使用 corePoolSize,当返回值等于 true 的时候表示执行成功,否则表示执行失败 。
/** * * @param runnable 需要被执行的任务 * @param max 是否使用 maximumPoolSize * @return boolean */ public synchronized boolean addWorker(Runnable runnable, boolean max) { if (ct.get() >= corePoolSize && !max) return false; if (ct.get() >= maximumPoolSize && max) return false; Worker worker = new Worker(runnable); workers.add(worker); Thread thread = new Thread(worker, "ThreadPool-" + "Thread-" + ct.addAndGet(1)); thread.start(); return true; }实现Callable这个函数其实比较简单 , 只需要将传入的Callable对象封装成一个FutureTask对象即可,因为FutureTask实现了Callable和Runnable两个接口,然后将这个结果返回即可,得到这个对象,再调用对象的 get 方法就能够得到结果 。
public <V> RunnableFuture<V> submit(Callable<V> task) throws InterruptedException { checkPoolState(); FutureTask<V> futureTask = new FutureTask<>(task); execute(futureTask); return futureTask; }
推荐阅读
-
昆明机场离哪个高铁站近,昆明飞机场到高铁站有多远?
-
-
-
-
-
-
父母买房可以写未成年孩子的名字吗,规避转让税但不能贷款
-
-
-
-
-
-
-
熟黄芪泡水喝的功效与作用 熟黄芪泡水喝有哪些功效与作用
-
-
-
-
-
-
今年广东调整养老金的新消息 2022广东省养老金上调方案及补发时间