Java 并发专题： Executor具体介绍打造基于Executor的Webserver

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

转载标明出处：http://blog.csdn.net/lmj623565791/article/details/26938985

继续并发，貌似并发的文章非常少有人看啊~哈~

今天准备具体介绍java并发包下的Executor，以及Java提供了非常多灵活的且极其方便的线程池的创建。

嗯。那就慢慢说，大家肯定都学过Socket，JavaSe的时候写聊天程序，游戏的server。以及Android程序自己须要提供server的。都会拿Socket来自己写个：

最初我们的server可能写成这样：

1、单线程server

package com.zhy.concurrency.executors;import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;/**
* 单线程Webserver
*
* @author zhy
*
*/
public class SingleThreadWebServer
{public static void main(String[] args) throws IOException
{ServerSocket server = new ServerSocket(7711);
while (true)
{
Socket client = server.accept();
handleReq(client);
}}/**
* 处理请求
* @param client
*/
private static void handleReq(Socket client)
{
}}

这种server代码非常easy，理论上也是正确的，可是在实现的环境中却非常糟糕，由于它每次仅仅能处理一个请求。假设每一个请求的耗时过长，后面的请求会长时间等待或者超时错误。

于是乎，出现了以下这种写法：

2、每一个请求分配一个线程的server

package com.zhy.concurrency.executors;import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 为每一个请求分配一个线程
* @author zhy
*
*/
public class TaskPreThreadServer
{
public static void main(String[] args) throws IOException
{
ServerSocket server = new ServerSocket(8811);
while (true)
{
final Socket client = server.accept();
new Thread()
{
public void run()
{
handleReq(client);
};
}.start();
}
}protected static void handleReq(Socket client)
{}
}

为每一个请求开辟一个线程，首先我得承认我也经经常使用这种写法~可是我们还是要吐槽下这样写法的不足：

a、线程的生命周期的开销还是相当高的，大量的线程的创建将消耗大量的计算机资源

b、可创建线程的数量存在一个限制值（这个值由平台认为，且受非常多因素的制约），假设超过这个限制，可能会报OOM错误

c、在一定范围内。添加线程能够提高系统吞吐量，可是超过了这个范围。就物极必反了，仅仅会减少程序的运行速度。

所以我们要继续改进我们的server代码，Executor提供了非常方便的方式：

3、基于Executor的server

package com.zhy.concurrency.executors;import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;/**
* 基于Executor的server
* @author zhy
*
*/
public class TaskExecutionServer
{
private static final int THREAD_COUNT = 100;
private static final Executor exec = Executors
.newFixedThreadPool(THREAD_COUNT);public static void main(String[] args) throws IOException
{
ServerSocket server = new ServerSocket(9911);
while (true)
{
final Socket client = server.accept();
Runnable task = new Runnable()
{
@Override
public void run()
{
handleReq(client);
}
};
exec.execute(task);
}}protected static void handleReq(Socket client)
{}
}