`
javaG
  • 浏览: 554928 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

深入研究线程池

阅读更多

深入研究线程池

一.什么是线程池?
线程池就是以一个或多个线程[循环执行]多个应用逻辑的线程集合.
注意这里用了线程集合的概念是我生造的,目的是为了区分执行一批应用逻辑的多个线程和
线程组的区别.关于线程组的概念请参阅基础部分.

一般而言,线程池有以下几个部分:
1.完成主要任务的一个或多个线程.
2.用于调度管理的管理线程.
3.要求执行的任务队列.

那么如果一个线程循环执行一段代码是否是线程池?
如果极端而言,应该算,但实际上循环代码应该算上一个逻辑单元.我们说最最弱化的线程池
应该是循环执行多个逻辑单元.也就是有一批要执行的任务,这些任务被独立为多个不同的执行
单元.比如:

int x = 0;
while(true){
 x ++;
}
这就不能说循环中执行多个逻辑单元,因为它只是简单地对循环外部的初始变量执行++操作.
而如果已经有一个队列
ArrayList al = new ArrayList();
for(int i=0;i<10000;i++){
 al.add(new AClass());
}

然后在一个线程中执行:
while(al.size() != 0){
 AClass a = (AClass)al.remove(0);
 a.businessMethod();
}
我们说这个线程就是循环执行多个逻辑单元.可以说这个线程是弱化的线程池.我们习惯上把这些
相对独立的逻辑单元称为任务.

二.为什么要创建线程池?

线程池属于对象池.所有对象池都具有一个非常重要的共性,就是为了最大程度复用对象.那么
线程池的最重要的特征也就是最大程度利用线程.

从编程模型模型上说讲,在处理多任务时,每个任务一个线程是非常好的模型.如果确实可以这么
做我们将可以使用编程模型更清楚,更优化.但是在实际应用中,每个任务一个线程会使用系统限
入"过度切换"和"过度开销"的泥潭.
打个比方,如果可能,生活中每个人一辆房车,上面有休息,娱乐,餐饮等生活措施.而且道路交道永远
不堵车,那是多么美好的梦中王国啊.可是残酷的现实告诉我们,那是不可能的.不仅每个人一辆车
需要无数多的社会资源,而且地球上所能容纳的车辆总数是有限制的.

首先,创建线程本身需要额外(相对于执行任务而必须的资源)的开销.

作业系统在每创建一个线程时,至少需要创建以下资源:
线程内核对象用于对线程上下文的管理.
用户模式执行栈.
内核模式执行栈.
这些资源被线程占有后作业系统和用户都无法使用.

相反的过程,销毁线程需要回收资源,也需要一定开销.

其次,过多的线程将导致过度的切换.
线程切换带来的性能更是不可估量.系统完成线程切换要经过以下过程:
从用户模式切换到内核模式.
将CPU寄存器的值保存到当前线程的内核对象中.
打开一个自旋锁,根据调度策略决定下一个要执行的线程.释放自旋锁,如果要执行的线程不是同一
进程中的线程,还需要切换虚拟内存等进程环境.
将要执行的线程的内核对象的值写到CPU寄存器中.
切换到用户模式执行新线程的执行逻辑.

以上开销对于用户要执行的任务而言,都是额外的.更不可容忍的是,如果用户的任务逻辑都是很小
的单元,而新分配线程和线程切换的开销与任务逻辑需要的开销的比例可能会10:1,100:1,1000:1.

也就是你花了1000$买的衣服只穿了一天!

所以线程池的目的就是为了减少创建和切换线程的额外开销,利用已经的线程多次循环执行多个任
务从而提高系统的处理能力.也就是在"社会主义初级阶段"一件衣服应该尽量多穿一些天数.

[扩展知识]
尽管目前绝大多数JVM实现都是一个Java线程对应一个作业系统线程,但事实上(如果是我来实现JVM)
完全可以用一个作业系统线程执行多个Java线程,因为对于作业系统线程来说Java线程就是一个任务.
而且无论是作业系统线程或Java线程中都可以更细地划分为超细线程(纤程),即在线程内部实现对纤
程的调度利用纤程来执行任务.


三.如何实现线程池?
一个线程池至少应该具有以下几个方面的功能:

1.提供一个任务接口以便用户加入任务
由于Java不支持方法指针,所以操作(方法)只能绑定在对象上,将拥有操作的队象放入队列中,以便
工作线程能按一定策略获取对象然后执行其上的方法.

这里需要有两个组件,一是规定操作的任务接口:

interface ITask{
 public void task();
}
一是存放操作的容器.容器可以根据调度策略来选择或自己实现,比如一个最简单的FIFO策略的容器
可以用LinkedList来实现.需要注意的是对这个容器的存取需要同步:
class TaskList{
    private LinkedList<ITask> tl = new LinkedList();
    public synchronized void addTask(ITask task){
        this.tl.add(task);

//notifyAll();
    }
    //加上addFistTask和addLastTask

    public synchronized ITask getTask(){
 if(this.size() <= 0)
 wait();
        return this.tl.poll();
    }
    //加上getFistTask和getLastTask

    public synchronized int getCount(){
 return this.tl.size();
    }
    public synchronized void removeAll(){
 this.tl.clear();
    }

}

加上addFistTask和addLastTask/getFistTask和getLastTask实现就可以实现简单的优先级调度.

2.工作线程
我们把用来执行用户任务的线程称为工作线程,工作线程就是不断从队列中获取任务对象并执行对象
上的业务方法:

class WorkThread extends Thread{
    private TaskList list;
    //多个工作线程共同从一个任务队列中获取任务,所以要从外面传入一个任务队列.
    public WorkThread(String name,TaskList list){
      super(name);
      this.list = list;
    }
    public void run(){
      while(true){    
        ITask task = null;

        task = list.getTask();
        if(task != null) task.task();
      }
    }
}

在基础知识部分已经介绍了对线程状态的标记控制,请参照前面的知识自己加入对线线程状态的判断.

完成了这几个基础部分,就需要有一个对工作线程的调度线程.完成以下几个功能:
1.生成需要的工作线程.由于创建线程需要一定的开销,一定要注意所创建的所有线程不能超一个设定
的最大值.建议最大值不要超25.

2.动态自适应调整集合中线程数.当有太多的线程处于闲置状态时(队列中没有任务),应该按一定比例
销毁闲置了一定时的线程.如果队列中任务队列积压太多而工作线程总数没有超最大线程数时应该及时
创建工作线程直至达到是大值.

3.需要一个专门的后台线程定时扫描队列中任务与正在工作的线程总数,闲置的线程总数.

以上功能有不同优化方法实现,可以参考JDK的线程池实现.

分享到:
评论

相关推荐

    深入研究线程池~

    深入研究线程池:理解与应用 在计算机科学领域,线程池技术是现代多线程编程中的核心概念之一,尤其在Java等高级语言中,它被广泛应用于提高程序的并发性和响应性。线程池的基本思想是预先创建一定数量的线程,将...

    线程池示例代码

    线程池是一种多线程处理形式,用于管理并发任务的执行。它通过预先创建一组可重用线程来提高系统效率,避免频繁地创建和销毁线程带来的开销。...因此,深入研究线程池的实现和使用技巧对于提升系统性能至关重要。

    50879510A6_Java线程池_funbde_

    Java线程池是一种高效管理线程的技术,它允许开发者预创建一定数量的线程,并将任务提交到线程池中进行执行,而不是每次需要时都...因此,深入研究线程池的工作原理和使用方式,对于任何Java开发者来说都是十分必要的。

    多线程写法(精易模块线程池和鱼刺模块线程池)

    通过`content.txt`文件,我们可以深入研究这两个线程池实现的源码,理解它们的工作原理和内部机制。源码分析可以帮助我们更好地掌握如何在实际项目中应用这些线程池,优化代码性能,解决并发问题。 总之,多线程...

    VC 线程池稳定版

    线程池在软件开发中是一种优化资源管理的技术,特别是在多线程编程中,它能有效减少线程创建和销毁的开销...对于需要深入理解线程池工作原理或希望优化自己应用程序的开发者来说,研究和利用这个线程池实现将大有裨益。

    spring 线程池

    `标签`中的“源码”提示我们可以深入研究Spring线程池的实现,例如分析`ThreadPoolTaskExecutor`的源代码,了解其内部如何处理任务提交、线程管理以及异常处理等。而“工具”则可能是指Spring提供的一些工具类或辅助...

    java线程方面的初级学习程序

    Java线程是多任务编程的重要概念,特别是在Java这种支持并发执行的编程语言中。...在进一步学习中,深入研究线程池、并发集合(如`ConcurrentHashMap`)以及高级并发工具类将有助于提升我们的并发编程能力。

    简单的线程代码编写,初学入门,

    在编程世界中,多线程是一项基础且重要的技术,尤其在现代计算机系统中,它能够提升程序的执行效率,...在后续的学习中,深入研究线程池、并发容器(如`ConcurrentHashMap`)和高级并发模式将对提升编程能力大有裨益。

    CoreJava课程学习资料--Java核心技术(第8版)

    8. **并发编程**:深入研究线程池、并发容器(如ConcurrentHashMap)、原子类等,以及如何编写高效并发代码。 9. **Java EE**:如果涵盖,可能会简述Java企业级应用开发,包括Servlet、JSP、EJB等。 每一章都配有...

    C++线程池源码

    在IT行业中,线程池是一种优化资源管理的技术,它通过...如果你正在学习或研究线程池,这将是一个很好的实践案例。通过对源码的阅读和调试,你可以深入理解线程池的工作机制,以及如何在实际项目中应用这一高效的技术。

    Java基础书籍

    5. **并发编程**:深入研究线程池、并发工具类(如Semaphore、CyclicBarrier)以及并发集合。 6. **Lambda表达式和函数式编程**:Java 8引入的新特性,使代码更加简洁和高效。 7. **模块系统**:了解Java 9及以后...

    Java私塾Java初中高级教材

    2. **并发编程**:深入研究线程池、并发容器如ConcurrentHashMap,以及高级同步工具如CountDownLatch、CyclicBarrier、Semaphore。 3. **泛型高级应用**:类型擦除、通配符、类型安全的数组、协变与逆变等。 4. **...

    IOCP线程池.rar

    通过深入研究这个源码,开发者不仅可以掌握易语言的基本语法,还能深入了解Windows平台下的高性能I/O编程,这对于开发高并发网络服务或其他需要大量I/O操作的应用来说,是非常宝贵的实践经验和理论知识。

    简单的线程池模型 (Dephi版),线程池

    这为学习和自定义线程池提供了便利,可以深入理解其内部工作机制,并根据项目需求进行调整。 标签“线程池 Dephi”进一步确认了这个资源与Delphi编程语言和线程池技术的关联。在Delphi中,线程池的创建通常基于...

    JAVA经典线程池源码

    通过深入研究和使用本资源提供的"JAVA经典线程池源码",开发者不仅可以理解线程池的基本工作原理,还能学习到如何自定义线程池以适应特定场景,从而提高程序的并发性能和稳定性。在实际项目中,结合Java并发API的...

    一个Ubuntu下的C线程池

    标题中的“一个Ubuntu下的C线程池”指的是在Ubuntu操作系统上使用C语言实现的一个线程池库。...通过研究这个项目,我们可以学习到多线程编程、线程池设计、以及在C语言中使用pthread库的相关知识。

    java线程池的源码分析.zip

    Java线程池是Java并发编程中的重要组成...通过深入研究Java线程池的源码,我们可以更好地控制并发任务的执行,优化系统性能,同时避免潜在的资源浪费和线程安全问题。理解并熟练运用线程池是每个Java开发者必备的技能。

    visual c++实现线程池的例子threadpooldemosrc.rar

    在深入研究这个示例之前,你需要了解以下几个关键的多线程概念: - 线程同步:确保线程安全,防止数据竞争,例如互斥量(mutex)、信号量(semaphore)、条件变量(condition variable)等。 - 临界区:只允许一个...

    易语言线程池支持库源码

    易语言是一种专为中国人设计的编程语言,它以简化的语法和中文标识符为特点,...通过深入研究这些资源,开发者不仅可以掌握易语言中的多线程编程,还能学习到如何优化和管理线程资源,从而提高程序的性能和响应速度。

    c++ 线程池

    本文将深入探讨线程池的概念、工作原理以及如何在C++中实现一个高效的线程池。 线程池的基本思想是预先创建一组线程,这些线程不立即执行任务,而是处于等待状态。当有任务需要执行时,线程池中的空闲线程会被分配...

Global site tag (gtag.js) - Google Analytics