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)
	{

	}
}

创建一个固定长度的线程池,既攻克了单线程的堵塞问题。也攻克了无限创建线程带来的内存消耗过多等问题。

4、Executors的API介绍

Java类库提供了很多静态方法来创建一个线程池:

a、newFixedThreadPool 创建一个固定长度的线程池。当到达线程最大数量时,线程池的规模将不再变化。

b、newCachedThreadPool 创建一个可缓存的线程池。假设当前线程池的规模超出了处理需求,将回收空的线程。当需求添加时。会添加线程数量;线程池规模无限制。

c、newSingleThreadPoolExecutor 创建一个单线程的Executor,确保任务对了,串行运行

d、newScheduledThreadPool 创建一个固定长度的线程池。并且以延迟或者定时的方式来运行。相似Timer;后面后单独使用Blog介绍它与Timer差别

小结一下:在线程池中运行任务比为每一个任务分配一个线程优势很多其它,通过重用现有的线程而不是创建新线程,能够在处理多个请求时分摊线程创建和销毁产生的巨大的开销。

当请求到达时,通常工作线程已经存在,提高了响应性。通过配置线程池的大小,能够创建足够多的线程使CPU达到忙碌状态,还能够防止线程太多耗尽计算机的资源。

好了,结束~欢迎大家留言~

    原文作者:zsychanpin
    原文地址: http://www.cnblogs.com/zsychanpin/p/6857955.html
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞