AI 助理
备案控制台
开发者社区 安全 文章 正文

JAVA之旅（十三）——线程的安全性，synchronized关键字，多线程同步代码块，同步函数，同步函数的锁是this

2016-06-04 1020
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： JAVA之旅（十三）——线程的安全性，synchronized关键字，多线程同步代码块，同步函数，同步函数的锁是this 我们继续上个篇幅接着讲线程的知识点一.线程的安全性 当我们开启四个窗口（线程）把票陆陆续续的卖完了之后，我们要反思一下，这里面有没有...

JAVA之旅（十三）——线程的安全性，synchronized关键字，多线程同步代码块，同步函数，同步函数的锁是this

我们继续上个篇幅接着讲线程的知识点

一.线程的安全性

当我们开启四个窗口（线程）把票陆陆续续的卖完了之后，我们要反思一下，这里面有没有安全隐患呢？在实际情况中，这种事情我们是必须要去考虑安全问题的，那我们模拟一下错误

package com.lgl.hellojava;

import javax.security.auth.callback.TextInputCallback;

//公共的   类   类名
public class HelloJJAVA {

    public static void main(String[] args) {

        /**
         * 需求：简单的卖票程序，多个线程同时卖票
         */
        MyThread myThread = new MyThread();
        Thread t1 = new Thread(myThread);
        Thread t2 = new Thread(myThread);
        Thread t3 = new Thread(myThread);
        Thread t4 = new Thread(myThread);

        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }

}

/**
 * 卖票程序
 * 
 * @author LGL
 *
 */
class MyThread implements Runnable {

    // 票数
    private  int tick = 100;

    @Override
    public void run() {
        while (true) {
            if (tick > 0) {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println("卖票:" + tick--);
            }
        }
    }
}

我们输出的结果

这里写图片描述

这里出现了0票，如果你继续跟踪的话，你会发现，还会出现-1，-2之类的票，这就是安全隐患，那原因是什么呢？

  • 当多条语句在操作同一个线程共享数据时，一个线程对多条语句只执行了一个部分，还没有执行完，另外一个线程参与了执行，导致共享数据的错误

解决办法：对多条操作共享数据的语句，只能让一个线程都执行完再执行过程中其他线程不可以参与运行

JAVA对多线程的安全问题提供了专业的解决办法，就是同步代码块


    synchronized(对象){
        //需要同步的代码
    }

那我们怎么用呢？

package com.lgl.hellojava;

//公共的   类   类名
public class HelloJJAVA {

    public static void main(String[] args) {

        /**
         * 需求：简单的卖票程序，多个线程同时卖票
         */
        MyThread myThread = new MyThread();
        Thread t1 = new Thread(myThread);
        Thread t2 = new Thread(myThread);
        Thread t3 = new Thread(myThread);
        Thread t4 = new Thread(myThread);

        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }

}

/**
 * 卖票程序
 * 
 * @author LGL
 *
 */
class MyThread implements Runnable {

    // 票数
    private  int tick = 100;

    Object oj = new Object();
    @Override
    public void run() {
        while (true) {
            synchronized(oj){
                if (tick > 0) {
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println("卖票:" + tick--);
                }
            }

        }
    }
}

这样，就输出

这里写图片描述

二.多线程同步代码块

我们为什么可以这样去同步线程？

对象如同锁，持有锁的线程可以在同步中执行，没有执行锁的线程即使获取了CPU的执行权，也进不去，因为没有获取锁，我们可以这样理解

  • 四个线程，哪一个进去就开始执行，其他的拿不到执行权，所以即使拿到了执行权，也进不去，这个同步能解决线程的安全问题

但是，同步是有前提的

  • 1.必须要有两个或者两个以上的线程，不然你同步也没必要呀
  • 2.必须是多个线程使用同一锁

必须保证同步中只能有一个线程在运行

但是他也有一个弊端：那就是多个线程都需要判断锁，较为消耗资源

三.多线成同步函数

我们可以写一段小程序，来验证这个线程同步的问题，也就是说我们看看下面这段程序是否有安全问题，有的话，如何解决？

package com.lgl.hellojava;

//公共的   类   类名
public class HelloJJAVA {

    public static void main(String[] args) {

        /**
         * 需求：银行里有一个金库 有两个人要存钱300
         */
        MyThread myThread = new MyThread();
        Thread t1 = new Thread(myThread);
        Thread t2 = new Thread(myThread);

        t1.start();
        t2.start();

    }

}

/**
 * 存钱程序，一次100
 * @author LGL
 *
 */
class MyThread implements Runnable {

    private Bank b = new Bank();

    @Override
    public void run() {
        for (int i = 0; i < 3; i++) {
            b.add(100);
        }
    }

}

/**
 * 银行
 * @author LGL
 *
 */
class Bank {
    private int sum;

    public void add(int n) {
        sum = sum + n;
        System.out.println("sum:" + sum);
    }
}

当你执行的时候你会发现

这里写图片描述

这里是没错的，存了600块钱，但是，这个程序是有安全隐患的

如何找到问题？

  • 1.明确哪些代码是多线成运行代码
  • 2.明确共享数据
  • 3.明确多线成运行代码中哪些语句是操作共享数据的

那我们怎么找到安全隐患呢？我们去银行的类里面做些认为操作

/**
 * 银行
 * @author LGL
 *
 */
class Bank {
    private int sum;

    public void add(int n) {
        sum = sum + n;
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("sum:" + sum);
    }
}

让他sleep一下你就会发现

这里写图片描述

这样的话，我们就可以使用我们的同步代码了

/**
 * 银行
 * 
 * @author LGL
 *
 */
class Bank {
    private int sum;

    Object j = new Object();

    public void add(int n) {
        synchronized (j) {
            sum = sum + n;
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println("sum:" + sum);
        }
    }
}

这样代码就可以同步了

这里写图片描述

哪些代码该同步，哪些不该同步，你一定要搞清楚，根据上面的3个条件

大家有没有注意到，函数式具有封装代码的特定，而我们所操作的同步代码块也是有封装代码的特性，拿这样的话我们就可以换一种形式去操作，那就是写成函数的修饰符


/**
 * 银行
 * 
 * @author LGL
 *
 */
class Bank {
    private int sum;

    public synchronized void add(int n) {
        sum = sum + n;
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("sum:" + sum);
    }
}

这样也是OK的

四.同步函数的锁是this

既然我们学习了另一种同步函数的写法，那我们就可以把刚才的买票小例子进一步封装一下了

package com.lgl.hellojava;

//公共的   类   类名
public class HelloJJAVA {

    public static void main(String[] args) {

        /**
         * 需求：简单的卖票程序，多个线程同时卖票
         */
        MyThread myThread = new MyThread();
        Thread t1 = new Thread(myThread);
        Thread t2 = new Thread(myThread);
        Thread t3 = new Thread(myThread);
        Thread t4 = new Thread(myThread);

        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }

}

/**
 * 卖票程序
 * 
 * @author LGL
 *
 */
class MyThread implements Runnable {

    // 票数
    private int tick = 100;

    @Override
    public synchronized void run() {
        while (true) {
            if (tick > 0) {
                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread()+"卖票:" + tick--);
            }
        }
    }
}

但是这样做，你却会发现一个很严重的问题，那就是

这里写图片描述

永远只有0线程在执行卖票

那是因为我们并没有搞清楚需要同步哪一个代码段，我们应该执行的只是里面的那两段代码，而不是整个死循环，所以我们得封装个函数进行线程同步

package com.lgl.hellojava;

//公共的   类   类名
public class HelloJJAVA {

    public static void main(String[] args) {

        /**
         * 需求：简单的卖票程序，多个线程同时卖票
         */
        MyThread myThread = new MyThread();
        Thread t1 = new Thread(myThread);
        Thread t2 = new Thread(myThread);
        Thread t3 = new Thread(myThread);
        Thread t4 = new Thread(myThread);

        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }

}

/**
 * 卖票程序
 * 
 * @author LGL
 *
 */
class MyThread implements Runnable {

    // 票数
    private int tick = 100;

    @Override
    public void run() {
        while (true) {
            show();
        }
    }

    private synchronized void show() {
        if (tick > 0) {
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread() + "卖票:" + tick--);
        }
    }
}

这样输出解决了

这里写图片描述

问题是被解决了，但是随之问题也就来了

  • 同步函数用的是哪一个锁呢？

函数需要被对象调用，那么函数都有一个所属对象的引用，就是this，所以同步函数所引用的锁是this,我们来验证一下，我们把程序改动一下

使用两个线程来卖票，一个线程在同步代码块中，一个线程在同步函数中，都在执行卖票动作

package com.lgl.hellojava;

//公共的   类   类名
public class HelloJJAVA {

    public static void main(String[] args) {

        /**
         * 需求：简单的卖票程序，多个线程同时卖票
         */
        MyThread myThread = new MyThread();
        Thread t1 = new Thread(myThread);
        Thread t2 = new Thread(myThread);
        // Thread t3 = new Thread(myThread);
        // Thread t4 = new Thread(myThread);

        t1.start();
        myThread.flag = false;
        t2.start();
        // t3.start();
        // t4.start();
    }

}

/**
 * 卖票程序
 * 
 * @author LGL
 *
 */
class MyThread implements Runnable {

    // 票数
    private int tick = 100;

    Object j = new Object();

    boolean flag = true;

    @Override
    public void run() {

        if (flag) {
            while (true) {
                synchronized (j) {
                    if (tick > 0) {
                        try {
                            Thread.sleep(10);
                        } catch (InterruptedException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                        System.out.println(Thread.currentThread() + "code:"
                                + tick--);
                    }
                }
            }
        } else {
            while (true) {
                show();
            }
        }

    }

    private synchronized void show() {
        if (tick > 0) {
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread() + "show:" + tick--);
        }
    }
}

当我们运行的时候就发现

这里写图片描述

他只在show中进行，那是为什么呢？因为主线程开启的时候瞬间执行，我们要修改一下，让线程1开启的时候，主线程睡个10毫秒试试

    t1.start();

        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        myThread.flag = false;
        t2.start();

这样输出的结果貌似是交替进行

这里写图片描述

但是所知而来的，是0票，这说明这个线程不安全，我们明明加了同步啊，怎么还是不安全呢？因为他用的不是同一个锁，一个用Object，一个是用this的锁，我们再改动一下，我们把Object更好为this，这样输出

这里写图片描述

现在就安全，也正确了

好的，我们本篇幅就先到这里了，我们下篇也继续讲线程

如果有兴趣，可以加入群：555974449

文章标签：
Java
安全
小程序
关键词：
Java锁
Java多线程
Java线程
Java Synchronized
Java线程synchronized
刘桂林
目录
相关文章
菜菜的后端私房菜
|
22天前
|
存储 消息中间件 安全
JUC组件实战：实现RRPC(Java与硬件通过MQTT的同步通信)
【10月更文挑战第9天】本文介绍了如何利用JUC组件实现Java服务与硬件通过MQTT的同步通信（RRPC）。通过模拟MQTT通信流程，使用`LinkedBlockingQueue`作为消息队列，详细讲解了消息发送、接收及响应的同步处理机制，包括任务超时处理和内存泄漏的预防措施。文中还提供了具体的类设计和方法实现，帮助理解同步通信的内部工作原理。
菜菜的后端私房菜
23 1
JUC组件实战：实现RRPC(Java与硬件通过MQTT的同步通信)
mikechen的互联网架构
|
8天前
|
Java 调度
Java 线程同步的四种方式，最全详解，建议收藏！
本文详细解析了Java线程同步的四种方式：synchronized关键字、ReentrantLock、原子变量和ThreadLocal，通过实例代码和对比分析，帮助你深入理解线程同步机制。关注【mikechen的互联网架构】，10年+BAT架构经验倾囊相授。
mikechen的互联网架构
21 0
Java 线程同步的四种方式，最全详解，建议收藏！
众所周知
|
14天前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法，探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法，探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法，并分享了最佳实践，帮助开发者避免常见陷阱，提高多线程程序的稳定性和效率。
众所周知
26 1
小王老师呀
|
23天前
|
安全 调度 C#
STA模型、同步上下文和多线程、异步调度
【10月更文挑战第19天】本文介绍了 STA 模型、同步上下文和多线程、异步调度的概念及其优缺点。STA 模型适用于单线程环境，确保资源访问的顺序性；同步上下文和多线程提高了程序的并发性和响应性，但增加了复杂性；异步调度提升了程序的响应性和资源利用率，但也带来了编程复杂性和错误处理的挑战。选择合适的模型需根据具体应用场景和需求进行权衡。
小王老师呀
17 0
john散漫
|
24天前
多线程通信和同步的方式有哪些？
【10月更文挑战第6天】
john散漫
81 0
石小浪♪
|
29天前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念，包括进程和线程的定义、并发的实现方式，以及如何在C++中创建和管理线程，包括使用`std::thread`库、线程的join和detach方法，并通过示例代码展示了如何创建和使用多线程。
石小浪♪
38 1
C++ 多线程之初识多线程
龙大吉
|
14天前
|
Java 开发者
在Java多线程编程中，创建线程的方法有两种：继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中，创建线程的方法有两种：继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱，帮助你更好地理解和选择适合项目需求的线程创建方式。
龙大吉
13 3
东方睿赢
|
14天前
|
Java 开发者
在Java多线程编程中，选择合适的线程创建方法至关重要
【10月更文挑战第20天】在Java多线程编程中，选择合适的线程创建方法至关重要。本文通过案例分析，探讨了继承Thread类和实现Runnable接口两种方法的优缺点及适用场景，帮助开发者做出明智的选择。
东方睿赢
12 2
东方睿赢
|
14天前
|
Java
Java中多线程编程的基本概念和创建线程的两种主要方式：继承Thread类和实现Runnable接口
【10月更文挑战第20天】《JAVA多线程深度解析：线程的创建之路》介绍了Java中多线程编程的基本概念和创建线程的两种主要方式：继承Thread类和实现Runnable接口。文章详细讲解了每种方式的实现方法、优缺点及适用场景，帮助读者更好地理解和掌握多线程编程技术，为复杂任务的高效处理奠定基础。
东方睿赢
27 2
龙大吉
|
14天前
|
Java 开发者
Java多线程初学者指南：介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点
【10月更文挑战第20天】Java多线程初学者指南：介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点，重点解析为何实现Runnable接口更具灵活性、资源共享及易于管理的优势。
龙大吉
26 1

热门文章

最新文章

  • 1
    从Socket数据处理线程想到的普通Winform数据显示的应用
  • 2
    踏破铁鞋无觅处，从AsyncTask学Android线程池
  • 3
    Android--线程详解
  • 4
    使用UncaughtExceptionHandler重启线程
  • 5
    springboot event线程池总结
  • 6
    一个简单的C#多线程间同步的例子
  • 7
    为什么redis是单线程的以及为什么这么快？
  • 8
    Python多线程编程之多线程加锁
  • 9
    多线程程序设计学习（4）guarded suspension模式
  • 10
    Linux多线程5-5_线程与fork
  • 1
    Java容器类List、ArrayList、Vector及map、HashTable、HashMap
    44
  • 2
    Java中数组详解
    79
  • 3
    Java并发设计的7条原则
    77
  • 4
    关于Java异常处理的9条原则
    68
  • 5
    12条通用编程原则✨全面提升Java编码规范性、可读性及性能表现
    98
  • 6
    掌握8条方法设计规则，设计优雅健壮的Java方法
    72
  • 7
    掌握8条泛型规则，打造优雅通用的Java代码
    66
  • 8
    关于创建、销毁对象⭐Java程序员需要掌握的8个编程好习惯
    56
  • 9
    Java内部类
    38
  • 10
    从源码出发：JAVA中对象的比较
    39

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 搭建Java Web开发环境（Anolis OS）
  • RocketMQ中使用Java客户端发送消息和消费的应用
  • 部署基于Dragonwell的Java运行环境
    • 下一篇
    DataWorks智能数据建模全面公测开始啦！