JDK自带线程池学习

bdk82924

浏览: 565486 次
性别:
来自: 南京

最近访客更多访客>>

javabang

zjzeric

zfantasy789

zhu1361

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

Java相关
线程相关

JDK Java Blog

线程池主类：

Java代码

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class DataHandlerThreadPool {
//核心线程数量，即初始化线程池的启动线程数量
private static final int corePoolSize = 10;
//最大线程数量
private static final int maximumPoolSize = 20;
//线程的存活时间，即完成任务后多久可再使用
private static final int keepAliveTime = 300;
//等待队列的长度
private static final int workQueueSize = 30;
private static ThreadPoolExecutor exec = null;
public static ThreadPoolExecutor getDHThreadPool() {
if (exec == null) {
//ThreadPoolExceptionHandler表示当线程池处理不了规定任务时的异常处理方式。
exec = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue(workQueueSize), new ThreadPoolExceptionHandler());
}
return exec;
}
}

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class DataHandlerThreadPool {
    //核心线程数量，即初始化线程池的启动线程数量
    private static final int corePoolSize = 10;
    //最大线程数量
    private static final int maximumPoolSize = 20;
    //线程的存活时间，即完成任务后多久可再使用
    private static final int keepAliveTime = 300;
    //等待队列的长度
    private static final int workQueueSize = 30;
    private static ThreadPoolExecutor exec = null;

    public static ThreadPoolExecutor getDHThreadPool() {
        if (exec == null) {
            //ThreadPoolExceptionHandler表示当线程池处理不了规定任务时的异常处理方式。
            exec = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.MILLISECONDS,
                    new LinkedBlockingQueue(workQueueSize), new ThreadPoolExceptionHandler());
        }
        return exec;
    }

}

线程池异常处理类：

Java代码

import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
public class ThreadPoolExceptionHandler implements RejectedExecutionHandler {
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
System.out.println("线程池出现异常！");
}
}

import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;

public class ThreadPoolExceptionHandler implements RejectedExecutionHandler {

    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {

        System.out.println("线程池出现异常！");

    }

}

任务实例，只需要实现Runnable接口就行

Java代码

public class ThreadPoolTask implements Runnable {
public void run() {
System.out.println("在这里执行业务逻辑和要执行的方法");
}
}

public class ThreadPoolTask implements Runnable {

    public void run() {
        System.out.println("在这里执行业务逻辑和要执行的方法");
    }

}

执行测试类：

Java代码

import java.util.concurrent.ThreadPoolExecutor;
public class TestMain {
/**
* @param args
*/
public static void main(String[] args) {
ThreadPoolExecutor executor = DataHandlerThreadPool.getDHThreadPool();
//适当控制i的循环次数，可以看到打印出的信息，有的是执行业务逻辑，有的是在线程异常处理类里
for (int i = 0; i < 100; i++) {
executor.execute(new ThreadPoolTask());
}
}
}

import java.util.concurrent.ThreadPoolExecutor;

public class TestMain {

    /**
     * @param args
     */
    public static void main(String[] args) {
        ThreadPoolExecutor executor = DataHandlerThreadPool.getDHThreadPool();
        //适当控制i的循环次数，可以看到打印出的信息，有的是执行业务逻辑，有的是在线程异常处理类里
        for (int i = 0; i < 100; i++) {
            executor.execute(new ThreadPoolTask());
        }
    }
}

exec = new ThreadPoolExecutor(corePoolSize, maximumPoolSize,
keepAliveTime, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue(workQueueSize),
new ThreadPoolExceptionHandler());

实例化线程池的方法，在倒数第二个参数 new LinkedBlockingQueue(workQueueSize)可以设置等待队列的形式，有无限队列，有规定队列，有固定的数组等等。

分享到：

Sybase字符集的修改 | Tomcat的增加虚拟内存

2011-03-18 17:33
浏览 1182
评论(0)
分类:企业架构
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

JDK自带线程池学习

评论

发表评论

相关推荐

最近访客 更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

JDK自带线程池学习

评论

发表评论

相关推荐

Jav解析soap的xml

Json转换利器Gson

asm jar包冲突的问题和解决方法(转)

Spring ehCache 示例

将json字符串转换为bean (json-lib)

QPID学习

短网址的原理和实现

JAVA实现栈(stack)与堆(heap)

Tomcat7.0下实现的websocket 代码

java IO写入文件效率——几种方法比较

Apache自带压力测试工具AB的使用方法

MyEclipse6.01注册码,Java源码

ant解决OutOfMemoryError 或者Error starting modern compiler

多线程的同步处理(待续)

在Web中部署定时器或者过滤器(待续)

JAVA线程的几种写法(待续)

JDK1.6中自带的线程池(待续)

Java中使用Json 用到的jar包

JsonUtils 类，将任意数据格式转换为Json格式

Java生成二维码或一维条形码(待续 未完)

最近访客更多访客>>

Java生成二维码或一维条形码(待续未完)