第一章附加:线程锁synchronized方法,synchronized块和synchronied(this)总结[通俗易懂]

第一章附加:线程锁synchronized方法,synchronized块和synchronied(this)总结[通俗易懂]第一章附加:线程锁synchronized方法,synchronized块和synchronied(this)总结

大家好,又见面了,我是你们的朋友全栈君。

本文主题转自:https://www.cnblogs.com/oracleDBA/archive/2010/05/22/1741642.html

本文主要阐述以下三个问题:

1.       synchronzied作用

2.       synchronzied语法

3.       synchronized(this)的理解

 

首先,解释一下synchronzied作用

Synchronzied关键字的作用一个词概括就是:线程同步。它可以用来修改对象中的方法,将对象加锁。相当于不管哪一个线程A每次运行到这个方法时,都要检查有没有其它正在用这个方法的线程B(或者C D等),有的话要等正在使用这个方法的线程B(或者C D)运行完这个方法后再运行此线程A,没有的话,直接运行。

 

然后,讲讲synchronzied语法

Synchronzied关键字包括两种用法:synchronized 方法和 synchronized 块。

1.       synchronized 方法

如:public synchronized void accessVal(int newVal);

synchronized 方法控制对类成员变量的访问:每个类实例对应一把锁,每个 synchronized 方法都必须获得调用该方法的类实例的锁方能执行,否则所属线程阻塞,方法一旦执行,就独占该锁,直到从该方法返回时才将锁释放,此后被阻塞的线程方能获得该锁,重新进入可执行状态。这种机制确保了同一时刻对于每一个类实例,其所有声明为 synchronized 的成员函数中至多只有一个处于可执行状态(因为至多只有一个能够获得该类实例对应的锁),从而有效避免了类成员变量的访问冲突(只要所有可能访问类成员变量的方法均被声明为 synchronized)。在 Java 中,不光是类实例,每一个类也对应一把锁,这样我们也可将类的静态成员函数声明为synchronized ,以控制其对类的静态成员变量的访问。

2.       synchronized 

synchronized 方法是对整个方法进行加锁。若将一个大的方法声明为synchronized 将会大大影响效率,典型地,若将线程类的方法 run() 声明为 synchronized,由于在线程的整个生命期内它一直在运行,因此将导致它对本类任何 synchronized 方法的调用都永远不会成功。当然我们可以通过将访问类成员变量的代码放到专门的方法中,将其声明为 synchronized ,并在主方法中调用来解决这一问题,但是 Java 为我们提供了更好的解决办法,那就是 synchronized 块。

如:synchronized(syncObject) {

  //允许访问控制的代码

  }

synchronized 块是这样一个代码块,其中的代码必须获得对象 syncObject (如前所述,可以是类实例或类)的锁方能执行,具体机制同前所述。由于可以针对任意代码块,且可任意指定上锁的对象,故灵活性较高。

 

最后,说说synchronzied(this)。下面的几个示例阐述地非常清晰,而且只有通过demo,才能对知识点理解得更加透彻。建议在IDE中亲自运行,体验一下。

这里先说一下this这个指向问题,我们经常说this指向的是当前对象,可是相信有很多朋友迷惑当前对象到底是谁,小编也有过相同的疑惑,曾经任务当前对象是所在的类。其实不然,一下面的代码为例,其实this指向的就是这个t1,Thread t1=new Thread();在下面的ta和tb中,尽管两个线程的地址不一样,也是两个线程,但是他们持有的线程对象都是t1,这样是为了同步代码块。用一个比较经典的总结就是:钥匙在给代码加锁的那个线程手里,钥匙就是this,这里指向t1.

一、当两个并发线程访问同一个对象object中的这个synchronized(this)同步代码块时,一个时间内只能有一个线程得到执行。另一个线程必须等待当前线程执行完这个代码块以后才能执行该代码块。

package ths;

 

public class Thread1 implements Runnable {

public void run() {

synchronized(this) {

for (int i = 0; i < 5; i++) {

System.out.println(Thread.currentThread().getName() + " synchronized loop " + i);

}

}

}

public static void main(String[] args) {

Thread1 t1 = new Thread1();

Thread ta = new Thread(t1, "A");

Thread tb = new Thread(t1, "B");

ta.start();

tb.start();

}

}

结果:

A synchronized loop 0

A synchronized loop 1

A synchronized loop 2

A synchronized loop 3

A synchronized loop 4

B synchronized loop 0

B synchronized loop 1

B synchronized loop 2

B synchronized loop 3

B synchronized loop 4

二、然而,当一个线程访问object的一个synchronized(this)同步代码块时,另一个线程仍然可以访问该object中的非synchronized(this)同步代码块。

package ths;

 

public class Thread2 {

public void m4t1() {

synchronized(this) {

int i = 5;

while( i-- > 0) {

System.out.println(Thread.currentThread().getName() + " : " + i);

try {

Thread.sleep(500);

} catch (InterruptedException ie) {

}

}

}

}

public void m4t2() {

int i = 5;

while( i-- > 0) {

System.out.println(Thread.currentThread().getName() + " : " + i);

try {

Thread.sleep(500);

} catch (InterruptedException ie) {

}

}

}

public static void main(String[] args) {

final Thread2 myt2 = new Thread2();

Thread t1 = new Thread(

new Runnable() {

public void run() {

myt2.m4t1();

}

}, "t1"

);

Thread t2 = new Thread(

new Runnable() {

public void run() {

myt2.m4t2();

}

}, "t2"

);

t1.start();

t2.start();

}

}

结果:

t1 : 4

t2 : 4

t1 : 3

t2 : 3

t1 : 2

t2 : 2

t1 : 1

t2 : 1

t1 : 0

t2 : 0

三、尤其关键的是,当一个线程访问object的一个synchronized(this)同步代码块时,其他线程对object中所有其它synchronized(this)同步代码块的访问将被阻塞。

//修改Thread2.m4t2()方法:

 

public void m4t2() {

synchronized(this) {

int i = 5;

while( i-- > 0) {

System.out.println(Thread.currentThread().getName() + " : " + i);

try {

Thread.sleep(500);

} catch (InterruptedException ie) {

}

}

}
}

结果:

t1 : 4

t1 : 3

t1 : 2

t1 : 1

t1 : 0

t2 : 4

t2 : 3

t2 : 2

t2 : 1

t2 : 0

四、第三个例子同样适用其它同步代码块。也就是说,当一个线程访问object的一个synchronized(this)同步代码块时,它就获得了这个object的对象锁。结果,其它线程对该object对象所有同步代码部分的访问都被暂时阻塞。

//修改Thread2.m4t2()方法如下:

 

public synchronized void m4t2() {

int i = 5;

while( i-- > 0) {

System.out.println(Thread.currentThread().getName() + " : " + i);

try {

Thread.sleep(500);

} catch (InterruptedException ie) {

}

}

}

结果:

t1 : 4

t1 : 3

t1 : 2

t1 : 1

t1 : 0

t2 : 4

t2 : 3

t2 : 2

t2 : 1

t2 : 0

五、以上规则对其它对象锁同样适用:

package ths;

 

public class Thread3 {

class Inner {

private void m4t1() {

int i = 5;

while(i-- > 0) {

System.out.println(Thread.currentThread().getName() + " : Inner.m4t1()=" + i);

try {

Thread.sleep(500);

} catch(InterruptedException ie) {

}

}

}

private void m4t2() {

int i = 5;

while(i-- > 0) {

System.out.println(Thread.currentThread().getName() + " : Inner.m4t2()=" + i);

try {

Thread.sleep(500);

} catch(InterruptedException ie) {

}

}

}

}

private void m4t1(Inner inner) {

synchronized(inner) { //使用对象锁

inner.m4t1();

}

}

private void m4t2(Inner inner) {

inner.m4t2();

}

public static void main(String[] args) {

final Thread3 myt3 = new Thread3();

final Inner inner = myt3.new Inner();

Thread t1 = new Thread(

new Runnable() {

public void run() {

myt3.m4t1(inner);

}

}, "t1"

);

Thread t2 = new Thread(

new Runnable() {

public void run() {

myt3.m4t2(inner);

}

}, "t2"

);

t1.start();

t2.start();

}

}

结果:

尽管线程t1获得了对Inner的对象锁,但由于线程t2访问的是同一个Inner中的非同步部分。所以两个线程互不干扰。

t1 : Inner.m4t1()=4

t2 : Inner.m4t2()=4

t1 : Inner.m4t1()=3

t2 : Inner.m4t2()=3

t1 : Inner.m4t1()=2

t2 : Inner.m4t2()=2

t1 : Inner.m4t1()=1

t2 : Inner.m4t2()=1

t1 : Inner.m4t1()=0

t2 : Inner.m4t2()=0

现在在Inner.m4t2()前面加上synchronized

private synchronized void m4t2() {

int i = 5;

while(i-- > 0) {

System.out.println(Thread.currentThread().getName() + " : Inner.m4t2()=" + i);

try {

Thread.sleep(500);

} catch(InterruptedException ie) {

}

}

}

结果:

 

尽管线程t1t2访问了同一个Inner对象中两个毫不相关的部分,但因为t1先获得了对Inner的对象锁,所以t2Inner.m4t2()的访问也被阻塞,因为m4t2()Inner中的一个同步方法。

t1 : Inner.m4t1()=4

t1 : Inner.m4t1()=3

t1 : Inner.m4t1()=2

t1 : Inner.m4t1()=1

t1 : Inner.m4t1()=0

t2 : Inner.m4t2()=4

t2 : Inner.m4t2()=3

t2 : Inner.m4t2()=2

t2 : Inner.m4t2()=1

t2 : Inner.m4t2()=0

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/106126.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • MessageDigest简单介绍

    MessageDigest简单介绍

    2021年12月5日
    52
  • 标签的含义_新建标签页的网址

    标签的含义_新建标签页的网址功能说明版权信息适用范围首页模板,列表模板,内容模板基本语法[NT:unLoop,NT:SiteID=0,NT:LabelType=CopyRight][/NT:unLoop]必填参数NT:SiteID表示站群ID,0表示总站NT:LabelType标签类型:值为CopyRight,表示版权信息后台设置:控制面板—系统…

    2022年9月30日
    2
  • ringbuffer的常规用法_likewise用法

    ringbuffer的常规用法_likewise用法C/C++Linux服务器开发/后台架构师知识体系整理环形缓冲区(RINGBUFFER)的实现原理环形缓冲区通常有一个读指针和一个写指针(一个入指针和一个出指针)。读指针指向环形缓冲区中可读的数据,写指针指向环形缓冲区中可写的缓冲区。通过移动读指针和写指针就可以实现缓冲区的数据读取和写入。在通常情况下,环形缓冲区的读用户仅仅会影响读指针,而写用户仅仅会影响写指针。如果仅仅有一个读用户和一个写用户,那么不需要添加互斥保护机制就可以保证数据的正确性。如果有多个读写用户访问环形缓冲区,那么必须添加互斥保护机

    2025年10月22日
    3
  • kafka和flume区别

    kafka和flume区别Flume更趋向于消息采集系统,Kafka更趋向于消息缓存系统。 kafka:目前项目中主要是用来做消息推送中间件,消息的处理完全由业务方自己定义,请求频次单机吞吐量轻轻松松50W+/s,数据在集群不全挂的情况下是不会丢数据,消费也很灵活,可以指定分区和offset,可以当做成一个数据库。 flume:用来做数据采集和落地,目前使用的是flume-ng,流程是source(kafka)->channel->hdfs相比较kafka比较轻量级,就是一个数据的流通管道,当..

    2022年6月23日
    27
  • 联想笔记本电脑键盘灯怎么开启_联想笔记本电脑的键盘灯怎么开[通俗易懂]

    联想笔记本电脑键盘灯怎么开启_联想笔记本电脑的键盘灯怎么开[通俗易懂]展开全部1、联想笔记本部分型号具备键盘背32313133353236313431303231363533e4b893e5b19e31333431336664光功能,方法通过“FN+空格”打开,支持此功能的机型,键盘上有相应标示。部分早期的Thinkpad笔记本电脑若带有键盘灯,需要通过“Fn+PageUp”组合键开启。发现电脑键盘的“Space(空格键)”按键上有下图所示的标识符号电脑一般带有键…

    2022年9月20日
    2
  • SSDP服务_upnp 端口映射

    SSDP服务_upnp 端口映射SSDP简单服务发现协议,是应用层协议,是构成UPnP(通用即插即用)技术的核心协议之一。它为网络客户端(networkclient)提供了一种发现网络服务(networkservices)的机制,采用基于通知和发现路由的多播方式实现。SSDP多播地址:239.255.255.250:1900(IPv4),FF0x::C(IPv6)两种类型的SSDP请求消息会通过SSDP多播地址发送:1….

    2022年10月10日
    2

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号