<Java> Mina线程池

前言

  在java并发编程中,线程池是非常常见的一种维护线程封闭的技术,当然在我们的web开发中,最熟悉的就是jdbc的连接池,那么这两种池有什么关系吗?

  答案显然是否定的,前置是实现线程安全性需要,后者是为了复用系统资源需要。我们先来讲讲线程池。

线程池

  从字面上来理解,池是管理一小组同构工作的资源池。它是与工作队列(Work Queue)密切相关的,工作队列是指保存了所有等待执行任务的队列。执行每个任务的线程叫做工作者线程(Work Thread),它的任务就是:到队列中领取一个任务,执行完后自己回到线程池中,等待下一个任务。

  那问题来了:为什么不每个任务开一个线程呢,这样也是差不多意思啊,这个问题的关键在于没有认识到创建线程和销毁线程是需要巨大的开销的,此外一个任务过来需要再去创建线程是需要时间的,就造成了任务执行的延迟,而这两个问题通过使用线程池通通解决了。

  如何创建线程池:

  在java的concurrent包中,提供了Executors可以方便的配置线程池。至于这个对象提供的一些方法,可以自行查找。

  Executor框架使用Runnable作为基本的任务表现形式,它是一种有很大局限性的抽象,它不能返回一个值或者不能抛出守检查的异常。对于一个任务对象,一般都是存在计算成本或I/O成本的,对于这些任务,Callable是一个比Runnable更好的封装。Executor的所有submit方法都会返回一个Future来描述任务。

  Future表示一个任务的生命周期,提供相应的方法来判断任务是否已经完成、任务是否已经取消、获取任务结果、取消任务等操作。

Mina线程池

  下面我们来讨论下Mina框架的线程池:

  Mina主要有四个地方使用了线程池:

    1.IoAcceptor/IoConnector线程池

      这两个都是继承自IoService接口的抽象实现类AbstractIoService,在AbstractIoService中,有:

        

      可以看到它使用的newCachedThreadPool(),这个方法提供的是一个可变大小的线程池。IoAcceptor每建立一个监听端口就开启一个线程,IoConnector每建立一个连接就开启一个线程。它们的线程都是从线程池中取的。

    2.IoProcess线程池

      每建立好一个连接之后,就生成一个IoSession,于是就可以将IoSession视为任务列表,都在等待执行(读取或写入操作),而IoProcess就充当了执行者的角色。我们可以在IoService创建的时候,就指定IoProcess线程池的大小,如下:

        

      如果我们不指定,则取默认值,如下:

        

      IoProcess其实是通过维护一个数组来实现线程池的,而数组中的对象其实也是从newCachedThreadPool中取出来的,至于它为什么不用newFixedThreadPool就未从可知了。

          

        

      IoProcess线程的生命周期有多长,取决于它执行的任务,他执行的任务就是完成一次socket对话,也就是IoSession的生命周期。

  3.IoHandler线程池

    数据在经过codec之后,就被送到handler中执行业务逻辑操作,而这块操作还是由IoProcess线程处理的,如果在handler中有非常耗时的操作,如磁盘I/O,复杂计算等,就造成IoProcess线程池无法回收这些线程,如果有大量socket连接,就会被等待。
    其实我们可以在过滤链上增加一个threadPool,这样在handler中的处理就交给另一个线程池,而IoProcess则可以返回到原来的池中。

    

  

    

时间: 2024-10-21 14:07:35

<Java> Mina线程池的相关文章

深入理解Java之线程池

原作者:海子 出处:http://www.cnblogs.com/dolphin0520/ 本文归作者海子和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利. 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了,这样频繁创建线程就会大大降低系统的效率,因为频繁创建线程和销毁线程需要时间. 那么有没有一种办法使得线程可

Java(Android)线程池 总结

一种是使用Executors工厂生产线程池:另一种是直接使用ThreadPoolExecutor自定义. Executors工厂生产线程池 Java(Android)线程池 Trinea 介绍new Thread的弊端及Java四种线程池的使用,对Android同样适用.本文是基础篇,后面会分享下线程池一些高级功能. 1.new Thread的弊端执行一个异步任务你还只是如下new Thread吗? Java 1 2 3 4 5 6 7 newThread(newRunnable(){ @Ove

Java高新技术—线程池的使用

一. 问题引入 我们知道可以用1.继承Thread类 2.实现runnable接口两种方法创建一个线程,这样实现起来很方便,但是同样出现了一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了,这样频繁创建线程就会大大降低系统的效率, 因为频繁创建线程和销毁线程需要时间. 那么有没有一种办法使得线程可以复用,就是执行完一个任务,并不被销毁,而是可以继续执行其他的任务? 在Java中可以通过线程池来达到这样的效果! 二. 线程池简介 ① Jdk1.5之后加入了java.

[转]深入理解Java之线程池

出处:http://www.cnblogs.com/dolphin0520/ 本文归作者海子和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利. 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了,这样频繁创建线程就会大大降低系统的效率,因为频繁创建线程和销毁线程需要时间. 那么有没有一种办法使得线程可以复用,就是执

java自制线程池

个人博客:www.zalezone.cn java自制线程池 暂无评论 1. 简介 1.1. 线程池 1.2. 线程池作用 1.3. 线程池优点 1.4. JDK自带线程池 1.4.1. ThreadPoolExecutor 2. 自制线程池 2.1. 线程池主体类 2.2. 任务类 2.3. 测试类 简介 线程池 线程池的基本思想是一种对象池的思想,先开辟一块内存空间,开许多等待任务的线程,一旦有任务出现就直接使用线程池中的线程来进行任务,等到任务结束后再将这个线程放入线程池中,池中的执行调度

Java(Android)线程池---基础篇

1.new Thread的弊端 执行一个异步任务你还只是如下new Thread吗? 1 newThread(newRunnable(){ 2 3 @Override 4 publicvoidrun(){ 5 // TODO Auto-generated method stub 6 } 7 }).start(); 那你就out太多了,new Thread的弊端如下: a. 每次new Thread新建对象性能差.b. 线程缺乏统一管理,可能无限制新建线程,相互之间竞争,及可能占用过多系统资源导致

关于Java中线程池的解读

之前的面试中多次被问到线程池的相关内容,所以在之后的时间内我仔细的学习了一下线程池的相关内容. 1.使用线程池的意义 复用:类似WEB服务器等系统,长期来看内部需要使用大量的线程处理请求,而单次请求响应时间通常比较短,此时Java基于操作系统的本地调用方式大量的创建和销毁线程本身会成为系统的一个性能瓶颈和资源浪费.若使用线程池技术可以实现工作线程的复用,即一个工作线程创建和销毁的生命周期期间内可以执行处理多个任务,从而总体上降低线程创建和销毁的频率和时间,提升了系统性能. 流控:服务器资源有限,

Java Executors(线程池)

Java Executors(线程池) //介绍了 Executors 创建线程池的多种方法和 差别,可以对照源码 学习

线程池;java实现线程池原理

线程池是一种多线程处理形式,处理过程中将任务添加到队列,然后在创建线程后自动启动这些任务.线程池线程都是后台线程.每个线程都使用默认的堆栈大小,以默认的优先级运行,并处于多线程单元中.如果某个线程在托管代码中空闲(如正在等待某个事件),则线程池将插入另一个辅助线程来使所有处理器保持繁忙.如果所有线程池线程都始终保持繁忙,但队列中包含挂起的工作,则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值.超过最大值的线程可以排队,但他们要等到其他线程完成后才启动. 组成部分 1.线程池