黑马程序员技术交流社区

标题: 11/21日day07-线程间通信-线程池-Lambda表达式 [打印本页]

作者: 849618121    时间: 2018-11-26 14:51
标题: 11/21日day07-线程间通信-线程池-Lambda表达式
本帖最后由 849618121 于 2018-11-26 15:04 编辑

day07 线程间通信 线程池 Lambda表达式 今日内容
多线程
        线程间通信 (等待唤醒案例)
        线程池
函数式编程
        Lambda表达式
                标准格式
                省略格式 线程间通信
线程间通信介绍知识点:
为什么要进行线程间通信
进行线程间通信要使用什么技术
总结:
线程间通信:
        多个线程在处理同一个资源, 但是多个线程的处理动作却不相同(线程的任务不同, 需要协调合作)为什么要进行线程间通信:
        通常是竞争关系: 多个线程并发执行时, 在默认情况下CPU是随机切换线程的.
        有时也"需要合作": 当我们需要多个线程来共同完成一件任务, 并且我们希望他们有规律的执行, 那么多线程之间需要一些协调通信, 以此来帮我们达到多线程共同操作一份数据如何实现线程间通信:
        "等待唤醒机制"
补充: 等待唤醒机制介绍
知识点:
什么是等待唤醒机制
了解 wait/notify 的执行流程
总结:
等待唤醒机制:
        wait/notify, 就是"线程间的一种协作机制", 用于实现线程间通信
等待唤醒中的方法
java.lang.Object类:
        // 成员方法 (只能通过"锁对象"调用)
        void notify(): 随机唤醒在同一个锁对象上的某一个处于等待状态的线程
        void notifyAll(): 唤醒所有在同一个锁对象上处于等待状态的线程
        void wait(): 让当前线程处于无限等待状态, 同时释放锁
        wait和notify/notifyAll的执行原理:
        wait:
                线程不再活动, 不再参与调度, 进入 wait set 中, 因此不会浪费 CPU 资源, 也不会去竞争锁, 这时的线程状态即是"WAITING". 它还要等着别的线程执行"通知(notify)", 让在锁对象上等待的线程从 wait set 中释放出来, 重新进入到调度队列(ready queue)中
        notify/notifyAll:
                哪怕只通知了一个等待的线程, 被通知线程也不能立即恢复执行, 因为它当初中断的地方是在同步块内, 而
此刻它已经不持有锁, 所以它需要"再次尝试去获取锁"(很可能面临其它线程的竞争), 成功后才能在当初调用 wait() 之后的地方恢复执行
                总结如下:
                        如果能获取锁, 线程就从"WAITING"状态变成"RUNNABLE"状态
                        否则, 从 wait set 出来, 又进入entry set, 线程就从"WAITING"状态又变成"BLOCKED"状态
调用 wait() 和 notify() 需要注意的细节:
        1. wait() 与 notify() 必须要由"同一个锁对象"调用
                因为对应的锁对象可以通过 notify() 唤醒使用同一个锁对象调用的 wait() 后的线程
        2. wait() 与 notify() 是属于Object类的方法
                因为锁对象可以是任意对象, 而任意对象的所属类都是继承了Object类的
        3. wait() 与 notify() 必须要在"同步代码块"或者是"同步方法"中使用
                因为必须要通过锁对象调用这2个方法
补充: 等待唤醒机制: 吃包子(需求分析)知识点:
生产者消费者问题: 模拟包子铺卖包子给吃货, 需要哪些类
总结:
资源: 包子类
        属性:
                皮
                馅
                是否有包子: true有, false没有
生产者: 包子铺类, 继承Thread
        任务:
                对包子状态进行判断:
                true: 有包子, 则wait()
                false: 没有包子, 则交替生产不同皮和馅的包子, 修改包子状态为true, 并notify()吃货来吃
消费者: 吃货类, 继承Thread
        任务:
                对包子状态进行判断:
                false: 没有包子, 则wait()
                true: 有包子, 则吃, 修改包子状态为false, 并notify()包子铺生产
测试类:
        创建包子对象(作为共享的锁对象)
        创建包子铺对象, 启动线程
        创建吃货对象, 启动线程![](./img/01_等待与唤醒案例分析.bmp)补充: 等待唤醒机制: 吃包子代码实现(包子类, 包子铺类)
5分钟练习: 定义包子类和包子铺类
需求:
定义包子类: Baozi
        属性: 为了写代码方便不用加private
        皮儿: String pi;
        馅儿: String xian;
        是否有包子: boolean you = false; 默认没有
定义包子铺类: BaoziPu, 继承Thread类
        属性: 为了写代码方便不用加private
                Baozi baozi;
        有参构造: public BaoziPu(Baozi baozi)
        重写run()方法:
                定义变量 int count = 0; 用于每次做不同的包子
                死循环 while(true)做包子
                循环中定义同步代码块, 锁对象是baozi对象
                同步代码块中, 先if判断是否有包子, 有则wait()
                if代码块外, 判断 count 的奇偶, 奇数将包子改为"冰皮牛肉馅", 偶数将包子改为"薄皮三鲜馅"
                count++ 增加
                打印输出包子铺生产的包子
                sleep 3 秒模拟生产包子的耗时
                修改baozi属性为 true 有包子
                notify()通知吃货来吃
               
包子铺任务:
    if (有包子) {
        则wait()等待吃货通知
    }
    醒了之后, 生产包子
    修改包子状态为: 有包子
    notify()通知吃货来吃
代码:
public class BaoziPu extends Thread {    // 定义包子成员变量, 作为共享的数据
    Baozi baozi;    // 定义有参构造方法, 便于将共享的同一个包子对象传入
    public BaoziPu(Baozi baozi) {
        this.baozi = baozi;
    }    // 定义包子铺的任务    @Override
    public void run() {
        // 定义一个计数器变量, 用于判断生产什么包子
        int count = 0;
        // 循环生产包子
        while (true) {
            // 使用同步代码块
            synchronized (baozi) {
                // 先判断是不是有包子, 有包子则先等待
                if (baozi.you) {
                    try {
                        baozi.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                // 如果能执行到这里, 说明被吃货唤醒了, 要开始做包子. 先判断做什么馅
                if (count % 2 == 0) {
                    // 做薄皮三鲜
                    baozi.pi = "薄皮";
                    baozi.xian = "三鲜馅";
                } else {
                    // 做冰皮牛肉
                    baozi.pi = "冰皮";
                    baozi.xian = "牛肉馅";
                }
                // 将计数器增加
                count++;
                // 打印一句话模拟包子制作过程
                System.out.println("[包子铺] 正在生产" + baozi.pi + baozi.xian + "的包子");
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                // 包子做好了, 要修改包子的状态
                baozi.you = true;
                // 通知吃货来吃
                System.out.println("[包子铺] 做好了" + baozi.pi + baozi.xian + "的包子, 快来取餐!");
                baozi.notify();
            }
        }
    }
}public class Baozi {    String pi;
    String xian;
    boolean you = false;  // 一开始没有包子
}
等待唤醒机制: 吃包子代码实现 (吃货类, 测试类)
5分钟练习: 定义吃货类和测试类
需求:
定义吃货类: Chihuo, 继承Thread类
        属性: 为了写代码方便不用加private
                Baozi baozi;
        有参构造: public ChiHuo(Baozi baozi)
        重写run()方法:
                while(true)循环吃包子
                循环内定义同步代码块, 锁对象为baozi对象
                if判断包子状态, 如果没有包子, 则 wait() 等待
                if代码块外, 打印吃货吃包子
                修改包子状态为 false 没有包子
                notify()通知包子铺做包子
                打印分割线
定义测试类:
        创建baozi对象
        创建包子铺对象, 传入包子, 调用start()启动线程
        创建吃货对象, 传入包子, 调用start()启动线程
        
吃货任务:
    if (没有包子) {
        则wait()等待包子铺通知
    }
    醒了之后, 吃包子
    修改包子状态为: 没有包子
    notify()通知包子铺生产包子
代码:
public class ChiHuo extends Thread {    Baozi baozi;    public ChiHuo(Baozi baozi) {
        this.baozi = baozi;
    }    @Override
    public void run() {
        // 循环吃包子
        while (true) {
            // 使用同步代码块
            synchronized (baozi) {
                // 先判断是不是没有包子, 没有包子则等待
                if (!baozi.you) {
                    try {
                        baozi.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }                // 如果代码能执行到这里 说明被包子铺唤醒了, 则有包子了, 开始吃包子
                System.out.println("[吃货] 我正在吃" + baozi.pi + baozi.xian + "的包子, 真香!");
                // 吃完了修改状态
                baozi.you = false;
                // 通知包子铺再去生产包子
                System.out.println("[吃货] 吃完了, 老板再来一锅!");
                baozi.notify();
                System.out.println("---------------------------");
            }
        }
    }
}public class Test {
    public static void main(String[] args) {
        // 创建一个包子对象, 同时传入包子铺和吃货, 作为共享的锁对象
        Baozi baozi = new Baozi();        // 创建包子铺, 并开始
        new BaoziPu(baozi).start();
        // 创建吃货, 并开始
        new ChiHuo(baozi).start();
    }
}
线程池
线程池概念和原理知识点:
普通创建线程方式有什么缺点
什么是线程池
线程池可以解决什么问题
线程池的工作原理是怎样的
总结:
普通创建线程方式的缺点:
        "创建"线程和"销毁"线程都是比较占用内存和CPU的操作.
        对于一些数量多, 执行时间短的任务, 频繁的创建和销毁线程来执行, 会降低程序运行效率.
        
线程池:
        一个容纳多个线程的容器(集合)
        
线程池可以解决的问题:
        其中的线程可以反复使用, 省去了频繁创建线程对象的操作, 无需反复创建线程而消耗过多资源
        
线程池的工作原理:
        提前创建好多个线程对象, 放在集合中. 多个任务来了反复使用这些线程对象来执行![](./img/02_线程池.bmp)
![](./img/线程池原理.bmp)补充: 线程池的代码实现知识点:
JDK 5 中提供了哪些类/接口和方法, 可以实现线程池
如何使用
总结:
                     一哥栽Q特儿斯
java.util.concurrent.Executors类: 线程池工厂类, 用于创建和管理线程池
        // 静态方法:
        static ExecutorService newFixedThreadPool(int nThreads): 创建固定数量线程的线程池(常用)
        
                     一哥载Q特儿 色儿喂斯
java.util.concurrent.ExecutorService接口: 真正执行任务的线程池服务
        // 成员方法:
        Future submit(Runnable task): 提交一个Runnable任务
        void shutdown(): 通知线程执行完任务后关闭. 如不调此方法, 则线程执行完任务后仍在运行以便重复使用
        
线程池的创建和使用步骤:
        1. 使用Executors的静态方法 newFixedThreadPool(int nThreads) 创建线程池ExecutorService
        2. 创建一个任务类, 实现Runnable接口, 重写run()方法
        3. 调用ExecutorService对象的 submit(Runnable task) 方法, 传递任务给线程池, 执行任务
        4. 调用ExecutorService对象的 shutdown() 方法, 销毁线程池 (不建议执行)
补充:
// 创建线程池对象
ExecutorService es = Executors.newFixedThreadPool(2);
// 提交任务
RunnableImpl r = new RunnableImpl();  // 1个任务
es.submit(new RunnableImpl());
es.submit(new RunnableImpl());
es.submit(new RunnableImpl());
// 销毁线程池
es.shutdown();
单独创建的线程 和 线程池 的适用场景:
    单独创建的线程: 适合任务执行时间长, 但数量少的场景 (包子铺吃货)
    线程池: 适合任务执行时间短, 但数量多的场景 (网络请求, 10000个用户分别查看一个网页页面)
5分钟练习: 使用线程池模拟银行服务员
需求: 模拟银行柜台办理业务
银行有2个柜台, 现在来了10个客户. 同一时间只能有2个客户办理业务, 其余客户要等待定义RunnableImpl类, 实现Runnable接口, 模拟办理业务:
        重写run()方法:
                打印: 线程名称+"号柜台为您服务"
        打印: "顾客正在办理业务..."
                sleep()2秒模拟客户办理业务耗时
                打印: 线程名称+"号柜台期待您再次光临"
                打印: 分割线--------
定义测试类:
        Executors.newFixedThreadPool(2) 创建有2个线程的线程池ExecutorService
        for循环10次, 循环内使用ExecutorService对象的 submit() 提交任务对象, 用来模拟10个用户
        循环结束后使用ExecutorService对象的 shutdown() 方法结束线程池
代码:
public class RunnableImpl implements Runnable {
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "号柜台为您服务");
        System.out.println("顾客正在办理业务...");
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "号柜台期待您再次光临");
        System.out.println("--------------------------------------------");
    }
}public class Test {
    public static void main(String[] args) {
        // 创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(2);
        // 提交10个任务
        for (int i = 0; i < 10; i++) {
            executorService.submit(new RunnableImpl());
        }
        // 可以关闭也可以不关闭
        executorService.shutdown();
    }
}
函数式编程思想: Lambda表达式
函数式编程思想概述知识点:
函数式编程思想强调什么
函数式编程思想与面向对象编程思想有什么区别
函数式编程思想有什么好处
总结:
函数式:
        在数学中, 函数就是有输入量, 输出量的一套计算方案, 也就是"传入什么东西, 得到什么结果"
    y = f(x)面向对象: 强调"用哪个对象的哪个方法"来做事 (注重语法形式: 继承 方法重写)
函数式: 强调"传入的参数 和 要执行的代码"函数式编程的好处:
        简化代码编写 (使用 λ Lambda表达式, 简化匿名内部类的代码)
补充: 冗余的Runnable代码知识点:
之前使用的匿名内部类方式创建线程对象的代码, 有哪些是按照面向对象思想不得不写出来的多余步骤
总结:
// 我们要通过Lambda表达式简化以下的代码
new Thread(new Runnable() {
    @Override
    public void run() {
        // 要执行的代码才是重要的
    }
}).start();关键代码是: run()方法中要执行的任务
而其他代码都只是形式
补充: 编程思想的转换, 体验Lambda更优写法知识点:
Lambda表达式是哪个JDK版本中加入的
体会Lambda表达式简化匿名内部类的代码的简洁性
总结:
JDK 8 中, 加入的Lambda表达式, 是函数式编程思想中的重点对比:
    // 面向对象方式的代码
    new Thread(new Runnable() {
        @Override
        public void run() {
            System.out.println(Thread.currentThread().getName() + "新线程创建了");
        }
    }).start();
    // 函数式编程的代码
    new Thread( ()-> {
                        System.out.println(Thread.currentThread().getName() + "新线程创建了");
            }
    ).start();
补充: Lambda标准格式知识点:
Lambda表达式的标准格式是什么样的, 由哪3部分组成
总结:
Lambda表达式的3个部分:
    1. 一些参数 ()
                接口中抽象方法的参数列表. 没参数就空着; 有参数就写, 多个参数用逗号分隔
    2. 一个箭头 ->
                将参数传递给方法体
    3. 一段代码 {}
                重写接口抽象方法的方法体格式:
        // 写成多行
        (数据类型 变量名, 数据类型 变量名) -> {
        一些重写方法的代码
        一些重写方法的代码
        ...
    }        // 如果代码只有一行, 也可以合并写成一行
        (参数列表) -> {一些重写方法的代码}
补充: 5分钟练习: 使用Lambda标准格式(简化线程创建)
需求:
定义测试类, 使用实现Runnable接口方式创建线程
        1. 创建Thread对象, 在构造方法参数中, 使用匿名内部类方式传入Runnable实现类对象
                重写 run() 方法, 打印 线程名字+"新线程创建了", 并启动线程
        2. 创建Thread对象, 在构造方法参数中, 使用Lambda表达式方式传入Runnable实现类对象
                重写 run() 方法, 打印 线程名字+"新线程创建了", 并启动线程
代码:
public class Test {
    public static void main(String[] args) {
        // 匿名内部类方式
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName()+"新线程创建了");
            }
        }).start();
        // Lambda标准格式
        new Thread(
                // 为了避免括号嵌套混乱看不清关系, 可以将参数括号单独换一行, 再写Lambda参数
                () -> {
                    System.out.println(Thread.currentThread().getName()+"新线程创建了");
                }
        ).start();
    }
}
练习: 使用Lambda标准格式(重写"无参无返回值"的方法)
5分钟练习: 厨师喊吃饭
需求:
已经提供了一个厨子 Cook 接口, 接口中只有唯一一个抽象方法 makeFood(), 且无参数, 无返回值. 如下:public interface Cook {
    void makeFood();
}在下面的代码中, 请分别使用匿名内部类方式, 和Lambda的标准格式, 调用 invokeCook() 方法, 打印输出"吃饭啦!"字样:public class Test {
    public static void main(String[] args) {
        // TODO 请在此使用匿名内部类方式调用invokeCook方法        // TODO 请在此使用Lambda【标准格式】调用invokeCook方法    }    private static void invokeCook(Cook cook) {
        cook.makeFood();
    }
}
代码:
public interface Cook {
    // 做饭的方法
    void makeFood();
}public class Test {
    public static void main(String[] args) {
        // 匿名内部类调用方法
        invokeCook(new Cook() {
            @Override
            public void makeFood() {
                System.out.println("匿名内部类方式: 吃饭啦");
            }
        });        // Lambda标准格式调用方法
        invokeCook(()->{
            System.out.println("Lambda标准格式: 吃饭啦");
        });
    }    private static void invokeCook(Cook cook) {
        cook.makeFood();
    }
}
练习: 使用Lambda标准格式(重写"有参有返回值"的方法)
5分钟练习: 数组排序
需求:
定义Person类:
        属性: private String name, private int age
        生成无参, 有参构造, set/get方法, toString()
定义测试类:
    定义Person数组存储3个Person对象:
        柳岩, 38
        迪丽热巴, 18
        古力娜扎, 19
    使用Arrays类的静态方法sort(T[] a, Comparator<? super T> c), 根据年龄升序对数组排序
            传入Comparator对象时, 分别使用匿名内部类比较器和Lambda表达式比较器2种方式来实现
    打印集合查看排序后的效果
代码:
public class Test {
    public static void main(String[] args) {
        // 创建3个Person对象
        Person p1 = new Person("柳岩", 38);
        Person p2 = new Person("迪丽热巴", 18);
        Person p3 = new Person("古力娜扎", 19);        // 创建数组
        Person[] arr = new Person[]{p1, p2, p3};        // 对数组排序
        // 匿名内部类方式
        /*Arrays.sort(arr, new Comparator<Person>() {
            @Override
            public int compare(Person o1, Person o2) {
                return o1.getAge() - o2.getAge();
            }
        });*/        // Lambda标准格式
        Arrays.sort(arr, (Person o1, Person o2) -> {
            return o1.getAge() - o2.getAge();
        });        // 打印排序后的结果
        for (Person person : arr) {
            System.out.println(person);
        }
    }
}
补充:
函数式接口:
        函数式接口: "有且仅有一个抽象方法的接口"
        但函数式接口对于 哪些方法算作抽象方法 有特殊规定:
                1. 有方法体的方法"不算作"抽象方法, 如默认方法, 静态方法, 私有方法
                2. 如果一个抽象方法 与 java.lang.Object类中的方法 定义相同的, 也"不算作"抽象方法
                        因为任何实现本接口的实现类, 都会直接或间接继承java.lang.Object类的public的方法, 所以在创建实现类时其实不用重写该抽象方法, 也就不算作抽象方法
练习: 使用Lambda标准格式(自定义接口, 抽象方法有参有返回值)
5分钟练习: 计算器
需求:
已经提供了一个计算器接口 Calculator, 接口中只有唯一一个抽象方法 calc(), 计算两个int数字:// 计算器
public interface Calculator {  
    int calc(int a, int b);  // 计算a和b的结果, 并返回
}在下面的代码中,请使用匿名内部类和Lambda的标准格式调用 invokeCalc() 方法, 完成120和130的相加计算:public class Demo08InvokeCalc {
    public static void main(String[] args) {
            // TODO 请在此使用匿名内部类方式调用invokeCalc方法来计算120+130的结果
            
        // TODO 请在此使用Lambda【标准格式】调用invokeCalc方法来计算120+130的结果
        
    }
   
    private static void invokeCalc(int a, int b, Calculator calculator) {
        int result = calculator.calc(a, b);
        System.out.println("结果是:" + result);
    }
}
代码:
// 函数式接口, 模拟Comparator接口
public interface Calculator {
    // 计算2个整数的结果并返回
    int calc(int a, int b);
}public class Test {
    public static void main(String[] args) {
        // 匿名内部类
        invokeCalc(120, 130, new Calculator() {
            @Override
            public int calc(int a, int b) {
                return a + b;
            }
        });        // Lambda标准格式
        invokeCalc(120, 130, (int a, int b)->{
            return a + b;
        });
    }    // 模拟 Arrays.sort(T[] arr, Comparator c) 方法
    private static void invokeCalc(int a, int b, Calculator calculator) {
        int result = calculator.calc(a, b);
        System.out.println("结果是:" + result);
    }
}
Lambda省略格式和使用前提知识点:
Lambda表达式的省略原则是什么, 哪些部分可以省略
Lambda表达式的使用前提有哪些
总结:
省略原则:
        "可推导的都可省略" (凡是能根据前后代码能猜测出来的代码, 都可以省略不写)
        
    可以省略的部分:
        1. (参数列表): 参数"类型"可以省略 (a, b) -> {}
        2. (参数列表): 如果参数只有1个, 则"类型"和"小括号"都可以省略  a -> sout(a)
        3. {一些代码}: 如果只有一条代码, 则"大括号", "return", "分号"都可以"一起省略"
        
            
*函数式接口:
        函数式接口: "有且仅有一个抽象方法的接口"
        但函数式接口对于 哪些方法算作抽象方法 有特殊规定:
                1. 有方法体的方法"不算作"抽象方法, 如默认方法, 静态方法, 私有方法
                2. 如果一个抽象方法 与 java.lang.Object类中的方法 定义相同的, 也"不算作"抽象方法
                        因为任何实现本接口的实现类, 都会直接或间接继承java.lang.Object类的public的方法, 所以在创建实现类时其实不用重写该抽象方法, 也就不算作抽象方法
Lambda表达式的使用前提:
    1. Lambda只能用于接口, 且"接口中有且仅有一个抽象方法"(也称为"函数式接口")
        普通类, 抽象类不能用
    2. 使用Lambda必须具有上下文推断
        接口中只能有一个抽象方法, 才能推断出来重写的是这个抽象方法
    简而言之: 参数类型必须是函数式接口
        
        
        比如以下构造方法
        Thread(Runnable r): 该构造方法的参数类型是Runnable        // Runnable接口中, 有且仅有一个抽象方法, 该接口就是一个函数式接口, 可以使用Lambda表达式
        public interface Runnable {
            public abstract void run();
        }
        
                // Comparator接口中, 有且仅有一个抽象方法
        public interface Comparator<T> {
            // 这是该接口中有且仅有的一个抽象方法
            int compare(T o1, T o2);            // 该方法与Object类中equals定义相同, 所以不算抽象方法
            boolean equals(Object obj);            // 一些default方法, 有方法体, 不算抽象方法
            // 一些静态方法, 有方法体, 不算抽象方法
        }                // 我们今天自己定义的接口, 也满足函数式接口的要求
                public interface Cook {
                        void makeFood();
                }
补充: 10分钟练习: 使用Lambda的省略格式
需求:
将今日使用Lambda标准格式写的4个练习(创建线程, 厨师喊吃饭, 数组对Person排序, 计算器)的代码, 使用Lambda的"省略格式"再次实现
代码:
// Lambda省略格式
new Thread(() -> System.out.println(Thread.currentThread().getName() + "新线程创建了")).start();// Lambda省略格式
invokeCook(()-> System.out.println("Lambda标准格式: 吃饭啦"));// Lambda省略格式
Arrays.sort(arr, (o1, o2) -> o1.getAge() - o2.getAge());// Lambda省略格式
invokeCalc(120, 130, (a, b)->a + b);
--- 今日API
java.lang.Object类:
        // 成员方法
        void wait(): 使用锁对象调用, 当前线程进入WAITING无限等待状态, 直到被其他线程唤醒
        void notify(): 使用锁对象调用, 随机唤醒一个处于等待状态的线程
        void notifyAll(): 使用锁对象调用, 唤醒所有处于等待状态的线程java.util.concurrent.Executors类: 线程池工厂类, 用于管理线程池
        // 静态方法:
        static ExecutorService newFixedThreadPool(int nThreads): 创建固定数量线程的线程池(常用)
        
java.util.concurrent.ExecutorService接口: 真正执行任务的线程池服务
        // 成员方法:
        Future submit(Runnable task): 提交一个Runnable任务
        void shutdown(): 通知线程执行完任务后关闭. 如不调此方法, 则线程执行完任务后仍在运行以便重复使用
今日目标 能够理解线程通信概念
        多个线程操作共享的资源, 每个线程执行的任务不同, 需要相互协作, 依赖线程间通信
等待唤醒机制
        wait/notify
                调用wait: 1. 释放锁 2.进入WAITING状态
                离开WAITING: 1. 获取锁 2.等待CPU调用执行wait()
        wait(long millis)
        notify()
        notifyAll()
描述Java中线程池运行原理
        集合装着提前创建好的线程对象
        有任务时, 从集合中取出线程来执行任务
        执行完任务后, 线程会被归还到线程池, 以备复用ExecutorService es = Executors.newFixedThreadPool(2)
        es.submit(new RunnableImpl());
理解函数式编程相对于面向对象的优点
        面向对象: 注重对象调用方法(语法格式)
        函数式: 注重输入什么(参数), 得到什么结果(运行代码)
                简化代码y = f(x);
掌握Lambda表达式的标准格式
        (参数列表) -> {一段代码}
使用Lambda标准格式使用Runnable与Comparator接口
        创建线程
        Person数组排序
Lambda表达式的省略格式与规则
        规则:
                1.(参数): 省略"数据类型"
                2.(参数): 如果参数只有1个, 省略"数据类型"和"小括号"
                3.{一段代码}: 如果代码只有一条, 可以"同时省略": "大括号{}", "return关键字", ";分号"
使用Lambda省略格式使用Runnable与Comparator接口
        创建线程
        Person数组排序
通过Lambda的标准格式使用自定义的接口(有且仅有一个抽象方法)
        Cook 厨师
        Calculator 计算器
通过Lambda的省略格式使用自定义的接口(有且仅有一个抽象方法)
        Cook 厨师
        Calculator 计算器
明确Lambda的两项使用前提
        1. Lambda只适用于"函数式接口" (有且仅有一个抽象方法)
        2. 必须具有上下文的推导




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2