java线程池举例详解
进程是程序的一个动态执行过程，是指一个内存中运行的应用程序，每个进程都有自己独立的一块内存空间，一个进程中可以启动多个线程。比如在Windows系统中，一个运行的exe就是一个进程。线程是指进程中的一个执行流程，一个进程中可以运行多个线程。比如java.exe进程中可以运行很多线程。线程总是属于某个进程，进程中的多个线程共享进程的内存。“同时”执行是人的感觉，在线程之间实际上轮换执行。
实现多线程有两种手段，一种是集成Thread类，另一种就是实现Runnable接口。
?
在CPU和内存还有磁盘IO并没有充分利用的时候，就可以在重构的时候，使用线程操作，将过去需要占用一定时间的同步操作，进行并发处理。这样，创建多个线程来解决同一个问题。这样就可以使操作成为异步，不需要进行等待就可以同时操作很多事情。
那么线程需要创建多少呢？
每监听到一个请求就创建一个线程，然后操作之后就销毁。这种办法可行么？
如果突然在客户端提交了1000000 * N 个请求，这些请求都进入服务器，然后在这里，为每一个请求都创建一个线程来执行。这样程序就会失去控制。最终挤爆服务器CPU和内存，使程序崩溃。
怎么样合理、可控的处理操作，变成了重点。
线程池，顾名思义，在池化开发的现在，如数据库连接池这种开发模式已经广泛流行。
在池中创建连接实例，在访问数据库时，从连接池中取得连接，操作之后归还。这样就可以有效的限制资源数量，但是又能提高操作速度。
package test.dao;
??? ?
??? import java.util.LinkedList;
?
??? import org.apache.log4j.Logger;
??? ???? ?
??? public class ThreadPool {
??? ?
??? ??????? private static final Logger Log = Logger.getLogger(ThreadPool.class);
??? ????????
??? ??????? private ThreadWorker[] worker;
??? ??????? private LinkedList<Runnable> queue;
??? ??????? private int poolSize;
??? ????????
??? ??????? public int getPoolSize(){
??? ??????????????? return poolSize;
??? ??????? }
????????
??? ??????? //initialize thread pool with pool size
??? ??????? public ThreadPool(int size){
??? ????????????????
??? ??????????????? poolSize = size;
??? ??????????????? worker = new ThreadWorker[size];
??? ??????????????? queue = new LinkedList<Runnable>();
??? ????????????????
??? ??????????????? for (int i = 0; i < size; i++) {
??? ??????????????????????? worker[i] = new ThreadWorker();
??? ??????????????????????? worker[i].start();
??? ??????????????? }
??? ????????????????
??? ??????? }
??? ????????
??? ????????
??? ????????
??? ??????? //add work queue
??? ??????? public void addQueue(Runnable runnable){
??? ??????????????? synchronized(queue) {
??? ??????????????????????? queue.add(runnable);
??? ??????????????????????? queue.notify();
??? ??????????????? }
??? ??????? }
??? ????????
??? ??????? //worker do work
??? ??????? private class ThreadWorker extends Thread{
??? ????????????????
??????????????? public void run(){
??? ????????????????????????
??? ??????????????????????? //runnable
??? ??????????????????????? Runnable runable;
??? ????????????????????????
??? ??????????????????????? while (true) {
??? ????????????????????????????????
??? ??????????????????????????????? synchronized(queue) {
??? ??????????????????? while (queue.isEmpty()) {
??? ??????????????????????? try
??? ??????????????????????? {
??? ???????????????????????? //is work queue is empty, wait
???????????????????????????? queue.wait();
??? ??????????????????????? }
??? ??????????????????????? catch (Exception e)
??? ??????????????????????? {
??? ??????????????????????????????? Log.error("pool queue wait", e);
??? ??????????????????????? }
??? ??????????????????? }
??? ????????????????????
??? ??????????????????? //get work in queue, and remove it
??? ??????????????????? runable = queue.removeFirst();
??? ??????????????? }
??? ?
??? ??????????????? try {
??? ??????????????????????? //do work
??? ??????????????????????? runable.run();
??? ??????????????? }
??? ??????????????? catch (RuntimeException e) {
??? ??????????????????????? Log.error("unknow runtime exception", e);
??? ??????????????? }
??? ????????????????????????????????
??? ??????????????????????? }
??? ??????????????? }
??? ???????????????? ??? ??????? }
??? ????????
??? ??????? public static void main(String[] args) {
????????????????
??? ??????????????? //test
??? ??????????????? ThreadPool pool = new ThreadPool(111);
??? ????????????????
??? ????????????????
??? ??????????????? //
??? ??????????????? class SSS implements Runnable{
??? ??????????????????????? private String abc;
??????????????????????? public void setAbc(String aaaaa){
??? ??????????????????????????????? this.abc = aaaaa;
??? ??????????????????????? }
??? ????????????????????????
??? ??????????????????????? public void run() {
??? ??????????????????????????????? System.out.println("do runnable " + abc);
??? ??????????????????????? }
??? ??????????????? }??? ????????????????
??? ??????????????? for (int i = 0; i < 200; i++) {
??? ??????????????????????? SSS a = new SSS();
??? ??????????????????????? a.setAbc(String.valueOf(i + 1));
??? ??????????????????????? pool.addQueue(a);
??? ??????????????? }
??? ????????????????
??? ??????? }
??? }