热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

深入解析Java多线程同步机制与应用

本文深入探讨了Java多线程环境下的同步机制及其应用,重点介绍了`synchronized`关键字的使用方法和原理。`synchronized`关键字主要用于确保多个线程在访问共享资源时的互斥性和原子性。通过具体示例,如在一个类中使用`synchronized`修饰方法,展示了如何实现线程安全的代码块。此外,文章还讨论了`ReentrantLock`等其他同步工具的优缺点,并提供了实际应用场景中的最佳实践。

synchronized关键字介绍:

synchronized锁定的是对象,这个很重要

例子:

class Sync {  

    public synchronized void test() {  
        System.out.println("test开始..");  
        try {  
            Thread.sleep(1000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("test结束..");  
    }  
}  

class MyThread extends Thread {  

    public void run() {  
        Sync sync = new Sync();  
        sync.test();  
    }  
}  

public class Main {  

    public static void main(String[] args) {  
        for (int i = 0; i <3; i++) {  
            Thread thread = new MyThread();  
            thread.start();  
        }  
    }  
}  
运行结果:
test开始..
test开始..
test开始..
test结束..
test结束..
test结束..

可以看出来,上面的程序起了三个线程,同时运行Sync类中的test()方法,虽然test()方法加上了synchronized,但是还是同时运行起来,貌似synchronized没起作用。

将test()方法上的synchronized去掉,在方法内部加上synchronized(this):



[java] view plain copy 在CODE上查看代码片派生到我的代码片
public void test() {  
    synchronized(this){  
        System.out.println("test开始..");  
        try {  
            Thread.sleep(1000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("test结束..");  
    }  
}  
运行结果:
test开始..
test开始..
test开始..
test结束..
test结束..
test结束..

一切还是这么平静,没有看到synchronized起到作用。 

实际上,synchronized(this)以及非static的synchronized方法(至于static synchronized方法请往下看),只能防止多个线程同时执行同一个对象的同步代码段。

synchronized锁住的是括号里的对象,而不是代码。对于非static的synchronized方法,锁的就是对象本身也就是this。

当synchronized锁住一个对象后,别的线程如果也想拿到这个对象的锁,就必须等待这个线程执行完成释放锁,才能再次给对象加锁,这样才达到线程同步的目的。即使两个不同的代码段,都要锁同一个对象,那么这两个代码段也不能在多线程环境下同时运行。

让synchronized锁这个类对应的Class对象。
class Sync {  

    public void test() {  
        synchronized (Sync.class) {  
            System.out.println("test开始..");  
            try {  
                Thread.sleep(1000);  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
            System.out.println("test结束..");  
        }  
    }  
}  

class MyThread extends Thread {  

    public void run() {  
        Sync sync = new Sync();  
        sync.test();  
    }  
}  

public class Main {  

    public static void main(String[] args) {  
        for (int i = 0; i <3; i++) {  
            Thread thread = new MyThread();  
            thread.start();  
        }  
    }  
}  
运行结果:
test开始..
test结束..
test开始..
test结束..
test开始..
test结束..

上面代码用synchronized(Sync.class)实现了全局锁的效果。

tatic方法可以直接类名加方法名调用,方法中无法使用this,所以它锁的不是this,而是类的Class对象,所以,static synchronized方法也相当于全局锁,相当于锁住了代码段。

分类解释:

synchronized方法

① synchronized方法表面上它只是锁定了当前的方法本身,实际上当synchronized方法起作用的时候,整个对象的带有synchronized的方法都将被锁定,这也就是为什么当一个线程执行一个synchronized方法时,其他的线程除了不能访问当前的同步方法外还并不能访问其他的同步方法,而只能访问非synchronized方法,因为这种锁定是对象级别的。
② 如使在静态方法中用synchronized时,因为这个方法就不是仅属于某个对象而是属于整个类的了,所以一旦一个线程进入了这个代码块就会将这个类的所有对象的所有synchronized方法或synchronized同步代码块锁定,其他的线程就没有办法访问所有这些对象的synchronized方法和synchronized代码块(注意其他线程还是仍然能访问这些对象的非synchronized方法和synchronized代码块的),因此这种锁定是class级别的。

2.synchronized同步代码块是对一个对象作为参数进行锁定。

① 如在使用synchronized(this)时,一旦一个线程进入了这个代码块就会将整个对象的所有synchronized方法或synchronized同步代码块锁定,其他的线程就没有办法访问这个对象的synchronized方法和synchronized代码块(注意其他线程还是仍然能访问这个对象的非synchronized方法和synchronized代码块的)。
② 如在使用synchronized(.class)时,一旦一个线程进入了这个代码块就会将整个类的所有这个synchronized(.class) 同步代码块锁定,其他的线程就没有办法访问这个对象的synchronized(**.class) 代码块,这种锁也是class级别的,但要注意在这种情况下,其他线程仍然是可以访问仅做了synchronized的代码块或非静态方法的,因为它们仅仅是对当前对象的锁定。

正式开始介绍多线程同步:

(1)同步方法:

即有synchronized关键字修饰的方法。 由于java的每个对象都有一个内置锁,当用此关键字修饰方法时,内置锁会保护整个方法。在调用该方法前,需要获得内置锁,否则就处于阻塞状态。


修改后的Bank.java

package threadTest;  

/** 
 * @author ww 
 * 
 */  
public class Bank {  

    private int count =0;//账户余额  

    //存钱  
    public  synchronized void addMoney(int money){  
        count +=money;  
        System.out.println(System.currentTimeMillis()+"存进:"+money);  
    }  

    //取钱  
    public  synchronized void subMoney(int money){  
        if(count-money <0){  
            System.out.println("余额不足");  
            return;  
        }  
        count -=money;  
        System.out.println(+System.currentTimeMillis()+"取出:"+money);  
    }  

    //查询  
    public void lookMoney(){  
        System.out.println("账户余额:"+count);  
    }  
}
再看看运行结果:

余额不足  
账户余额:0  

余额不足  
账户余额:0  

1441790837380存进:100  
账户余额:100  

1441790838380取出:100  
账户余额:0  
1441790838380存进:100  
账户余额:100  

1441790839381取出:100  
账户余额:0
瞬间感觉可以理解了吧。

注: synchronized关键字也可以修饰静态方法,此时如果调用该静态方法,
将会锁住整个类

(2)同步代码块
即有synchronized关键字修饰的语句块。被该关键字修饰的语句块会自动被加上内置锁,从而实现同步

Bank.java代码如下:

package threadTest;  

/** 
 * @author ww 
 * 
 */  
public class Bank {  

    private int count =0;//账户余额  

    //存钱  
    public   void addMoney(int money){  

        synchronized (this) {  
            count +=money;  
        }  
        System.out.println(System.currentTimeMillis()+"存进:"+money);  
    }  

    //取钱  
    public   void subMoney(int money){  

        synchronized (this) {  
            if(count-money <0){  
                System.out.println("余额不足");  
                return;  
            }  
            count -=money;  
        }  
        System.out.println(+System.currentTimeMillis()+"取出:"+money);  
    }  

    //查询  
    public void lookMoney(){  
        System.out.println("账户余额:"+count);  
    }  
}
运行结果如下:

余额不足  
账户余额:0  

1441791806699存进:100  
账户余额:100  

1441791806700取出:100  
账户余额:0  

1441791807699存进:100  
账户余额:100
效果和方法一差不多。

注:同步是一种高开销的操作,因此应该尽量减少同步的内容。通常没有必要同步整个方法,使用synchronized代码块同步关键代码即可。

(3)使用特殊域变量(Volatile)实现线程同步
a.volatile关键字为域变量的访问提供了一种免锁机制
b.使用volatile修饰域相当于告诉虚拟机该域可能会被其他线程更新
c.因此每次使用该域就要重新计算,而不是使用寄存器中的值
d.volatile不会提供任何原子操作,它也不能用来修饰final类型的变量

Bank.java代码如下:

package threadTest;  

/** 
 * @author ww 
 * 
 */  
public class Bank {  

    private volatile int count = 0;// 账户余额  

    // 存钱  
    public void addMoney(int money) {  

        count += money;  
        System.out.println(System.currentTimeMillis() + "存进:" + money);  
    }  

    // 取钱  
    public void subMoney(int money) {  

        if (count - money <0) {  
            System.out.println("余额不足");  
            return;  
        }  
        count -= money;  
        System.out.println(+System.currentTimeMillis() + "取出:" + money);  
    }  

    // 查询  
    public void lookMoney() {  
        System.out.println("账户余额:" + count);  
    }  
}
运行效果怎样呢?

余额不足  
账户余额:0  

余额不足  
账户余额:100  

1441792010959存进:100  
账户余额:100  

1441792011960取出:100  
账户余额:0  

1441792011961存进:100  
账户余额:100

就是因为volatile不能保证原子操作导致的,因此volatile不能代替synchronized。此外volatile会组织编译器对代码优化,因此能不使用它就不适用它吧。它的原理是每次要线程要访问volatile修饰的变量时都是从内存中读取,而不是存缓存当中读取,因此每个线程访问到的变量值都是一样的。这样就保证了同步。

(4)使用重入锁实现线程同步

在JavaSE5.0中新增了一个java.util.concurrent包来支持同步。ReentrantLock类是可重入、互斥、实现了Lock接口的锁, 它与使用synchronized方法和快具有相同的基本行为和语义,并且扩展了其能力。
ReenreantLock类的常用方法有:
ReentrantLock() : 创建一个ReentrantLock实例
lock() : 获得锁
unlock() : 释放锁
注:ReentrantLock()还有一个可以创建公平锁的构造方法,但由于能大幅度降低程序运行效率,不推荐使用
Bank.java代码修改如下:



package threadTest;  

import java.util.concurrent.locks.Lock;  
import java.util.concurrent.locks.ReentrantLock;  

/** 
 * @author ww 
 * 
 */  
public class Bank {  

    private  int count = 0;// 账户余额  

    //需要声明这个锁  
    private Lock lock = new ReentrantLock();  

    // 存钱  
    public void addMoney(int money) {  
        lock.lock();//上锁  
        try{  
        count += money;  
        System.out.println(System.currentTimeMillis() + "存进:" + money);  

        }finally{  
            lock.unlock();//解锁  
        }  
    }  

     // 取钱  
    public void subMoney(int money) {  
        lock.lock();  
        try{  

        if (count - money <0) {  
            System.out.println("余额不足");  
            return;  
        }  
        count -= money;  
        System.out.println(+System.currentTimeMillis() + "取出:" + money);  
        }finally{  
            lock.unlock();  
        }  
    }  

    // 查询  
    public void lookMoney() {  
        System.out.println("账户余额:" + count);  
    }  
}
 余额不足  
账户余额:0  

余额不足  
账户余额:0  

1441792891934存进:100  
账户余额:100  

1441792892935存进:100  
账户余额:200  

1441792892954取出:100  
账户余额:100
效果和前两种方法差不多。

如果synchronized关键字能满足用户的需求,就用synchronized,因为它能简化代码 。如果需要更高级的功能,就用ReentrantLock类,此时要注意及时释放锁,否则会出现死锁,通常在finally代码释放锁

(5)使用局部变量实现线程同步
package threadTest;  

/** 
 * @author ww 
 * 
 */  
public class Bank {  

    private static ThreadLocal count = new ThreadLocal(){  

        @Override  
        protected Integer initialValue() {  
            // TODO Auto-generated method stub  
            return 0;  
        }  

    };  

    // 存钱  
    public void addMoney(int money) {  
        count.set(count.get()+money);  
        System.out.println(System.currentTimeMillis() + "存进:" + money);  

    }  

    // 取钱  
    public void subMoney(int money) {  
        if (count.get() - money <0) {  
            System.out.println("余额不足");  
            return;  
        }  
        count.set(count.get()- money);  
        System.out.println(+System.currentTimeMillis() + "取出:" + money);  
    }  

    // 查询  
    public void lookMoney() {  
        System.out.println("账户余额:" + count.get());  
    }  
}
运行效果:

余额不足  
账户余额:0  

余额不足  
账户余额:0  

1441794247939存进:100  
账户余额:100  

余额不足  
1441794248940存进:100  
账户余额:0  

账户余额:200  

余额不足  
账户余额:0  

1441794249941存进:100  
账户余额:300

如果使用ThreadLocal管理变量,则每一个使用该变量的线程都获得该变量的副本,副本之间相互独立,这样每一个线程都可以随意修改自己的变量副本,而不会对其他线程产生影响。现在明白了吧,原来每个线程运行的都是一个副本,也就是说存钱和取钱是两个账户,知识名字相同而已。所以就会发生上面的效果。

ThreadLocal与同步机制

a.ThreadLocal与同步机制都是为了解决多线程中相同变量的访问冲突问题
b.前者采用以”空间换时间”的方法,后者采用以”时间换空间”的方式

欢迎入群:

公众号IT面试题汇总讨论群

技术分享

如果扫描不进去,加我微信(rdst6029930)拉你。

扫我微信二维码加我

技术分享

欢迎关注《IT面试题汇总》微信订阅号。每天推送经典面试题和面试心得技巧,都是干货!

微信订阅号二维码如下:

技术分享

参考:
https://segmentfault.com/a/1190000003810166
http://blog.csdn.net/xiao__gui/article/details/8188833
http://www.codeceo.com/article/java-multi-thread-sync.html

【53】java的多线程同步剖析


推荐阅读
  • 本文深入解析了Java面向对象编程的核心概念及其应用,重点探讨了面向对象的三大特性:封装、继承和多态。封装确保了数据的安全性和代码的可维护性;继承支持代码的重用和扩展;多态则增强了程序的灵活性和可扩展性。通过具体示例,文章详细阐述了这些特性在实际开发中的应用和优势。 ... [详细]
  • 在探讨Hibernate框架的高级特性时,缓存机制和懒加载策略是提升数据操作效率的关键要素。缓存策略能够显著减少数据库访问次数,从而提高应用性能,特别是在处理频繁访问的数据时。Hibernate提供了多层次的缓存支持,包括一级缓存和二级缓存,以满足不同场景下的需求。懒加载策略则通过按需加载关联对象,进一步优化了资源利用和响应时间。本文将深入分析这些机制的实现原理及其最佳实践。 ... [详细]
  • 作为软件工程专业的学生,我深知课堂上教师讲解速度之快,很多时候需要课后自行消化和巩固。因此,撰写这篇Java Web开发入门教程,旨在帮助初学者更好地理解和掌握基础知识。通过详细记录学习过程,希望能为更多像我一样在基础方面还有待提升的学员提供有益的参考。 ... [详细]
  • NOIP2000的单词接龙问题与常见的成语接龙游戏有异曲同工之妙。题目要求在给定的一组单词中,从指定的起始字母开始,构建最长的“单词链”。每个单词在链中最多可出现两次。本文将详细解析该题目的解法,并分享学习过程中的心得体会。 ... [详细]
  • 在Android平台上,视频监控系统的优化与应用具有重要意义。尽管已有相关示例(如http:www.open-open.comlibviewopen1346400423609.html)展示了基本的监控功能实现,但若要提升系统的稳定性和性能,仍需进行深入研究和优化。本文探讨了如何通过改进算法、优化网络传输和增强用户界面来提高Android视频监控系统的整体效能,以满足更复杂的应用需求。 ... [详细]
  • 单链表的高效遍历及性能优化策略
    本文探讨了单链表的高效遍历方法及其性能优化策略。在单链表的数据结构中,插入操作的时间复杂度为O(n),而遍历操作的时间复杂度为O(n^2)。通过在 `LinkList.h` 和 `main.cpp` 文件中对单链表进行封装,我们实现了创建和销毁功能的优化,提高了单链表的使用效率。此外,文章还介绍了几种常见的优化技术,如缓存节点指针和批量处理,以进一步提升遍历性能。 ... [详细]
  • 初探性能优化:入门指南与实践技巧
    在编程领域,常有“尚未精通编码便急于优化”的声音。为了从性能优化的角度提升代码质量,本文将带领读者初步探索性能优化的基本概念与实践技巧。即使程序看似运行良好,数据处理效率仍有待提高,通过系统学习性能优化,能够帮助开发者编写更加高效、稳定的代码。文章不仅介绍了性能优化的基础知识,还提供了实用的调优方法和工具,帮助读者在实际项目中应用这些技术。 ... [详细]
  • ButterKnife 是一款用于 Android 开发的注解库,主要用于简化视图和事件绑定。本文详细介绍了 ButterKnife 的基础用法,包括如何通过注解实现字段和方法的绑定,以及在实际项目中的应用示例。此外,文章还提到了截至 2016 年 4 月 29 日,ButterKnife 的最新版本为 8.0.1,为开发者提供了最新的功能和性能优化。 ... [详细]
  • 本文详细介绍了使用 Python 进行 MySQL 和 Redis 数据库操作的实战技巧。首先,针对 MySQL 数据库,通过 `pymysql` 模块展示了如何连接和操作数据库,包括建立连接、执行查询和更新等常见操作。接着,文章深入探讨了 Redis 的基本命令和高级功能,如键值存储、列表操作和事务处理。此外,还提供了多个实际案例,帮助读者更好地理解和应用这些技术。 ... [详细]
  • 近期,针对Axis2默认凭据漏洞的攻击案例在安全社区引起了广泛关注。这些攻击通常利用Axis2的默认用户名和密码进行渗透测试,技术手段相对固定。本文在综合分析多个案例的基础上,详细探讨了该漏洞的安全风险,并提出了有效的防范措施,以帮助企业和开发者加强Web服务的安全防护。 ... [详细]
  • 在 CentOS 6.5 系统上部署 VNC 服务器的详细步骤与配置指南
    在 CentOS 6.5 系统上部署 VNC 服务器时,首先需要确认 VNC 服务是否已安装。通常情况下,VNC 服务默认未安装。可以通过运行特定的查询命令来检查其安装状态。如果查询结果为空,则表明 VNC 服务尚未安装,需进行手动安装。此外,建议在安装前确保系统的软件包管理器已更新至最新版本,以避免兼容性问题。 ... [详细]
  • Java环境中Selenium Chrome驱动在大规模Web应用扩展时的性能限制分析 ... [详细]
  • C# .NET 4.1 版本大型信息化系统集成平台中的主从表事务处理标准示例
    在C# .NET 4.1版本的大型信息化系统集成平台中,本文详细介绍了主从表事务处理的标准示例。通过确保所有操作要么全部成功,要么全部失败,实现主表和关联子表的同步插入。主表插入时会返回当前生成的主键,该主键随后用于子表插入时的关联。以下是一个示例代码片段,展示了如何在一个数据库事务中同时添加角色和相关用户。 ... [详细]
  • iOS 设备唯一标识获取的高效解决方案与实践
    在iOS 7中,苹果公司再次禁止了对MAC地址的访问,使得开发者无法直接获取设备的物理地址。为了在开发过程中实现设备的唯一标识,苹果推荐使用Keychain服务来存储和管理唯一的标识符。此外,还可以结合其他技术手段,如UUID和广告标识符(IDFA),以确保设备的唯一性和安全性。这些方法不仅能够满足应用的需求,还能保护用户的隐私。 ... [详细]
  • 提升Android开发效率:Clean Code的最佳实践与应用
    在Android开发中,提高代码质量和开发效率是至关重要的。本文介绍了如何通过Clean Code的最佳实践来优化Android应用的开发流程。以SQLite数据库操作为例,详细探讨了如何编写高效、可维护的SQL查询语句,并将其结果封装为Java对象。通过遵循这些最佳实践,开发者可以显著提升代码的可读性和可维护性,从而加快开发速度并减少错误。 ... [详细]
author-avatar
太2真人05
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有