多线程--同步与锁

同步与锁

上一篇中,笔者介绍了Java多线程的基础知识,主要讲解了进程/线程的区别、Java多线程的创建、Java多线程的使用,以及Java多线程的生命周期。

对于多线程,笔者想强调一点的是,多线程的使用并不是为了提高程序的运行速度,而是为了提高程序的运行效率,让CPU的使用率更高,让资源得到更合理的安排。

如果你对上述的知识点,还不了解,那笔者建议还是先从多线程--基础入手,再来学习本篇文章。

今天,我们来继续学习Java多线程的内容---同步与锁。

线程安全

多线程的使用,让CPU得到了更充分的释放,让程序有了更高的执行效率,说直白点这叫释放天性。但是,多线程在使用的同时,也带来了一些烦恼和麻烦。俗话说的好,世界上任何事物都包含有利的一面和不利的一面,事物的两面性。

对于多线程来说,也遵循同样的道理,而不好的一面就是安全问题。

(1)什么是线程的安全问题?

(2)什么情况下会导致线程的安全问题?

解决问题之前,我们需要知道上面两个问题的答案。

问题一:

一个线程从开始执行到执行结束的过程,如果在执行过程中有一个对象的变量被其他线程锁修改,那么对于当前线程来说,就发生了线程安全问题。如果每次运行结果和单线程运行的结果不一致,那么就会产生线程安全问题。 

问题二:

运行多线程环境;

多线程中存在共享变量;

多线程中操作共享变量,主要操作行为--写操作;

我们都知道,CPU在任何一个时间点上都只会操作一个线程,我们感受到多个程序同时执行的情况,只不过是CPU模拟出来的结果,由于CPU处理的速度很快,在一秒中内CPU可以执行很多指令,处理很多线程,所以我们误认为是CPU在同时执行。

当一个线程在被执行时,不巧的是CPU在切换时,把执行权切换到了另一条线程上,处理了另外一个线程的请求,而另外的线程对共享数据做了改变。当CPU再次切换回原有的线程上时,共享的数据已被改变,数据安全问题由此诞生。

我们举个简单例子,来验证:

//卖票的例子:
public class ThreadTest9 implements Runnable {

    //可售总数量 100张:
    private Integer count = 100;

    @Override
    public void run() {
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        while(true) {
            //如果大于0,就进行卖票
            if(count>0) {
                System.out.println(Thread.currentThread().getName()+"正在售票,剩余票数:"+ count--);
                continue;
            }
            System.out.println(Thread.currentThread().getName()+"票源不足,此时可售票数为:"+ count);
            break;
        }
    }

    public static void main(String[] agrs){
        ThreadTest9 ticket = new ThreadTest9();
        //开启4个窗口来卖票
        new Thread(ticket,"窗口1").start();
        new Thread(ticket,"窗口2").start();
        new Thread(ticket,"窗口3").start();
        new Thread(ticket,"窗口4").start();
    }
}

测试结果:

窗口3正在售票,剩余票数:100
窗口4正在售票,剩余票数:100
窗口2正在售票,剩余票数:100
窗口1正在售票,剩余票数:99
窗口2正在售票,剩余票数:98
。。。。。。。。。。。。。。。省略   
窗口2正在售票,剩余票数:8
窗口3正在售票,剩余票数:7
窗口1正在售票,剩余票数:6
窗口4正在售票,剩余票数:7
窗口2正在售票,剩余票数:5
窗口4正在售票,剩余票数:4
窗口4正在售票,剩余票数:1
窗口4票源不足,此时可售票数为:0
窗口2正在售票,剩余票数:44
窗口3正在售票,剩余票数:98
窗口2票源不足,此时可售票数为:-1
窗口1正在售票,剩余票数:0
窗口1票源不足,此时可售票数为:-1
窗口3票源不足,此时可售票数为:-1

在run()方法中,加入Thread.sleep(10)的主要目的是为了让四个线程都能得到执行。

通过测试结果,可以看到不同的窗口卖了相同的票,而在可售票源为0时,依旧有线程在做--操作。

如何解决线程的安全问题?

消除共享数据:在多线程中,不同线程间可共享的数据包括“成员变量、静态变量”,将这两种类型的变量转换为局部变量,那么线程安全问题自然就解决了。

建立副本:使用ThreadLocal为每一个线程建立一个变量的副本,将共享变量存入到ThreadLocal当中,这样以来实现每个线程间独立操作,算是上面解决方案的一种升华。

使用同步:在线程执行逻辑中,给读写共享变量的操作同时加锁处理,使得同一时刻只有一个线程可以操作访问共享数据。

下面,就主要来讲解下加锁处理线程安全!!!

解决线程的安全问题,主要是通过加锁来处理,加锁的目的就是为了保证一个线程在操作共享变量时,如果没执行完,那其他线程不能执行。简单点说就是一个线程在执行,其他线程给我等着,我不执行完,你们靠边呆着去。

在Java中,主要有三种方式来进行加锁,以来保证线程的安全:

同步方法:在类中的方法上加synchronized修饰符;

public synchronized void test(){
    //代码逻辑  
}  

同步方法中的锁是:this,即调用者本身;

静态同步方法: 在类中的静态方法上加synchronized

public static synchronized void test(){
    //代码逻辑  
}

静态同步方法中的锁是:类名.class,即Class对象;

同步代码块:在需要同步的代码上写一个synchronized(Object obj){}代码块;

synchronized(Object o){
    //代码逻辑
} 

同步代码块中的锁是:任意对象;

接下来,我们通过加锁的方式,再进行卖票:

//卖票的例子:
public class ThreadTest9 implements Runnable {

    //可售总数量 100张:
    private Integer count = 100;

    @Override
    public void run() {
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        while(true) {
            //如果大于0,就进行卖票
            if(count>0) {
                synchronized (this) {
                    if(count>0){
                        System.out.println(Thread.currentThread().getName() + "正在售票,剩余票数:" + count--);
                        continue;
                    }
                }
            }
            System.out.println(Thread.currentThread().getName()+"票源不足,此时可售票数为:"+ count);
            break;
        }
    }

    public static void main(String[] agrs){
        ThreadTest9 ticket = new ThreadTest9();
        new Thread(ticket,"窗口1").start();
        new Thread(ticket,"窗口2").start();
        new Thread(ticket,"窗口3").start();
        new Thread(ticket,"窗口4").start();
    }
}

测试结果:

窗口2正在售票,剩余票数:100
窗口2正在售票,剩余票数:99
窗口1正在售票,剩余票数:98
窗口1正在售票,剩余票数:97
窗口3正在售票,剩余票数:96
窗口4正在售票,剩余票数:95
。。。。。。。。。。。。。。省略
窗口2正在售票,剩余票数:4
窗口2正在售票,剩余票数:3
窗口1正在售票,剩余票数:2
窗口4正在售票,剩余票数:1
窗口4票源不足,此时可售票数为:0
窗口1票源不足,此时可售票数为:0
窗口3票源不足,此时可售票数为:0
窗口2票源不足,此时可售票数为:0

synchronized的使用,解决了线程的安全问题,但是随着而来的是程序性能的下降。正所谓,事物的两面性。

单例设计模式

本文的最高,我们来说下面试中常见的一个问题:写一个性能安全的单例。

不安全的单例:

public class ThreadTest10 {
    private static ThreadTest10 single;
    private ThreadTest10(){}
    //懒汉:
    public static ThreadTest10 getInstance(){
        if(single==null){
            single = new ThreadTest10();
        }
        return single;
    }
}

安全的单例:

//无锁版:
public class ThreadTest11 {
    private static ThreadTest11 single = new ThreadTest11();
    private ThreadTest11(){}
    public static ThreadTest11 getInstance(){
        return single;
    }
}

//加锁版:
public class ThreadTest13 {
    //创建一把锁
    private static Object obj = new Object();

    private static ThreadTest13 threadTest13;

    private ThreadTest13(){}

    public static ThreadTest13 getInstance(){
        if(threadTest13==null){
            synchronized (obj){
                //双判断:
                if(threadTest13==null){
                    threadTest13 = new ThreadTest13();
                }
            }
        }
        return threadTest13;
    }
}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏逆向技术

win32线程

3.单核CPU可以实现多线程. 几秒钟换一次线程执行不同进程的代码.就实现了多线程.

521
来自专栏java相关

线程安全问题分析

计算机系统资源分配的单位为进程,同一个进程中允许多个线程并发执行,并且多个线程会共享进程范围内的资源:例如内存地址。当多个线程并发访问同一个内存地址并且内存地址...

652
来自专栏用户2442861的专栏

在QT中处理windows消息

http://blog.csdn.net/sryan/article/details/6744070

441
来自专栏GIS讲堂

Openlayers4+servlet实现切片的本地缓存

本文实现的是结合Openlayers4和java servlet实现公网资源切片的本地缓存。

613
来自专栏DOTNET

.Net多线程编程—Parallel LINQ、线程池

Parallel LINQ 1 System.Linq.ParallelEnumerable 重要方法概览: 1)public static ParallelQ...

2797
来自专栏大内老A

关于CLR内存管理一些深层次的讨论[上篇]

半年之前,PM让我在部门内部进行一次关于“内存泄露”的专题分享,我为此准备了一份PPT。今天无意中将其翻出来,觉得里面提到的关于CLR下关于内存管理部分的内存还...

1658
来自专栏Spring相关

第11章—使用对象关系映射持久化数据—SpringBoot+SpringData+Jpa进行查询修改数据库

JPA由EJB 3.0软件专家组开发,作为JSR-220实现的一部分。但它又不限于EJB 3.0,你可以在Web应用、甚至桌面应用中使用。JPA的宗旨是为POJ...

693
来自专栏从零开始学自动化测试

python笔记7-多线程threading

前言 1.python环境2.7 2.threading模块系统自带 一、 单线程 1.平常写的代码都是按顺序挨个执行的,就好比吃火锅和哼小曲这两个行为事件,定...

2957
来自专栏余林丰

MyBatis之TypeHandler

  在大学写web应用的时候经常会遇到这么个问题,当我要插入一条数据,某个数据是Date类型,数据库中却是VARCHAR类型,这个时候可能会傻乎乎的先把这个数据...

2397
来自专栏Android机动车

我的图片四级缓存框架

开发App一定涉及到图片加载、图片处理,那就必须会用到三方的图片框架,要么选择自己封装。至于主流的三方图片框架,就不得不说老牌的ImageLoader、如今更流...

873

扫码关注云+社区