synchronized 是java语言keyword。当它用来修饰一个方法或者一个代码块的时候,可以保证在同一时刻最多仅仅有一个线程运行该段代码。
synchronized keyword,它包含两种使用方法:synchronized 方法和 synchronized 块。
本文直接以代码的形式来展示 synchronized keyword的使用:
【1】synchronized Demo1:
- package com.andyidea.demo;
- /**
- * 当两个并发线程訪问同一个对象object中的这个synchronized(this)同步代码块时,
- * 一个时间内仅仅能有一个线程得到运行。还有一个线程必须等待当前线程运行完这个代码
- * 块以后才干运行该代码块。
- * @author Andy.Chen
- *
- */
- public class Thread01 implements Runnable {
- @Override
- public void run() {
- synchronized (this) {
- for(int i=0;i<3;i++){
- System.out.println(Thread.currentThread().getName()+" synchronized loop "+i);
- }
- }
- }
- public static void main(String[] args) {
- Thread01 t01 = new Thread01();
- System.out.println("synchronized keyword使用 "
- +"--------------------------");
- Thread ta = new Thread(t01,"A");
- Thread tb = new Thread(t01,"B");
- ta.start();
- tb.start();
- }
- }
执行结果例如以下:
-
- synchronized keyword使用
- --------------------------
- B synchronized loop 0
- B synchronized loop 1
- B synchronized loop 2
- A synchronized loop 0
- A synchronized loop 1
- A synchronized loop 2
【2】synchronized Demo2:
- package com.andyidea.demo;
- /**
- * 当一个线程訪问object的一个synchronized(this)同步代码块时,
- * 还有一个线程仍然能够訪问该object中的非synchronized(this)同步代码块。
- * @author Andy.Chen
- *
- */
- public class Thread02 {
- public void method01(){
- synchronized (this) {
- int i=0;
- while(i++ < 3){
- System.out.println(Thread.currentThread().getName() +":"+ i);
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- }
- public void method02(){
- //第1种方式:当一个线程訪问object的一个synchronized(this)同步代码块时。
- //还有一个线程仍然能够訪问该object中的非synchronized(this)同步代码块。
- // int j=0;
- // while(j++ < 3){
- // System.out.println(Thread.currentThread().getName() +":"+ j);
- // try {
- // Thread.sleep(1000);
- // } catch (InterruptedException e) {
- // e.printStackTrace();
- // }
- // }
- //第2种方式:当一个线程訪问object的一个synchronized(this)同步代码块时,
-
//其他线程对object中全部其他synchronized(this)同步代码块的訪问将被堵塞。
- synchronized (this) {
- int j=0;
- while(j++ < 3){
- System.out.println(Thread.currentThread().getName() +":"+ j);
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- }
- /**
- * 当一个线程訪问object的一个synchronized(this)同步代码块时,
-
* 它就获得了这个object的对象锁。
- * 结果,其他线程对该object对象全部同步代码部分的訪问都被临时堵塞。
- */
- public synchronized void method3(){
- int k=0;
- while(k++ < 3){
- System.out.println(Thread.currentThread().getName() +":"+ k);
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- public static void main(String[] args) {
- final Thread02 t02 = new Thread02();
- System.out.println("synchronized keyword使用 "
- +"--------------------------");
- Thread t02A = new Thread(new Runnable() {
- @Override
- public void run() {
- t02.method01();
- }
- },"A");
- Thread t02B = new Thread(new Runnable() {
- @Override
- public void run() {
- t02.method02();
- }
- },"B");
- Thread t02C = new Thread(new Runnable() {
- @Override
- public void run() {
- t02.method3();
- }
- },"C");
- t02A.start();
- t02B.start();
- t02C.start();
- }
- }
-
- synchronized keyword使用
- --------------------------
- B:1
- B:2
- B:3
- C:1
- C:2
- C:3
- A:1
- A:2
- A:3
- package com.andyidea.demo;
- /**
- * synchronized对象锁
- * @author Andy.Chen
- *
- */
- public class Thread03 {
- class InnerObject{
- /**
- * 内部类方法1
- */
- private void innerMethod01(){
- int i=0;
- while(i++ < 3){
- System.out.println(Thread.currentThread().getName() +":"+ i);
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- /**
- * 内部类方法2
- */
- private void innerMethod02(){
- int j=0;
- while(j++ < 3){
- System.out.println(Thread.currentThread().getName() +":"+ j);
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- }
- /**
- * 外部类方法1
- * @param innerObj
- */
- private void outerMethod01(InnerObject innerObj){
- synchronized (innerObj) {
- innerObj.innerMethod01();
- }
- }
- /**
- * 外部类方法2
- * @param innerObj
- */
- private void outerMethod02(InnerObject innerObj){
- innerObj.innerMethod02();
- }
- public static void main(String[] args) {
- final Thread03 t03 = new Thread03();
- final InnerObject innerObj = t03.new InnerObject();
- System.out.println("synchronized keyword使用 "
- +"--------------------------");
- Thread t03A = new Thread(new Runnable() {
- @Override
- public void run() {
- t03.outerMethod01(innerObj);
- }
- },"A");
- Thread t03B = new Thread(new Runnable() {
- @Override
- public void run() {
- t03.outerMethod02(innerObj);
- }
- },"B");
- t03A.start();
- t03B.start();
- }
- }
- synchronized keyword使用
- --------------------------
- A:1
- B:1
- B:2
- A:2
- B:3
- A:3
总结:
1. synchronized 方法控制对类成员变量的訪问:每一个类实例相应一把锁,每一个 synchronized 方法都必须获得调用该方法的类实例的锁方能运行。否则所属线程堵塞,方法一旦运行。就独占该锁。直到从该方法返回时才将锁释放。此后被堵塞的线程方能获得该锁。又一次进入可运行状态。
这样的机制确保了同一时刻对于每一个类实例,其全部声明为 synchronized 的成员函数中至多仅仅有一个处于可运行状态(由于至多仅仅有一个可以获得该类实例相应的锁),从而有效避免了类成员变量的訪问冲突(仅仅要全部可能訪问类成员变量的方法均被声明为 synchronized)。
2. synchronized 块是这样一个代码块,当中的代码必须获得对象 syncObject (如前所述,能够是类实例或类)的锁方能运行。
因为能够针对随意代码块。且可随意指定上锁的对象。故灵活性较高。
对synchronized(this)的一些理解
一、当两个并发线程訪问同一个对象object中的这个synchronized(this)同步代码块时。一个时间内仅仅能有一个线程得到运行。
还有一个线程必须等待当前线程运行完这个代码块以后才干运行该代码块。
二、然而。当一个线程訪问object的一个synchronized(this)同步代码块时。还有一个线程仍然能够訪问该object中的非synchronized(this)同步代码块。
三、尤其关键的是。当一个线程訪问object的一个synchronized(this)同步代码块时,其他线程对object中全部其他synchronized(this)同步代码块的訪问将被堵塞。
四、当一个线程訪问object的一个synchronized(this)同步代码块时。它就获得了这个object的对象锁。
结果,其他线程对该object对象全部同步代码部分的訪问都被临时堵塞。