博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java多线程系列--“基础篇”04之 synchronized关键字
阅读量:6589 次
发布时间:2019-06-24

本文共 11135 字,大约阅读时间需要 37 分钟。

hot3.png

概要

本章,会对synchronized关键字进行介绍。涉及到的内容包括:

转载请注明出处:

1. synchronized原理

在java中,每一个对象有且仅有一个同步锁。这也意味着,同步锁是依赖于对象而存在

当我们调用某对象的synchronized方法时,就获取了该对象的同步锁。例如,synchronized(obj)就获取了“obj这个对象”的同步锁。
不同线程对同步锁的访问是互斥的。也就是说,某时间点,对象的同步锁只能被一个线程获取到!通过同步锁,我们就能在多线程中,实现对“对象/方法”的互斥访问。 例如,现在有两个线程A和线程B,它们都会访问“对象obj的同步锁”。假设,在某一时刻,线程A获取到“obj的同步锁”并在执行一些操作;而此时,线程B也企图获取“obj的同步锁” —— 线程B会获取失败,它必须等待,直到线程A释放了“该对象的同步锁”之后线程B才能获取到“obj的同步锁”从而才可以运行。

2. synchronized基本规则

我们将synchronized的基本规则总结为下面3条,并通过实例对它们进行说明。

: 当一个线程访问“某对象”的“synchronized方法”或者“synchronized代码块”时,其他线程对“该对象”的该“synchronized方法”或者“synchronized代码块”的访问将被阻塞。
第二条: 当一个线程访问“某对象”的“synchronized方法”或者“synchronized代码块”时,其他线程仍然可以访问“该对象”的非同步代码块
第三条: 当一个线程访问“某对象”的“synchronized方法”或者“synchronized代码块”时,其他线程对“该对象”的其他的“synchronized方法”或者“synchronized代码块”的访问将被阻塞。

第一条

当一个线程访问“某对象”的“synchronized方法”或者“synchronized代码块”时,其他线程对“该对象”的该“synchronized方法”或者“synchronized代码块”的访问将被阻塞。

下面是“synchronized代码块”对应的演示程序。

class MyRunable implements Runnable {        @Override    public void run() {        synchronized(this) {            try {                  for (int i = 0; i < 5; i++) {                    Thread.sleep(100); // 休眠100ms                    System.out.println(Thread.currentThread().getName() + " loop " + i);                  }            } catch (InterruptedException ie) {              }        }      }}public class Demo1_1 {    public static void main(String[] args) {          Runnable demo = new MyRunable();     // 新建“Runnable对象”        Thread t1 = new Thread(demo, "t1");  // 新建“线程t1”, t1是基于demo这个Runnable对象        Thread t2 = new Thread(demo, "t2");  // 新建“线程t2”, t2是基于demo这个Runnable对象        t1.start();                          // 启动“线程t1”        t2.start();                          // 启动“线程t2”     } }

运行结果

t1 loop 0t1 loop 1t1 loop 2t1 loop 3t1 loop 4t2 loop 0t2 loop 1t2 loop 2t2 loop 3t2 loop 4

结果说明

run()方法中存在“synchronized(this)代码块”,而且t1和t2都是基于"demo这个Runnable对象"创建的线程。这就意味着,我们可以将synchronized(this)中的this看作是“demo这个Runnable对象”;因此,线程t1和t2共享“demo对象的同步锁”。所以,当一个线程运行的时候,另外一个线程必须等待“运行线程”释放“demo的同步锁”之后才能运行。

如果你确认,你搞清楚这个问题了。那我们将上面的代码进行修改,然后再运行看看结果怎么样,看看你是否会迷糊。修改后的源码如下:

class MyThread extends Thread {        public MyThread(String name) {        super(name);    }    @Override    public void run() {        synchronized(this) {            try {                  for (int i = 0; i < 5; i++) {                    Thread.sleep(100); // 休眠100ms                    System.out.println(Thread.currentThread().getName() + " loop " + i);                  }            } catch (InterruptedException ie) {              }        }      }}public class Demo1_2 {    public static void main(String[] args) {          Thread t1 = new MyThread("t1");  // 新建“线程t1”        Thread t2 = new MyThread("t2");  // 新建“线程t2”        t1.start();                          // 启动“线程t1”        t2.start();                          // 启动“线程t2”     } }

代码说明

比较Demo1_2 和 Demo1_1,我们发现,Demo1_2中的MyThread类是直接继承于Thread,而且t1和t2都是MyThread子线程。
幸运的是,在“Demo1_2的run()方法”也调用了synchronized(this),正如“Demo1_1的run()方法”也调用了synchronized(this)一样!
那么,Demo1_2的执行流程是不是和Demo1_1一样呢?
运行结果:

t1 loop 0t2 loop 0t1 loop 1t2 loop 1t1 loop 2t2 loop 2t1 loop 3t2 loop 3t1 loop 4t2 loop 4

结果说明

如果这个结果一点也不令你感到惊讶,那么我相信你对synchronized和this的认识已经比较深刻了。否则的话,请继续阅读这里的分析。
synchronized(this)中的this是指“当前的类对象”,即synchronized(this)所在的类对应的当前对象。它的作用是获取“当前对象的同步锁”。
对于Demo1_2中,synchronized(this)中的this代表的是MyThread对象,而t1和t2是两个不同的MyThread对象,因此t1和t2在执行synchronized(this)时,获取的是不同对象的同步锁。对于Demo1_1对而言,synchronized(this)中的this代表的是MyRunable对象;t1和t2共同一个MyRunable对象,因此,一个线程获取了对象的同步锁,会造成另外一个线程等待。

第二条

当一个线程访问“某对象”的“synchronized方法”或者“synchronized代码块”时,其他线程仍然可以访问“该对象”的非同步代码块。

下面是“synchronized代码块”对应的演示程序。

class Count {    // 含有synchronized同步块的方法    public void synMethod() {        synchronized(this) {            try {                  for (int i = 0; i < 5; i++) {                    Thread.sleep(100); // 休眠100ms                    System.out.println(Thread.currentThread().getName() + " synMethod loop " + i);                  }            } catch (InterruptedException ie) {              }        }      }    // 非同步的方法    public void nonSynMethod() {        try {              for (int i = 0; i < 5; i++) {                Thread.sleep(100);                System.out.println(Thread.currentThread().getName() + " nonSynMethod loop " + i);              }        } catch (InterruptedException ie) {          }    }}public class Demo2 {    public static void main(String[] args) {          final Count count = new Count();        // 新建t1, t1会调用“count对象”的synMethod()方法        Thread t1 = new Thread(                new Runnable() {                    @Override                    public void run() {                        count.synMethod();                    }                }, "t1");        // 新建t2, t2会调用“count对象”的nonSynMethod()方法        Thread t2 = new Thread(                new Runnable() {                    @Override                    public void run() {                        count.nonSynMethod();                    }                }, "t2");          t1.start();  // 启动t1        t2.start();  // 启动t2    } }
t1 synMethod loop 0t2 nonSynMethod loop 0t1 synMethod loop 1t2 nonSynMethod loop 1t1 synMethod loop 2t2 nonSynMethod loop 2t1 synMethod loop 3t2 nonSynMethod loop 3t1 synMethod loop 4t2 nonSynMethod loop 4

结果说明

主线程中新建了两个子线程t1和t2。t1会调用count对象的synMethod()方法,该方法内含有同步块;而t2则会调用count对象的nonSynMethod()方法,该方法不是同步方法。t1运行时,虽然调用synchronized(this)获取“count的同步锁”;但是并没有造成t2的阻塞,因为t2没有用到“count”同步锁。

第三条

当一个线程访问“某对象”的“synchronized方法”或者“synchronized代码块”时,其他线程对“该对象”的其他的“synchronized方法”或者“synchronized代码块”的访问将被阻塞。

我们将上面的例子中的nonSynMethod()方法体的也用synchronized(this)修饰。修改后的源码如下:

class Count {    // 含有synchronized同步块的方法    public void synMethod() {        synchronized(this) {            try {                  for (int i = 0; i < 5; i++) {                    Thread.sleep(100); // 休眠100ms                    System.out.println(Thread.currentThread().getName() + " synMethod loop " + i);                  }            } catch (InterruptedException ie) {              }        }      }    // 也包含synchronized同步块的方法    public void nonSynMethod() {        synchronized(this) {            try {                  for (int i = 0; i < 5; i++) {                    Thread.sleep(100);                    System.out.println(Thread.currentThread().getName() + " nonSynMethod loop " + i);                  }            } catch (InterruptedException ie) {              }        }    }}public class Demo3 {    public static void main(String[] args) {          final Count count = new Count();        // 新建t1, t1会调用“count对象”的synMethod()方法        Thread t1 = new Thread(                new Runnable() {                    @Override                    public void run() {                        count.synMethod();                    }                }, "t1");        // 新建t2, t2会调用“count对象”的nonSynMethod()方法        Thread t2 = new Thread(                new Runnable() {                    @Override                    public void run() {                        count.nonSynMethod();                    }                }, "t2");          t1.start();  // 启动t1        t2.start();  // 启动t2    } }

运行结果

t1 synMethod loop 0t1 synMethod loop 1t1 synMethod loop 2t1 synMethod loop 3t1 synMethod loop 4t2 nonSynMethod loop 0t2 nonSynMethod loop 1t2 nonSynMethod loop 2t2 nonSynMethod loop 3t2 nonSynMethod loop 4

结果说明

主线程中新建了两个子线程t1和t2。t1和t2运行时都调用synchronized(this),这个this是Count对象(count),而t1和t2共用count。因此,在t1运行时,t2会被阻塞,等待t1运行释放“count对象的同步锁”,t2才能运行。

3. synchronized方法 和 synchronized代码块

“synchronized方法”是用synchronized修饰方法,而 “synchronized代码块”则是用synchronized修饰代码块。

synchronized方法示例

public synchronized void foo1() {    System.out.println("synchronized methoed");}

synchronized代码块

public void foo2() {    synchronized (this) {        System.out.println("synchronized methoed");    }}

synchronized代码块中的this是指当前对象。也可以将this替换成其他对象,例如将this替换成obj,则foo2()在执行synchronized(obj)时就获取的是obj的同步锁。

synchronized代码块可以更精确的控制冲突限制访问区域,有时候表现更高效率。下面通过一个示例来演示:

// Demo4.java的源码public class Demo4 {    public synchronized void synMethod() {        for(int i=0; i<1000000; i++)            ;    }    public void synBlock() {        synchronized( this ) {            for(int i=0; i<1000000; i++)                ;        }    }    public static void main(String[] args) {        Demo4 demo = new Demo4();        long start, diff;        start = System.currentTimeMillis();                // 获取当前时间(millis)        demo.synMethod();                                // 调用“synchronized方法”        diff = System.currentTimeMillis() - start;        // 获取“时间差值”        System.out.println("synMethod() : "+ diff);                start = System.currentTimeMillis();                // 获取当前时间(millis)        demo.synBlock();                                // 调用“synchronized方法块”        diff = System.currentTimeMillis() - start;        // 获取“时间差值”        System.out.println("synBlock()  : "+ diff);    }}

(某一次)执行结果

synMethod() : 11synBlock() : 3

4. 实例锁 和 全局锁

实例锁 -- 锁在某一个实例对象上。如果该类是单例,那么该锁也具有全局锁的概念。

               实例锁对应的就是synchronized关键字。
全局锁 -- 该锁针对的是类,无论实例多少个对象,那么线程都共享该锁。
               全局锁对应的就是static synchronized(或者是锁在该类的class或者classloader对象上)。

关于“实例锁”和“全局锁”有一个很形象的例子:

pulbic class Something {    public synchronized void isSyncA(){}    public synchronized void isSyncB(){}    public static synchronized void cSyncA(){}    public static synchronized void cSyncB(){}}

假设,Something有两个实例x和y。分析下面4组表达式获取的锁的情况。

(01) 
(02) 
(03) 
(04) 

(01) 不能被同时访问。因为isSyncA()和isSyncB()都是访问同一个对象(对象x)的同步锁!

// LockTest1.java的源码class Something {    public synchronized void isSyncA(){        try {              for (int i = 0; i < 5; i++) {                Thread.sleep(100); // 休眠100ms                System.out.println(Thread.currentThread().getName()+" : isSyncA");            }        }catch (InterruptedException ie) {          }      }    public synchronized void isSyncB(){        try {              for (int i = 0; i < 5; i++) {                Thread.sleep(100); // 休眠100ms                System.out.println(Thread.currentThread().getName()+" : isSyncB");            }        }catch (InterruptedException ie) {          }      }}public class LockTest1 {    Something x = new Something();    Something y = new Something();    // 比较(01) x.isSyncA()与x.isSyncB()     private void test1() {        // 新建t11, t11会调用 x.isSyncA()        Thread t11 = new Thread(                new Runnable() {                    @Override                    public void run() {                        x.isSyncA();                    }                }, "t11");        // 新建t12, t12会调用 x.isSyncB()        Thread t12 = new Thread(                new Runnable() {                    @Override                    public void run() {                        x.isSyncB();                    }                }, "t12");          t11.start();  // 启动t11        t12.start();  // 启动t12    }    public static void main(String[] args) {        LockTest1 demo = new LockTest1();        demo.test1();    }}
t11 : isSyncAt11 : isSyncAt11 : isSyncAt11 : isSyncAt11 : isSyncAt12 : isSyncBt12 : isSyncBt12 : isSyncBt12 : isSyncBt12 : isSyncB

(02) 可以同时被访问。因为访问的不是同一个对象的同步锁,x.isSyncA()访问的是x的同步锁,而y.isSyncA()访问的是y的同步锁。

 

 

 

 

 

 

 

 

 

转载于:https://my.oschina.net/LucasZhu/blog/1528995

你可能感兴趣的文章
软件架构师常会用到的几款软件
查看>>
Spring boot with Hive
查看>>
笔记本安装CentOS环境
查看>>
常用 Git 命令清单
查看>>
内购开发指南
查看>>
smarty foreach
查看>>
start.sh
查看>>
MathType几个常用字体的名称
查看>>
Flex 布局教程:语法篇
查看>>
Spring MVC 3.2+ @ResponseBody 导致的中文乱码处理
查看>>
Thread.currentThread().getContextClassLoader()和Class.getClassLoader()区别
查看>>
Dubbo zookeeper 初探【转】
查看>>
读写分离无效的大坑(新使用数据库读写分离的同学可以参考)
查看>>
这么多年被第三方接入坑的那些事。。。关于md5签名和sha1证书的坑
查看>>
淘宝SOA框架dubbo学习(4)--参数验证
查看>>
大话说github建立里程碑(SE)
查看>>
将当前登录用户去重显示。
查看>>
AWS使用记录
查看>>
传输层
查看>>
J2EE 架构师之路
查看>>