`

并发编程之-Excutor框架

阅读更多

1.Excutor框架出现的背景

在正常负载情况下,服务器应用程序应该兼具良好的吞吐量和快速的响应性。同时在过载时应平缓的劣化,而不应该负载一高就简单地以失败告终。为了达到这个目的,你要选择一个清晰的任务边界,并配合一个明确的任务执行策略。

 

1.1顺序化执行任务

看下面的例子:

class SingleThreadWebServer{

    public static void main(String[] args){

        ServerSocket socket = new ServerSocket(80);

        while(true)

            Socket connection = socket.accept();

            handleRequest(connection);

        }

    }

}

 

上面的例子是实现了一个单线程化的Web Server,缺点很明显:只有当主线程处理完当前请求,才能继续接收其他请求。同时单线程化在等待I/O操作时,cpu基本处于闲置状态,因此导致了资源利用率非常低。

 

顺序化处理几乎不能为服务器应用程序提供良好的吞吐量和快速的用户响应,而且没有任何并发性而言。

 

1.2 显式为任务创建线程

class ThreadPerTaskWebServer{

    public static void main(String[] args){

        ServerSocket socket = new ServerSocket(80);

        while(true)

            final Socket connection = socket.accept();

 

            Runnable task = new Runnable(){

                public void run(){

                    handleRequest(connection);

                }

            }

            new Thread(task).start();

        }

    }

}

 

上面的例子为每个socket分配了一个线程,这样主线程可以不断接受连接请求,从而提高响应性和并发性。在中等强度的负载水平下,每线程没任务方法对顺序化执行进行了良好的改进。只要请求的到达速度尚未打到服务器的处理能力,那么这种方法可以同时带来更快的响应性和更大的吞吐量。

 

1.3无限制创建线程的缺点:

 

1.线程生命周期的开销:线程的创建和销毁不是免费的,创建线程需要时间,会带来请求的延时,如果请求是大量而且频繁的,每线程每任务会消耗大量的计算资源。

2.内存消耗和cpu消耗:一个线程需要一定的内存,而且会给gc带来压力,同时大量线程会竞争cpu资源,还能产生其他的性能开销。

3.稳定性:每个线程会为栈分配一定的内存,如果打破了操作系统的限制,会收到一个OutOfMemory异常。

 

2.Excutor框架

无限制线程,有很多缺陷,而有界的线程可以防止资源过载而耗尽内存。作为Excutor的一部分,java.util.concurrent包提供了一个灵活的线程池实现。在java类库中,任务执行的首要抽象不是Thread,而是Excutor:

 

public interface Executor{

    void execute(Runnable command);

}

 

package executor;

import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;

/**
 *
 *<p>Test</p>
 *<p>Description:</P>
 *<p>Company:Cisco CAS</p>
 *<p>Department:CAS</p>
 *@Author: Tommy Zhou
 *@Since: 1.0
 *@Version:Date:2011-5-7
 *
 **/

public class ExecutorTest {
   
    public static void main(String[] args) {
        /**
         * Creates a thread pool that reuses a fixed number
         * of threads operating off a shared unbounded queue.
         * At any point, at most nThreads threads will be
         * active processing tasks. If additional tasks
         * are submitted when all threads are active,
         * they will wait in the queue until a thread is
         * available.
         * If any thread terminates due to a failure during execution prior
         * to shutdown, a new one will take its place if needed to
         * execute subsequent tasks. The threads in the pool will exist
         * until it is explicitly shutdown.
         *创建一个固定大小的线程池,如果当前线程数目已经超过线程池尺寸大小,
         *当此时有新的请求任务,将被放置在队列里面等待,直到线程池有闲置线程为止。
         *如果在线程执行过程中,遇到未知异常而终止,将补充一个新的线程

         */
        Executor exec = Executors.newFixedThreadPool(20);
       
        /**
         * 创建一个可缓存的非固定大小的线程池,当有新的请求时,
         * 如果池中有闲置的线程,而重用已有的闲置线程,如果没有
         * 则新创建一个,线程的数量没有上限。并且那些没有在60秒之内使用的
         * 线程会被终止并且从cache中移除,因此那些在池中闲置长时间的线程并不会
         * 消耗任何资源。
         * Threads that have not been used
         * for sixty seconds are terminated and removed from the cache. Thus,
         * a pool that remains idle for long enough will not consume any resources.
         *
         *
         */
       
        Executor execCachedPool = Executors.newCachedThreadPool();
        /**
         * 创建一个单线程化的executor,它创建唯一的线程来执行任务,如果这个线程异常结束,会有
         * 另外一个线程代替它
         *
         */
        Executor singleTaskPool = Executors.newSingleThreadExecutor();
       
        /**
         * 创建一个定长的线程池,而且支持定时或者周期性的任务执行
         */
        ScheduledExecutorService  scheduledPool = Executors.newScheduledThreadPool(20);

       
//        exec.equals(obj)
    }

}

分享到:
评论

相关推荐

    Java并发编程实践-电子书

    Java并发编程实践-电子书-01章.pdf Java并发编程实践-电子书-02章.pdf Java并发编程实践-电子书-03章.pdf Java并发编程实践-电子书-04章.pdf Java并发编程实践-电子书-05章.pdf Java并发编程实践-电子书-06章.pdf ...

    62-Java并发编程实战

    62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java...

    Java并发编程---synchronized关键字

    Java并发编程---synchronized关键

    JAVA并发编程实践-中文-高清-带书签-完整版

    并发编程主要通过Java线程API(如Thread类和Runnable接口)、同步工具(如synchronized关键字、wait()和notify()方法、Semaphore、CyclicBarrier、CountDownLatch等)、并发集合(如ConcurrentHashMap、...

    高并发编程资料-java

    高并发编程资料-springboot、高并发 适用于学生及工作后的人员

    Java并发编程实践-电子书-09章.pdf

    Java并发编程实践-电子书-09章.pdf

    Java并发编程实践-电子书1-9章pdf

    《Java并发编程实践》是Java开发者深入理解并发编程的重要参考资料,尤其对于想要提升多线程应用设计和性能优化技能的程序员来说,这本书提供了丰富的实践经验和深入的理论知识。以下是根据提供的章节内容概述的一些...

    Java 并发编程实战-随书源码

    Java提供的并发工具,如线程、同步机制、并发集合以及Executor框架,为开发高效、可靠的并发应用程序提供了强大的支持。以下是一些关键知识点: 1. **线程与进程**:线程是操作系统分配CPU时间的基本单位,而进程则...

    JAVA并发编程核心方法与框架-高洪岩著

    JAVA并发编程核心方法与框架-高洪岩著 java 多并发经典书籍

    go 并发编程实战-郝林

    在Go语言中,并发编程是其核心特性之一,也是实现高性能服务的关键技术。下面将详细讨论这本书中涉及的重要知识点。 1. **Goroutines与Channels**: - Goroutines是Go语言轻量级线程的实现,它们比传统的线程更...

    java并发编程1-9

    java并发编程1-9,可解压,并发编程必看资料。 1 Java 并发编程实践基础 2 构建线程安全应用程序 3 使用JDK 并发包构建程序 4 使用开源软件 Amino 构建并发应用程序 5 数据冲突及诊断工具MTRAT 6 死锁 7 显示锁 ...

    Java并发编程实践--电子书.rar

    并发编程是现代软件开发中的核心技能之一,尤其是在多核处理器普及后,利用多线程进行并发处理已经成为提升程序性能的关键技术。这本书深入浅出地讲解了Java平台上的并发编程原理、工具和最佳实践。 在Java中,线程...

    JAVA并发编程实践-

    根据提供的信息,我们可以推断出该资源主要关注的是“Java并发编程实践”的相关内容,并且它是一本高清晰度的PDF电子书。虽然提供的链接部分似乎只是重复的网站地址,我们仍可以根据标题、描述以及标签来生成相关的...

    阿里专家级并发编程架构师课程 彻底解决JAVA并发编程疑难杂症 JAVA并发编程高级教程

    阿里专家级并发编程架构师级课程,完成课程的学习可以帮助同学们解决非常多的JAVA并发编程疑难杂症,极大的提高JAVA并发编程的效率。课程内容包括了JAVA手写线程池,UC线程池API详解,线程安全根因详解,锁与原子类...

Global site tag (gtag.js) - Google Analytics