Java多线程同步代码块Synchronized
Java中的每个对象都有一个与之关联的内部锁(Intrinsic lock). 这种锁也称为监视器(Monitor), 这种内部锁是一种排他锁,可以保障原子性,可见性与有序性。
内部锁是通过synchronized关键字实现的.synchronized关键字修饰代码块,修饰该方法。
修饰代码块的语法:
synchronized( 对象锁 ) {
同步代码块,可以在同步代码块中访问共享数据
}
修饰实例方法就称为同步实例方法
修饰静态方法称称为同步静态方法
synchronized同步代码块
package com.wkcto.intrinsiclock;
/**
* synchronized同步代码块
* this锁对象
* Author: 老崔
*/
public class Test01 {
public static void main(String[] args) {
//创建两个线程,分别调用mm()方法
//先创建Test01对象,通过对象名调用mm()方法
Test01 obj = new Test01();
new Thread(new Runnable() {
@Override
public void run() {
obj.mm(); //使用的锁对象this就是obj对象
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
obj.mm(); //使用的锁对象this也是obj对象
}
}).start();
}
//定义方法,打印100行字符串
public void mm(){
synchronized ( this ) { //经常使用this当前对象作为锁对象
for (int i = 1; i <= 100; i++) {
System.out.println(Thread.currentThread().getName() + " --> " + i);
}
}
}
}
package com.wkcto.intrinsiclock;
/**
* synchronized同步代码块
* 如果线程的锁不同, 不能实现同步
* 想要同步必须使用同一个锁对象
* Author: 老崔
*/
public class Test02 {
public static void main(String[] args) {
//创建两个线程,分别调用mm()方法
//先创建Test01对象,通过对象名调用mm()方法
Test02 obj = new Test02();
Test02 obj2 = new Test02();
new Thread(new Runnable() {
@Override
public void run() {
obj.mm(); //使用的锁对象this就是obj对象
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
obj2.mm(); //使用的锁对象this也是obj2对象
}
}).start();
}
//定义方法,打印100行字符串
public void mm(){
synchronized ( this ) { //经常使用this当前对象作为锁对象
for (int i = 1; i <= 100; i++) {
System.out.println(Thread.currentThread().getName() + " --> " + i);
}
}
}
}
package com.wkcto.intrinsiclock;
/**
* synchronized同步代码块
* 使用一个常量对象作为锁对象
* Author: 老崔
*/
public class Test03 {
public static void main(String[] args) {
//创建两个线程,分别调用mm()方法
//先创建Test01对象,通过对象名调用mm()方法
Test03 obj = new Test03();
Test03 obj2 = new Test03();
new Thread(new Runnable() {
@Override
public void run() {
obj.mm(); //使用的锁对象OBJ常量
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
obj2.mm(); //使用的锁对象OBJ常量
}
}).start();
}
public static final Object OBJ = new Object(); //定义一个常量,
//定义方法,打印100行字符串
public void mm(){
synchronized ( OBJ ) { //使用一个常量对象作为锁对象
for (int i = 1; i <= 100; i++) {
System.out.println(Thread.currentThread().getName() + " --> " + i);
}
}
}
}
package com.wkcto.intrinsiclock;
/**
* synchronized同步代码块
* 使用一个常量对象作为锁对象,不同方法中 的同步代码块也可以同步
* Author: 老崔
*/
public class Test04 {
public static void main(String[] args) {
//创建两个线程,分别调用mm()方法
//先创建Test01对象,通过对象名调用mm()方法
Test04 obj = new Test04();
Test04 obj2 = new Test04();
new Thread(new Runnable() {
@Override
public void run() {
obj.mm(); //使用的锁对象OBJ常量
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
obj2.mm(); //使用的锁对象OBJ常量
}
}).start();
//第三个线程调用静态方法
new Thread(new Runnable() {
@Override
public void run() {
sm(); //使用的锁对象OBJ常量
}
}).start();
}
public static final Object OBJ = new Object(); //定义一个常量,
//定义方法,打印100行字符串
public void mm(){
synchronized ( OBJ ) { //使用一个常量对象作为锁对象
for (int i = 1; i <= 100; i++) {
System.out.println(Thread.currentThread().getName() + " --> " + i);
}
}
}
//定义方法,打印100行字符串
public static void sm(){
synchronized ( OBJ ) { //使用一个常量对象作为锁对象
for (int i = 1; i <= 100; i++) {
System.out.println(Thread.currentThread().getName() + " --> " + i);
}
}
}
}
