Java并发之Executor

  • 引入Executor
  • 创建Executor
  • 创建固定大小的线程Executor

引入Executor

我们在开发Java多线程程序的时候，往往会创建很多个Runnable对象，然后创建对应的Thread对象来执行它们。但是，如果需要开发一个大量的并发任务，过多的任务就会导致下面这些问题：

  • 必须给每个Runnable对象创建一个Thread，也就意味着要创建相关的线程创建，结束，取结果的代码，代码很冗余
  • 过多的Thread对象对于降低了应用程序的效率，系统负荷过重

从Java 5之后，引入了一套API框架用来解决这个问题。这套新的框架就是执行器框架（Executor Framework）,围绕着Executor接口和它的自接口的ExecutorService，以及实现这两个接口的ThreadPoolExecutor类。

部分继承关系：

image.png

这套框架分离了任务的创建和执行。使用Executor，只要将Runnable对象，直接丢给执行器就可以了。Executor会自己创建线程，来负责这些Runnable对象任务的执行。Executor有一个好处就是利用线程池提高性能，当收到一个新任务时，会尝试使用线程池中的空闲线程来执行，避免了重复创建过多的线程而导致系统性能的下降。

创建Executor

使用Executor的第一步就是创建一个线程池对象，java提供了Executors的工厂类，可以帮我们创建不同的线程池对象

image.png

然后调用Executor的execute方法执行相应的线程，并且要显示的结束线程池
server类：

package CreateExecutor;

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;

public class Server {
    private ThreadPoolExecutor executor;

    public Server() {
        executor = (ThreadPoolExecutor)Executors.newCachedThreadPool();
    }
    
    public void executorTask(Task task) {
        System.out.println("a new task arrived");
        executor.execute(task);
        System.out.println("Server : Pool Size :" + executor.getPoolSize());
        System.out.println("Server : ActiveCount :" + executor.getActiveCount());
        System.out.println("Server : CompletedTaskCount :" + executor.getCompletedTaskCount());
        System.out.println();
    }
    
    public void endServer() {
        executor.shutdown();
    }
}

Task类用来创建多个runnable对象

package CreateExecutor;

import java.util.Date;
import java.util.concurrent.TimeUnit;

public class Task implements Runnable {

    private Date initDate;
    
    private String name;
    
    
    
    public Task(Date initDate, String name) {
        super();
        this.initDate = initDate;
        this.name = name;
    }



    @Override
    public void run() {
        
        System.out.printf("%s : Task %s : Created on : %s\n",
                Thread.currentThread().getName(),name,initDate);
        System.out.printf("%s : Task %s : Started on : %s\n",
                Thread.currentThread().getName(),name, new Date());
        
        //将任务休眠一段时间，模拟任务的执行
        try {
        Long duration = (long)(Math.random() * 10);
        System.out.printf("%s : Task %s : Doing a task during %d seconds\n",
                Thread.currentThread().getName(), name, duration);
        
        TimeUnit.SECONDS.sleep(duration);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        
        System.out.printf("%s : Task %s : Finished on : %s\n",
                Thread.currentThread().getName(), name, new Date());
    }
}

Main类测试：

package CreateExecutor;

import java.util.Date;

public class Main {

    public static void main(String[] args) {
        Server server = new Server();
        for(int i=0;i<10;i++) {
            Task task = new Task(new Date(), "Task " + i);
            server.executorTask(task);
        }
        server.endServer();
    }

}

运行结果

a new task arrived
Server : Pool Size :1
pool-1-thread-1 : Task Task 0 : Created on : Mon Jul 24 20:31:10 CST 2017
pool-1-thread-1 : Task Task 0 : Started on : Mon Jul 24 20:31:11 CST 2017
Server : ActiveCount :1
Server : CompletedTaskCount :0

a new task arrived
Server : Pool Size :2
Server : ActiveCount :2
Server : CompletedTaskCount :0

a new task arrived
Server : Pool Size :3
Server : ActiveCount :3
Server : CompletedTaskCount :0

a new task arrived
Server : Pool Size :4
Server : ActiveCount :4
Server : CompletedTaskCount :0

a new task arrived
Server : Pool Size :5
Server : ActiveCount :5
Server : CompletedTaskCount :0

pool-1-thread-2 : Task Task 1 : Created on : Mon Jul 24 20:31:11 CST 2017
pool-1-thread-2 : Task Task 1 : Started on : Mon Jul 24 20:31:11 CST 2017
pool-1-thread-5 : Task Task 4 : Created on : Mon Jul 24 20:31:11 CST 2017
pool-1-thread-4 : Task Task 3 : Created on : Mon Jul 24 20:31:11 CST 2017
pool-1-thread-3 : Task Task 2 : Created on : Mon Jul 24 20:31:11 CST 2017
pool-1-thread-1 : Task Task 0 : Doing a task during 3 seconds
pool-1-thread-3 : Task Task 2 : Started on : Mon Jul 24 20:31:11 CST 2017
pool-1-thread-3 : Task Task 2 : Doing a task during 8 seconds
pool-1-thread-4 : Task Task 3 : Started on : Mon Jul 24 20:31:11 CST 2017
pool-1-thread-4 : Task Task 3 : Doing a task during 7 seconds
pool-1-thread-5 : Task Task 4 : Started on : Mon Jul 24 20:31:11 CST 2017
pool-1-thread-2 : Task Task 1 : Doing a task during 9 seconds
pool-1-thread-5 : Task Task 4 : Doing a task during 1 seconds
pool-1-thread-5 : Task Task 4 : Finished on : Mon Jul 24 20:31:12 CST 2017
pool-1-thread-1 : Task Task 0 : Finished on : Mon Jul 24 20:31:14 CST 2017
pool-1-thread-4 : Task Task 3 : Finished on : Mon Jul 24 20:31:18 CST 2017
pool-1-thread-3 : Task Task 2 : Finished on : Mon Jul 24 20:31:19 CST 2017
pool-1-thread-2 : Task Task 1 : Finished on : Mon Jul 24 20:31:20 CST 2017

Executor的一个特性，必须通过显示的结束，如果不这么做，Executor会继续执行，线程也不会结束，程序也不会结束。如果Executor没有任务可执行了，它不会结束，会一直等待新的任务到来，而不会结束执行。

创建固定大小的线程Executor

上面的例子，对五个任务新生成了5个线程，为了重复利用线程，我们可以创建固定的线程数，Executors工厂类就提供了这么一个工厂方法。
这个Executor会有一个最大的线程最大数，如果发送超过这个任务数的任务给Executor，执行器不会再创建额外的线程，剩下的任务将被阻塞直到Executor有足够的空闲的线程可用。

package CreateFixedExecutor;

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;

public class Server {
    private ThreadPoolExecutor executor;

    public Server() {
        executor = (ThreadPoolExecutor)Executors.newFixedThreadPool(5);
    }
    
    public void executorTask(Task task) {
        System.out.println("a new task arrived\n");
        executor.execute(task);
        System.out.println("Server : Pool Size :" + executor.getPoolSize());
        System.out.println("Server : ActiveCount :" + executor.getActiveCount());
        System.out.println("Server : TaskCount :" + executor.getTaskCount());
        System.out.println("Server : CompletedTaskCount :" + executor.getCompletedTaskCount());
    }
    
    public void endServer() {
        executor.shutdown();
    }
}


package CreateFixedExecutor;

import java.util.Date;
import java.util.concurrent.TimeUnit;

public class Task implements Runnable {

    private Date initDate;
    
    private String name;
    
    
    
    public Task(Date initDate, String name) {
        super();
        this.initDate = initDate;
        this.name = name;
    }



    @Override
    public void run() {
        
        System.out.printf("%s : Task %s : Created on : %s\n",
                Thread.currentThread().getName(),name,initDate);
        System.out.printf("%s : Task %s : Started on : %s\n",
                Thread.currentThread().getName(),name, new Date());
        
        //将任务休眠一段时间，模拟任务的执行
        try {
        Long duration = (long)(Math.random() * 10);
        System.out.printf("%s : Task %s : Doing a task during %d seconds\n",
                Thread.currentThread().getName(), name, duration);
        
        TimeUnit.SECONDS.sleep(duration);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        
        System.out.printf("%s : Task %s : Finished on : %s\n",
                Thread.currentThread().getName(), name, new Date());
    }
}


package CreateFixedExecutor;

import java.util.Date;

public class Main {

    public static void main(String[] args) {
        Server server = new Server();
        for(int i=0;i<10;i++) {
            Task task = new Task(new Date(), "Task " + i);
            server.executorTask(task);
        }
        server.endServer();
    }

}

运行结果：

a new task arrived

Server : Pool Size :1
pool-1-thread-1 : Task Task 0 : Created on : Mon Jul 24 20:40:07 CST 2017
Server : ActiveCount :1
Server : TaskCount :1
Server : CompletedTaskCount :0
a new task arrived

pool-1-thread-1 : Task Task 0 : Started on : Mon Jul 24 20:40:07 CST 2017
Server : Pool Size :2
Server : ActiveCount :2
Server : TaskCount :2
Server : CompletedTaskCount :0
a new task arrived

Server : Pool Size :3
Server : ActiveCount :3
Server : TaskCount :3
Server : CompletedTaskCount :0
a new task arrived

Server : Pool Size :4
Server : ActiveCount :4
Server : TaskCount :4
Server : CompletedTaskCount :0
a new task arrived

Server : Pool Size :5
Server : ActiveCount :5
Server : TaskCount :5
Server : CompletedTaskCount :0
a new task arrived

Server : Pool Size :5
Server : ActiveCount :5
Server : TaskCount :6
Server : CompletedTaskCount :0
a new task arrived

Server : Pool Size :5
pool-1-thread-2 : Task Task 1 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-2 : Task Task 1 : Started on : Mon Jul 24 20:40:07 CST 2017
Server : ActiveCount :5
pool-1-thread-2 : Task Task 1 : Doing a task during 7 seconds
pool-1-thread-4 : Task Task 3 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-4 : Task Task 3 : Started on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-1 : Task Task 0 : Doing a task during 9 seconds
pool-1-thread-3 : Task Task 2 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-3 : Task Task 2 : Started on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-4 : Task Task 3 : Doing a task during 2 seconds
pool-1-thread-5 : Task Task 4 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-5 : Task Task 4 : Started on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-5 : Task Task 4 : Doing a task during 5 seconds
Server : TaskCount :7
pool-1-thread-3 : Task Task 2 : Doing a task during 4 seconds
Server : CompletedTaskCount :0
a new task arrived

Server : Pool Size :5
Server : ActiveCount :5
Server : TaskCount :8
Server : CompletedTaskCount :0
a new task arrived

Server : Pool Size :5
Server : ActiveCount :5
Server : TaskCount :9
Server : CompletedTaskCount :0
a new task arrived

Server : Pool Size :5
Server : ActiveCount :5
Server : TaskCount :10
Server : CompletedTaskCount :0
pool-1-thread-4 : Task Task 3 : Finished on : Mon Jul 24 20:40:09 CST 2017
pool-1-thread-4 : Task Task 5 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-4 : Task Task 5 : Started on : Mon Jul 24 20:40:09 CST 2017
pool-1-thread-4 : Task Task 5 : Doing a task during 4 seconds
pool-1-thread-3 : Task Task 2 : Finished on : Mon Jul 24 20:40:11 CST 2017
pool-1-thread-3 : Task Task 6 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-3 : Task Task 6 : Started on : Mon Jul 24 20:40:11 CST 2017
pool-1-thread-3 : Task Task 6 : Doing a task during 4 seconds
pool-1-thread-5 : Task Task 4 : Finished on : Mon Jul 24 20:40:12 CST 2017
pool-1-thread-5 : Task Task 7 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-5 : Task Task 7 : Started on : Mon Jul 24 20:40:12 CST 2017
pool-1-thread-5 : Task Task 7 : Doing a task during 1 seconds
pool-1-thread-5 : Task Task 7 : Finished on : Mon Jul 24 20:40:13 CST 2017
pool-1-thread-5 : Task Task 8 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-5 : Task Task 8 : Started on : Mon Jul 24 20:40:13 CST 2017
pool-1-thread-5 : Task Task 8 : Doing a task during 4 seconds
pool-1-thread-4 : Task Task 5 : Finished on : Mon Jul 24 20:40:13 CST 2017
pool-1-thread-4 : Task Task 9 : Created on : Mon Jul 24 20:40:07 CST 2017
pool-1-thread-4 : Task Task 9 : Started on : Mon Jul 24 20:40:13 CST 2017
pool-1-thread-4 : Task Task 9 : Doing a task during 9 seconds
pool-1-thread-2 : Task Task 1 : Finished on : Mon Jul 24 20:40:14 CST 2017
pool-1-thread-3 : Task Task 6 : Finished on : Mon Jul 24 20:40:15 CST 2017
pool-1-thread-1 : Task Task 0 : Finished on : Mon Jul 24 20:40:16 CST 2017
pool-1-thread-5 : Task Task 8 : Finished on : Mon Jul 24 20:40:17 CST 2017
pool-1-thread-4 : Task Task 9 : Finished on : Mon Jul 24 20:40:22 CST 2017
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 206,723评论 6赞 481
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 88,485评论 2赞 382
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 152,998评论 0赞 344
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 55,323评论 1赞 279
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 64,355评论 5赞 374
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 49,079评论 1赞 285
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,389评论 3赞 400
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,019评论 0赞 259
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 43,519评论 1赞 300
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,971评论 2赞 325
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,100评论 1赞 333
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,738评论 4赞 324
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,293评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,289评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,517评论 1赞 262
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,547评论 2赞 354
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,834评论 2赞 345

推荐阅读更多精彩内容

  • JAVA并发
    一.线程安全性 线程安全是建立在对于对象状态访问操作进行管理，特别是对共享的与可变的状态的访问 解释下上面的话： ...
    黄大大吃不胖阅读 828评论 0赞 3
  • Java 并发入门
    一、并发 进程：每个进程都拥有自己的一套变量 线程：线程之间共享数据 1.线程 Java中为多线程任务提供了很多的...
    SeanMa阅读 2,405评论 0赞 11
  • Java线程面试题
    下面是我自己收集整理的Java线程相关的面试题，可以用它来好好准备面试。 参考文档：-《Java核心技术 卷一》-...
    阿呆变Geek阅读 14,738评论 14赞 507
  • 晚霞1
    马来西亚中霹雳 晚霞虽然总是在日落以后 但也意味着 黎明即将来临 希望就在前头 正面思考 让自己过得自在些
    小木路过阅读 241评论 0赞 1
  • 命中注定难达心愿的誉王，我突然开始同情他了|总看《琅琊榜》系列（2）
    不得不说，琅琊榜是这么多年看的所有剧里，难得“听了”这么多遍还没太腻的高分剧。 誉王还是太子，戏外的观众，清楚的知...
    青霜叒橙阅读 604评论 0赞 2