高并发编程之多线程锁和Callable&Future 接口

柔情只为你懂 2024-03-30 09:04 67阅读 0赞

## **5 多线程锁** ##

### **5.1 锁的八个问题演示** ###

package com.xingchen.sync;
    
    import java.util.concurrent.TimeUnit;
    
    class Phone {
    
        public static synchronized void sendSMS() throws Exception {
            //停留4秒
            TimeUnit.SECONDS.sleep(4);
            System.out.println("------sendSMS");
        }
    
        public synchronized void sendEmail() throws Exception {
            System.out.println("------sendEmail");
        }
    
        public void getHello() {
            System.out.println("------getHello");
        }
    }
    
    /**
     * @author xing'chen
     * @Description: 8锁
     *
    1 标准访问，先打印短信还是邮件
    ------sendSMS
    ------sendEmail
    
    2 停4秒在短信方法内，先打印短信还是邮件
    ------sendSMS
    ------sendEmail
    
    3 新增普通的hello方法，是先打短信还是hello
    ------getHello
    ------sendSMS
    
    4 现在有两部手机，先打印短信还是邮件
    ------sendEmail
    ------sendSMS
    
    5 两个静态同步方法，1部手机，先打印短信还是邮件
    ------sendSMS
    ------sendEmail
    
    6 两个静态同步方法，2部手机，先打印短信还是邮件
    ------sendSMS
    ------sendEmail
    
    7 1个静态同步方法,1个普通同步方法，1部手机，先打印短信还是邮件
    ------sendEmail
    ------sendSMS
    
    8 1个静态同步方法,1个普通同步方法，2部手机，先打印短信还是邮件
    ------sendEmail
    ------sendSMS
    
     */
    
    public class Lock_8 {
        public static void main(String[] args) throws Exception {
    
            Phone phone = new Phone();
            Phone phone2 = new Phone();
    
            new Thread(() -> {
                try {
                    phone.sendSMS();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }, "AA").start();
    
            Thread.sleep(100);
    
            new Thread(() -> {
                try {
                   // phone.sendEmail();
                   // phone.getHello();
                    phone2.sendEmail();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }, "BB").start();
        }
    }

### **结论** **:** ###

一个对象里面如果有多个 synchronized 方法，某一个时刻内，只要一个线程去调用其中的

一个 synchronized 方法了，

其它的线程都只能等待，换句话说，某一个时刻内，只能有唯一一个线程去访问这些

synchronized 方法

锁的是当前对象 this，被锁定后，其它的线程都不能进入到当前对象的其它的

synchronized 方法

加个普通方法后发现和同步锁无关

换成两个对象后，不是同一把锁了，情况立刻变化。

synchronized 实现同步的基础：Java 中的每一个对象都可以作为锁。

### **具体表现为以下** **3** **种形式。** ###

*  **对于普通同步方法，锁是当前实例对象。**
 *  **对于静态同步方法，锁是当前类的** **Class** **对象。**
 *  **对于同步方法块，锁是 Synchonized 括号里配置的对象**

当一个线程试图访问同步代码块时，它首先必须得到锁，退出或抛出异常时必须释放锁。

也就是说如果一个实例对象的非静态同步方法获取锁后，该实例对象的其他非静态同步方法必须等待获取锁的方法释放锁后才能获取锁，可是别的实例对象的非静态同步方法因为跟该实例对象的非静态同步方法用的是不同的锁，所以毋须等待该实例对象已获取锁的非静态同步方法释放锁就可以获取他们自己的锁。所有的静态同步方法用的也是同一把锁——类对象本身，这两把锁是两个不同的对象，所以静态同步方法与非静态同步方法之间是不会有竞态条件的。但是一旦一个静态同步方法获取锁后，其他的静态同步方法都必须等待该方法释放锁后才能获取锁，而不管是同一个实例对象的静态同步方法之间，还是不同的实例对象的静态同步方法之间，只要它们同一个类的实例对象！

## **6 Callable&Future 接口** ##

### **6.1 Callable 接口** ###

目前我们学习了有两种创建线程的方法-一种是通过创建 Thread 类，另一种是

通过使用 Runnable 创建线程。但是，Runnable 缺少的一项功能是，当线程

终止时（即 run（）完成时），我们无法使线程返回结果。为了支持此功能，

Java 中提供了 Callable 接口。

**现在我们学习的是创建线程的第三种方案—Callable 接口**

**Callable 接口的特点如下(重点)**

• 为了实现 Runnable，需要实现不返回任何内容的 run（）方法，而对于

Callable，需要实现在完成时返回结果的 call（）方法。

• call（）方法可以引发异常，而 run（）则不能。

• 为实现 Callable 而必须重写 call 方法

• 不能直接替换 runnable,因为 Thread 类的构造方法根本没有 Callable

创建新类 MyThread 实现 runnable 接口
    class MyThread implements Runnable{
        @Override
        public void run() {
        }
    }
        新类 MyThread2 实现 callable 接口
    class MyThread2 implements Callable<Integer> {
        @Override
        public Integer call() throws Exception {
            return 200;
        }
    }

### **6.2 Future 接口** ###

当 call（）方法完成时，结果必须存储在主线程已知的对象中，以便主线程可

以知道该线程返回的结果。为此，可以使用 Future 对象。将 Future 视为保存结果的对象–它可能暂时不保存结果，但将来会保存（一旦

Callable 返回）。Future 基本上是主线程可以跟踪进度以及其他线程的结果的

一种方式。要实现此接口，必须重写 5 种方法，这里列出了重要的方法,如下:

• **public boolean cancel（boolean mayInterrupt）：** 用于停止任务。

==如果尚未启动，它将停止任务。如果已启动，则仅在 mayInterrupt 为 true

时才会中断任务。==

• **public Object get（）抛出 InterruptedException，ExecutionException：**

用于获取任务的结果。

==如果任务完成，它将立即返回结果，否则将等待任务完成，然后返回结果。

• **public boolean isDone（）：** 如果任务完成，则返回 true，否则返回 false

可以看到 Callable 和 Future 做两件事-Callable 与 Runnable 类似，因为它封

装了要在另一个线程上运行的任务，而 Future 用于存储从另一个线程获得的结

果。实际上，future 也可以与 Runnable 一起使用。

要创建线程，需要 Runnable。为了获得结果，需要 future。

### **6.3 FutureTask** ###

Java 库具有具体的 FutureTask 类型，该类型实现 Runnable 和 Future，并方

便地将两种功能组合在一起。 可以通过为其构造函数提供 Callable 来创建

FutureTask。然后，将 FutureTask 对象提供给 Thread 的构造函数以创建

Thread 对象。因此，间接地使用 Callable 创建线程。

**核心原理:(重点)**

在主线程中需要执行比较耗时的操作时，但又不想阻塞主线程时，可以把这些

作业交给 Future 对象在后台完成

• 当主线程将来需要时，就可以通过 Future 对象获得后台作业的计算结果或者执

行状态• 一般 FutureTask 多用于耗时的计算，主线程可以在完成自己的任务后，再去

获取结果。

• 仅在计算完成时才能检索结果；如果计算尚未完成，则阻塞 get 方法

• 一旦计算完成，就不能再重新开始或取消计算

• get 方法而获取结果只有在计算完成时获取，否则会一直阻塞直到任务转入完

成状态，然后会返回结果或者抛出异常

• get 只计算一次,因此 get 方法放到最后

**demo 案例**

### **6.4 使用 Callable 和 Future** ###

CallableDemo 案例

/**
     * CallableDemo 案列
     */
    public class CallableDemo {
        /**
         * 实现 runnable 接口
         */
        static class MyThread1 implements Runnable{
            /**
             * run 方法
             */
            @Override
            public void run() {
                try {
                    System.out.println(Thread.currentThread().getName() + "线程进入了 run
                            方法");
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        }
        /**
         * 实现 callable 接口
         */
        static class MyThread2 implements Callable{
            /**
             * call 方法
             * @return
             * @throws Exception
             */
            @Override
            public Long call() throws Exception {
                try {
                    System.out.println(Thread.currentThread().getName() + "线程进入了 call
                            方法,开始准备睡觉");
                            Thread.sleep(1000);
                    System.out.println(Thread.currentThread().getName() + "睡醒了");
                }catch (Exception e){
                    e.printStackTrace();
                }
                return System.currentTimeMillis();
            }
        }
        public static void main(String[] args) throws Exception{
            //声明 runable
            Runnable runable = new MyThread1();
            //声明 callable
            Callable callable = new MyThread2();
            //future-callable
            FutureTask<Long> futureTask2 = new FutureTask(callable);
            //线程二
            new Thread(futureTask2, "线程二").start();
            for (int i = 0; i < 10; i++) {
                Long result1 = futureTask2.get();
                System.out.println(result1);
            }
            //线程一
            new Thread(runable,"线程一").start();
        }
    }

### **6.5 小结(重点)** ###

• 在主线程中需要执行比较耗时的操作时，但又不想阻塞主线程时，可以把这些

作业交给 Future 对象在后台完成, 当主线程将来需要时，就可以通过 Future

对象获得后台作业的计算结果或者执行状态• 一般 FutureTask 多用于耗时的计算，主线程可以在完成自己的任务后，再去

获取结果

• 仅在计算完成时才能检索结果；如果计算尚未完成，则阻塞 get 方法。一旦计

算完成，就不能再重新开始或取消计算。get 方法而获取结果只有在计算完成

时获取，否则会一直阻塞直到任务转入完成状态，然后会返回结果或者抛出异

常。

• 只计算一次

## 文件的所有图片 ##

![db0e990b2397ca9dd9d9ae6bd023640b.png][]![b551d2908738eec137e17360917680f1.png][]![02ef04253596fbe33ce2ae8d17e6a50c.png][]![c27f7f50bfed2cada10b98fa0c51235c.png][]![b254e4cafa55b66d6dbc44b9fbfe21e3.png][]![b44e5eee68dff79efabe3da54108c3e3.png][]![8e562553aa8c4b913aca9abf8823fad5.png][]![78244ea7a655667dd3414da0951910a1.png][]![56e1d6ccabc750651b5f5c19e6aca87e.png][]![ef3249170261f2404f95cb74c3b11bd7.png][]![9390092decd696ae8be5ce5b4e22e184.png][]![c7360fbddbd382c63f643c16c12bd8bd.png][]![4c6b19df8b9a6d05a7dec9988981dbc2.png][]![6cb6e5a0a9c810648b0e40e357dc3c3e.png][]![bbdef721cae015de794372a79fd27909.png][]![f57ec0e204aa423ea024aa37bbc81234.png][]

[db0e990b2397ca9dd9d9ae6bd023640b.png]: https://img-blog.csdnimg.cn/img_convert/db0e990b2397ca9dd9d9ae6bd023640b.png
[b551d2908738eec137e17360917680f1.png]: https://img-blog.csdnimg.cn/img_convert/b551d2908738eec137e17360917680f1.png
[02ef04253596fbe33ce2ae8d17e6a50c.png]: https://img-blog.csdnimg.cn/img_convert/02ef04253596fbe33ce2ae8d17e6a50c.png
[c27f7f50bfed2cada10b98fa0c51235c.png]: https://img-blog.csdnimg.cn/img_convert/c27f7f50bfed2cada10b98fa0c51235c.png
[b254e4cafa55b66d6dbc44b9fbfe21e3.png]: https://img-blog.csdnimg.cn/img_convert/b254e4cafa55b66d6dbc44b9fbfe21e3.png
[b44e5eee68dff79efabe3da54108c3e3.png]: https://img-blog.csdnimg.cn/img_convert/b44e5eee68dff79efabe3da54108c3e3.png
[8e562553aa8c4b913aca9abf8823fad5.png]: https://img-blog.csdnimg.cn/img_convert/8e562553aa8c4b913aca9abf8823fad5.png
[78244ea7a655667dd3414da0951910a1.png]: https://img-blog.csdnimg.cn/img_convert/78244ea7a655667dd3414da0951910a1.png
[56e1d6ccabc750651b5f5c19e6aca87e.png]: https://img-blog.csdnimg.cn/img_convert/56e1d6ccabc750651b5f5c19e6aca87e.png
[ef3249170261f2404f95cb74c3b11bd7.png]: https://img-blog.csdnimg.cn/img_convert/ef3249170261f2404f95cb74c3b11bd7.png
[9390092decd696ae8be5ce5b4e22e184.png]: https://img-blog.csdnimg.cn/img_convert/9390092decd696ae8be5ce5b4e22e184.png
[c7360fbddbd382c63f643c16c12bd8bd.png]: https://img-blog.csdnimg.cn/img_convert/c7360fbddbd382c63f643c16c12bd8bd.png
[4c6b19df8b9a6d05a7dec9988981dbc2.png]: https://img-blog.csdnimg.cn/img_convert/4c6b19df8b9a6d05a7dec9988981dbc2.png
[6cb6e5a0a9c810648b0e40e357dc3c3e.png]: https://img-blog.csdnimg.cn/img_convert/6cb6e5a0a9c810648b0e40e357dc3c3e.png
[bbdef721cae015de794372a79fd27909.png]: https://img-blog.csdnimg.cn/img_convert/bbdef721cae015de794372a79fd27909.png
[f57ec0e204aa423ea024aa37bbc81234.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/020d077f67a248fc8a181750b48119b9.png