标题: 简单线程池的实现（1） [打印本页]

---

作者: look_w    时间: 2019-2-18 19:13     标题: 简单线程池的实现（1）

本篇主要用作链接使用。

    线程池的核心就是，当接收到一个任务，需要一个线程去执行时，并不着急创建一个线程，而是先去线程池检查是否有空闲的线程，如果有，则直接使用，如果没有则创建新的线程，然后执行任务。任务执行完成后，也不着急销毁线程，而是将线程放到线程池的空闲队列中，等待下次使用。
    首先是线程池的实现。

首先是线程池的实现：

    /**
     * Created by Joker on 2015/3/7.
     */
     public class ThreadPool {
     private static ThreadPool instance = null;
     //空闲的线程队列
     private List<JThread> idleThreads;
     //已有的线程总数
     private int threadCounter = 0;
     private Boolean isShunDown = false;
     public ThreadPool() {
         //初始化空闲线程队列容量为5
         this.idleThreads = new Vector<JThread>(5);
         this.threadCounter = 0;
     }
     private static class SingleTonHolder {
         private static ThreadPool threadPool = new ThreadPool();
     }
     /*单例获得线程池实例*/
     public static ThreadPool getInstance() {
         return SingleTonHolder.threadPool;
     }
     public int getThreadCounter() {
         return threadCounter;
     }
     
     /**
      * 将线程放入池中，回收线程
      */
     protected synchronized void repool(JThread repoolingThread) {
         if (!isShunDown) {
             idleThreads.add(repoolingThread);
         } else {
             repoolingThread.shutDown();
         }
     }
     /**
      * 停止池中所有线程
      */
     public synchronized void shutDownAll() {
         this.isShunDown = true;
         for (JThread jThread : idleThreads) {
             jThread.shutDown();
         }
     }
     
     /**
      * 执行线程任务
      */
     public synchronized void execute(Runnable target) {
         this.isShunDown = false;
         JThread jThread = null;
         /*如果池中有空余线程，直接使用该线程*/
         if (idleThreads.size() > 0) {
             jThread = idleThreads.get(idleThreads.size() - 1);
             //将该线程从池中移除
             idleThreads.remove(jThread);
             //立即执行该任务
             jThread.setTarget(target);
         }
         /*没有空闲线程，创建新线程*/
         else {
             threadCounter++;
             //创建线程
             jThread = new JThread(target, "JThread:" + threadCounter, ThreadPool.this);
             jThread.start();
         }
     }
    }

要使用上述线程池，还需要一个永不退出的工作现场与之配合。是一个While循环，手动关闭之前，永不结束，一直等待新的任务进来。

---

欢迎光临 电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/)

Powered by Discuz! 7.0.0