多线程的环境中,尽量采用线程池
2009-04-21 20:11
204 查看
我个人比较喜欢线程,因为线程可以同时并发处理多个请求,于是乎我在编写线程的总是以如下方式启动:
没有错吗,是不是很爽,如果有多少个请求,就产生多少个线程,请像在门口待客的接待员一样,让每个客人都马上得到处理,程序绝对正确,你不信到其它地方搜索一下,启动和调用都是正确的。
可是这样的编写方式,绝对只适合小量访问的环境中,并且要保证不会有大量的并发发生才可以勉强这样写,我做过试验,如果是50个并发,还勉强可以接受,如果有1000个,也许就要丢掉一大半了,我做过如下试验:
并发50,循环100次,就有一大群线程,因为缺少资源等等原因活不过来,偶尔能够全部活过来(在金融系统中千万不能够有这样的问题,少一个0就值多少钱,我一辈子的工资都不够)。
要保证全部存活,就要让多出来的线程等等,有资源的时候也处理,没有资源就在外面吹吹风吗,宁愿慢,不可以乱吗。这个时候就必须要用到线程池了,线程池是个什么样的概念,我这里简而言之,具体的请上网去查相关的概念。
线程池,就是在调用线程的时候初使化一定数量的线程,有线程过来的时候,先检测初使化的线程还有空的没有,没有就再看当前运行中的线程数是不是已经达到了最大数,如果没有,就新分配一个线程去处理,就像餐馆中吃饭一样,从里面叫一个服务员出来;但如果已经达到了最大数,就相当于服务员已经用于了,那没得办法,另外的线程就只有等了,直到有新的“服务员”为止。线程池的优点就是可以管理线程,有一个高度中枢,这样程序才不会乱,保证系统不会因为大量的并发而因为资源不足挂掉。这个时候既然知道了线程池的优点,那么我们启动线程的时候就要换一种方式了:
可以看出这里的启动和上面没有多大的差别,这样写还更简洁,只是需要初使化一些必须的参数而已。
参考文章:http://blog.sina.com.cn/s/blog_568c94a301000ebj.html
本文出自:冯立彬的博客
... while(true){ server.clientSocket=server.serverSocket.accept(); if(server.clientSocket!=null) { Thread thread=new Thread(new MsgListener(server.clientSocket)); thread.start(); } } ...
没有错吗,是不是很爽,如果有多少个请求,就产生多少个线程,请像在门口待客的接待员一样,让每个客人都马上得到处理,程序绝对正确,你不信到其它地方搜索一下,启动和调用都是正确的。
可是这样的编写方式,绝对只适合小量访问的环境中,并且要保证不会有大量的并发发生才可以勉强这样写,我做过试验,如果是50个并发,还勉强可以接受,如果有1000个,也许就要丢掉一大半了,我做过如下试验:
public static void main(String[] args) { // TODO Auto-generated method stub BatClient b=new BatClient(); String transq=""; int index=0; int times=100; for(int j=0;j<times;j++){ for(int i=0;i<50;i++){ transq=String.valueOf(index); transq=b.getZeroString(transq.length())+transq; Thread thread=new Thread(new Client(transq)); thread.start(); index++; } try { Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
并发50,循环100次,就有一大群线程,因为缺少资源等等原因活不过来,偶尔能够全部活过来(在金融系统中千万不能够有这样的问题,少一个0就值多少钱,我一辈子的工资都不够)。
要保证全部存活,就要让多出来的线程等等,有资源的时候也处理,没有资源就在外面吹吹风吗,宁愿慢,不可以乱吗。这个时候就必须要用到线程池了,线程池是个什么样的概念,我这里简而言之,具体的请上网去查相关的概念。
线程池,就是在调用线程的时候初使化一定数量的线程,有线程过来的时候,先检测初使化的线程还有空的没有,没有就再看当前运行中的线程数是不是已经达到了最大数,如果没有,就新分配一个线程去处理,就像餐馆中吃饭一样,从里面叫一个服务员出来;但如果已经达到了最大数,就相当于服务员已经用于了,那没得办法,另外的线程就只有等了,直到有新的“服务员”为止。线程池的优点就是可以管理线程,有一个高度中枢,这样程序才不会乱,保证系统不会因为大量的并发而因为资源不足挂掉。这个时候既然知道了线程池的优点,那么我们启动线程的时候就要换一种方式了:
//初使化线程池,这是JDK5.0中自带的线程池,这里的参数依次代表: //核心线程数(最小活动线程数) //最大线程数及并发数【这个要注意,如果你的实际发大于该数,则有些请求这个时候虽然被接收,但是去得不到处理,这个数据一定得根据实际情况而设定,如我这里设值为20,实际模拟并发50,如循环一次,或者是二次并发,总会有20个不能够处理,如果设为25,就有15得不到处理,如果设为50则全部可以被处理,这个可以折磨了我好几天】 //线程池维护线程所允许的空闲时间 //线程池维护线程所允许的空闲时间的单位 //线程池所使用的缓冲队列 //线程池对拒绝任务的处理策略(通常是抛出异常) ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 100, 10,TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10), new ThreadPoolExecutor.DiscardOldestPolicy()); while(true){ //侦听 server.clientSocket=server.serverSocket.accept(); if(server.clientSocket!=null) { //采用线程池启动线程 threadPool.execute(new MsgListener(server.clientSocket)); } }
可以看出这里的启动和上面没有多大的差别,这样写还更简洁,只是需要初使化一些必须的参数而已。
参考文章:http://blog.sina.com.cn/s/blog_568c94a301000ebj.html
本文出自:冯立彬的博客
相关文章推荐
- 【使用线程池的好处】多线程的环境中,尽量采用线程池
- 【使用线程池的好处】多线程的环境中,尽量采用线程池
- 【使用线程池的好处】多线程的环境中,尽量采用线程池
- 【使用线程池的好处】多线程的环境中,尽量采用线程池
- 多线程的环境中,尽量采用线程池
- 【使用线程池的好处】多线程的环境中,尽量采用线程池
- 采用线程池实现多线程一:没有返回值
- java 网络编程(2.2)-----------采用线程池多线程的Socket 通信
- java 网络编程(2.3)-----------采用线程池多线程的Socket 通信
- java 网络编程(2.4)-----------采用线程池多线程的Socket 通信
- unix环境IPC通信之socket(三),tcp采用并发服务器编程实例,多进程方式 4000
- vs2013中配置多线程的使用环境
- Qt中采用多线程实现Socket编程
- c#多线程线程池快速入门
- (四) Java多线程详解之四种不同线程池使用详解
- 通过线程池使用多线程并发:ThreadPoolTaskExecutor 的应用例子
- java多线程(四)-自定义线程池
- VC8下多线程环境中AfxGetMainWnd()返回空指针问题及解决方法
- 【转】java&android线程池-Executor框架之ThreadPoolExcutor&ScheduledThreadPoolExecutor浅析(多线程编程之三)
- 多线程:线程池