java线程池举例讲解

  提问: 6 年 前 最后更新: 4 个月 前 浏览数: 12853
6
5
在CPU和内存还有磁盘IO并没有充分利用的时候,就可以在重构的时候,使用线程操作,将过去需要占用一定时间的同步操作,进行并发处理。这样,创建多个线程来解决同一个问题。这样就可以使操作成为异步,不需要进行等待就可以同时操作很多事情。
那么线程需要创建多少呢?
每监听到一个请求就创建一个线程,然后操作之后就销毁。这种办法可行么?

如果突然在客户端提交了1000000 * N 个请求,这些请求都进入服务器,然后在这里,为每一个请求都创建一个线程来执行。这样程序就会失去控制。最终挤爆服务器CPU和内存,使程序崩溃。

怎么样合理、可控的处理操作,变成了重点。

线程池,顾名思义,在池化开发的现在,如数据库连接池这种开发模式已经广泛流行。
在池中创建连接实例,在访问数据库时,从连接池中取得连接,操作之后归还。这样就可以有效的限制资源数量,但是又能提高操作速度。
package test.dao;

import java.util.LinkedList;

import org.apache.log4j.Logger;


/**
* 
* @author Andy.xiaomeng
*
*/
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);
                }
                
        }
}

提问时间 2011-11-01 14:44

fmms的头像

fmms
0 5 7
答案被采用率: 14.285714285714285%

不错
5 年 前 wangbihua

12 [下一页]

直接使用jdk中的线程池

回答于 2011-11-20 09:23

wilson_lu的头像

wilson_lu
0 0 3
答案被采用率: 0.0%

不错的文章

回答于 2012-05-30 20:57

mrkuangfq的头像

mrkuangfq
0 0 6
答案被采用率: 0.0%

很好

回答于 2013-08-26 21:05

zhangbin_vip的头像

zhangbin_vip
0 0 3
答案被采用率: 0.0%

5656565656565656

回答于 2017-11-22 17:17

糖长老的头像

糖长老
0 0 4
答案被采用率: 0.0%

有用,谢谢

回答于 2017-12-15 20:20

很好地故意的头像

很好地故意
0 0 5
答案被采用率: 0.0%

不错

回答于 2017-12-19 13:06

1376353531的头像

1376353531
0 0 4
答案被采用率: 0.0%

66

回答于 2017-12-19 13:25

1376353531的头像

1376353531
0 0 4
答案被采用率: 0.0%

好文章

回答于 2011-12-13 19:17

jgshdx305的头像

jgshdx305
0 0 6
答案被采用率: 0.0%


回答于 2012-08-18 14:19

zhangyiwen的头像

zhangyiwen
0 0 40
答案被采用率: 0.0%

nice

回答于 2015-06-19 11:36

507815032的头像

507815032
0 0 2
答案被采用率: 0.0%

您的回答:

  

powered by Open-Open.com