【为什么需要多线程】

本文代码会在后期整理上传到github中

1. 没有使用多线程情况

代码：

package com.tinygao.thread;
import com.google.common.base.Stopwatch;
import com.tinygao.thread.executor.JobExecutionFactory;
import com.tinygao.thread.job.DBJob;
import com.tinygao.thread.job.FileJob;
import com.tinygao.thread.job.Job;
import com.tinygao.thread.job.JobType;
import lombok.extern.slf4j.Slf4j;
import java.net.URI;
import java.util.concurrent.TimeUnit;
@Slf4j
public class ExecutionSingleClient {
    public static void main(String[] args) throws Exception {
        final Stopwatch stopwatch = Stopwatch.createStarted();
        runDBJob();
        runFileJob();
        log.info("total elapse time {}s", stopwatch.elapsed(TimeUnit.SECONDS));
        stopwatch.stop();
    }

    private static void runDBJob() throws Exception {
        //创建一个任务
        Job dbJob = new DBJob("select * from tbl_user");
        //创建一个数据库执行者
        Execution dbExecution = new Execution(
                dbJob,
                JobExecutionFactory.createInstance(JobType.DB_JOB));
        dbExecution.call();
    }

    private static void runFileJob() throws Exception {
        //创建一个任务
        Job fileJob = new FileJob(new URI("file://d:"));
        //创建一个文件执行者
        Execution fileExecution = new Execution(
                fileJob,
                JobExecutionFactory.createInstance(JobType.FILE_JOB));
        fileExecution.call();
    }
}

输出：

2017-01-14 21:34:40.129 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : STARTING， elapse time : 0s
2017-01-14 21:34:40.129 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 0s
2017-01-14 21:34:41.183 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 1s
2017-01-14 21:34:42.184 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 2s
2017-01-14 21:34:43.185 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 3s
2017-01-14 21:34:44.187 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 4s
2017-01-14 21:34:45.189 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 5s
2017-01-14 21:34:46.191 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 6s
2017-01-14 21:34:47.193 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 7s
2017-01-14 21:34:48.194 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 8s
2017-01-14 21:34:49.196 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 9s
2017-01-14 21:34:50.198 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 10s
2017-01-14 21:34:50.198 [main] INFO com.tinygao.thread.job.Job - DB_JOB job status : FINISHED， elapse time : 10s
2017-01-14 21:34:50.198 [main] INFO com.tinygao.thread.job.Job - FILE_JOB job status : STARTING， elapse time : 0s
2017-01-14 21:34:50.198 [main] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 0s
2017-01-14 21:34:51.200 [main] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 0s
2017-01-14 21:34:52.202 [main] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 1s
2017-01-14 21:34:53.204 [main] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 3s
2017-01-14 21:34:54.207 [main] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 4s
2017-01-14 21:34:55.208 [main] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 5s
2017-01-14 21:34:55.208 [main] INFO com.tinygao.thread.job.Job - FILE_JOB job status : FINISHED， elapse time : 5s
2017-01-14 21:34:55.208 [main] INFO com.tinygao.thread.ExecutionSingleClient - total elapse time 15s

2. 使用多线程情况

package com.tinygao.thread;

import com.google.common.base.Stopwatch;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import com.tinygao.thread.Execution;
import com.tinygao.thread.executor.JobExecutionFactory;
import com.tinygao.thread.job.DBJob;
import com.tinygao.thread.job.FileJob;
import com.tinygao.thread.job.Job;
import com.tinygao.thread.job.JobType;
import lombok.extern.slf4j.Slf4j;

import java.net.URI;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;

import static java.util.concurrent.Executors.newFixedThreadPool;

/**
 * Created by gsd on 2017/1/14.
 */
@Slf4j
public class ExecutionMultiClient {

    public static ThreadFactory daemonThreadsNamed(String nameFormat){
        return new ThreadFactoryBuilder().setNameFormat(nameFormat).setDaemon(false).build();
    }

    public static void main(String[] args) throws Exception {
        final Stopwatch stopwatch = Stopwatch.createStarted();

        ExecutorService threads = Executors.newFixedThreadPool(
                    2,
                    daemonThreadsNamed("job-threads-%d"));
        threads.submit(ExecutionMultiClient::runDBJob);
        threads.submit(ExecutionMultiClient::runFileJob);

        threads.shutdown();
        threads.awaitTermination(1, TimeUnit.DAYS);

        log.info("total elapse time {}s", stopwatch.elapsed(TimeUnit.SECONDS));
        stopwatch.stop();
    }

    private static void runDBJob() {
        //创建一个任务
        Job dbJob = new DBJob("select * from tbl_user");
        //创建一个数据库执行者
        Execution dbExecution = new Execution(
                dbJob,
                JobExecutionFactory.createInstance(JobType.DB_JOB));
        try {
            dbExecution.call();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static void runFileJob() {
        //创建一个任务
        try {
        Job fileJob = new FileJob(new URI("file://d:"));
        //创建一个文件执行者
        Execution fileExecution = new Execution(
                fileJob,
                JobExecutionFactory.createInstance(JobType.FILE_JOB));

            fileExecution.call();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

输出：

2017-01-14 21:38:13.384 [job-threads-1] INFO com.tinygao.thread.job.Job - FILE_JOB job status : STARTING， elapse time : 0s
2017-01-14 21:38:13.384 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : STARTING， elapse time : 0s
2017-01-14 21:38:13.391 [job-threads-1] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 0s
2017-01-14 21:38:13.391 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 0s
2017-01-14 21:38:14.404 [job-threads-1] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 1s
2017-01-14 21:38:14.405 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 1s
2017-01-14 21:38:15.426 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 2s
2017-01-14 21:38:15.426 [job-threads-1] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 2s
2017-01-14 21:38:16.427 [job-threads-1] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 3s
2017-01-14 21:38:16.427 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 3s
2017-01-14 21:38:17.428 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 4s
2017-01-14 21:38:17.428 [job-threads-1] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 4s
2017-01-14 21:38:18.429 [job-threads-1] INFO com.tinygao.thread.job.Job - FILE_JOB job status : RUNNING， elapse time : 5s
2017-01-14 21:38:18.429 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 5s
2017-01-14 21:38:18.429 [job-threads-1] INFO com.tinygao.thread.job.Job - FILE_JOB job status : FINISHED， elapse time : 5s
2017-01-14 21:38:19.430 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 6s
2017-01-14 21:38:20.430 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 7s
2017-01-14 21:38:21.432 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 8s
2017-01-14 21:38:22.434 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 9s
2017-01-14 21:38:23.440 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : RUNNING， elapse time : 10s
2017-01-14 21:38:23.440 [job-threads-0] INFO com.tinygao.thread.job.Job - DB_JOB job status : FINISHED， elapse time : 10s
2017-01-14 21:38:23.440 [main] INFO com.tinygao.thread.ExecutionMultiClient - total elapse time 10s

3. 分析

当cpu时间片轮到某一个线程时候，他就会执行它（如果可执行）
同一个应用在多线程和单线程情况下，多线程获取的cpu时间可能较多
从上面的例子可以看出多线程在较短的时间内完成两个任务。吞吐量高。

4. 总结

<b>from 《现代操作系统》p53</b>

许多应用中有多种活动，某些活动随着时间推移会被阻塞。通过将应用程序分解成可并行运行的多个线程来优化。
线程比进程更轻量级，比进程更快创建和撤销。在许多系统中，创建线程较创建进程要快10~100倍。
若多线程都是CPU密集型，性能上无法得以提升。如果存在大量计算和大量的I/O处理，拥有多线程允许这些活动彼此重叠进行，从而加快应用程序的执行速度。

5. 遗留问题

需要讲解阻塞（举例：cpu指令阻塞、应用层面的IO阻塞）

最后编辑于：2017.12.05 06:29:27

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 199,271评论 5赞 466
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 83,725评论 2赞 376
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 146,252评论 0赞 328
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 53,634评论 1赞 270
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 62,549评论 5赞 359
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 47,985评论 1赞 275
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,471评论 3赞 390
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,128评论 0赞 254
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,257评论 1赞 294
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,233评论 2赞 317
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,235评论 1赞 328
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 32,940评论 3赞 316
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,528评论 3赞 302
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,623评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 30,858评论 1赞 255
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 42,245评论 2赞 344
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 41,790评论 2赞 339

【为什么需要多线程】

1. 没有使用多线程情况

2. 使用多线程情况

3. 分析

4. 总结

5. 遗留问题

推荐阅读更多精彩内容