三个数额损坏就满门破坏,(this)同步代码块时

本婴孩新手,勿喷!直接上代码了,

在十二线程开垦中,大家常常看看synchronized(this)、synchronized(*.class)与synchronized(大四对象)这几种类型同步方法。可是是不是通晓那两种写法有怎么着分别了?上边依据代码来深入分析:

线程范围内共享难题:各样线程之间共享同1块数据,四个数目损坏就整个磨损,供给的能够运转一下!

一、synchronized代码块间的同步性

威尼斯人娱乐, 


public class Threads {
private static HashMap<Thread, Integer> data = new
HashMap<Thread,Integer>();
public static void main(String[] args) {
for (int i = 0; i < 2; i++) {
new Thread(new Runnable() {

package com.zwz.thread.demo1;  

@Override
public void run() {
int value = new Random().nextInt(1000);
data.put(Thread.currentThread(), value);
System.out.println(“名字是:”+Thread.currentThread().getName()+”数据是:”+value);
A a1 = new A();
a1.getData();
B b1 = new B();
b1.getData();
C c = new C();
c.getDate();
}
}).start();
}
}
static class A{
public void getData(){
Thread thread = Thread.currentThread();
int value = data.get(thread);
System.out.println(thread.getName()+”从A中获取数据”+value);
}
}
static class B{
public void getData(){
Thread thread = Thread.currentThread();
int value = data.get(thread);
System.out.println(thread.getName()+”从B中获取数据”+value);
}
}
static class C{
public void getDate() {
Thread thread = Thread.currentThread();
int value = data.get(thread);
System.out.println(thread.getName()+”从C中获取数据”+value);
}
}

public class ObjectService {  

}

public void serviceMethodA(){  

try {  

synchronized (this) {  

System.out.println(“A begin time=”+System.currentTimeMillis());  

Thread.sleep(2000);  

System.out.println(“A end   time=”+System.currentTimeMillis());  

            }  

}catch (InterruptedException e) {  

            e.printStackTrace();  

        }  

    }  

public void serviceMethodB(){  

synchronized (this) {  

System.out.println(“B begin time=”+System.currentTimeMillis());  

System.out.println(“B end   time=”+System.currentTimeMillis());  

        }  

    }  

}  


package com.zwz.thread.demo1;  

public class ThreadA extends Thread {  

private ObjectService objectService;  

public ThreadA(ObjectService objectService){  

super();  

this.objectService=objectService;  

    }  

@Override  

public void run() {  

super.run();  

        objectService.serviceMethodA();  

    }  

}  


package com.zwz.thread.demo1;  

public class ThreadB extends Thread {  

private ObjectService objectService;  

public ThreadB(ObjectService objectService){  

super();  

this.objectService=objectService;  

    }  

@Override  

public void run() {  

super.run();  

        objectService.serviceMethodB();  

    }  

}  


package com.zwz.thread.demo1;  

public class MainTest {  

public static void main(String[] args) {  

ObjectService service=new ObjectService();  

ThreadA a=new ThreadA(service);  

a.setName(“a”);  

        a.start();  

ThreadB b=new ThreadB(service);  

b.setName(“b”);  

        b.start();  

    }  

}  


运维结果:

威尼斯人娱乐 1

结论:

当四个线程访问ObjectService的2个synchronized
(this)同步代码块时,其它线程对同3个ObjectService中任何的synchronized
(this)同步代码块的拜会将是杜绝,表明synchronized
(this)使用的是同二个对象锁。


2、验证synchronized (this)代码块是锁定当前目的


package com.zwz.thread.demo2;  

public class ObjectService {  

public void objectMethodA(){  

System.out.println(“run—-objectMethodA”);  

    }  

public void objectMethodB(){  

synchronized (this) {  

try {  

for (int i = 1; i <= 10; i++) {  

System.out.println(“synchronized thread name:”+Thread.currentThread().getName()+”–>i=”+i);  

Thread.sleep(1000);  

                }  

}catch (InterruptedException e) {  

                    e.printStackTrace();  

            }  

        }  

    }  

}  


package com.zwz.thread.demo2;  

public class ThreadA extends Thread {  

private ObjectService objectService;  

public ThreadA(ObjectService objectService) {  

super();  

this.objectService = objectService;  

    }  

@Override  

public void run() {  

super.run();  

        objectService.objectMethodA();  

    }  

}  


package com.zwz.thread.demo2;  

public class ThreadB extends Thread {  

private ObjectService objectService;  

public ThreadB(ObjectService objectService) {  

super();  

this.objectService = objectService;  

    }  

@Override  

public void run() {  

super.run();  

        objectService.objectMethodB();  

    }  

}  


package com.zwz.thread.demo2;  

public class MainTest {  

public static void main(String[] args) throws InterruptedException {  

ObjectService service=new ObjectService();  

ThreadB b=new ThreadB(service);  

        b.start();  

Thread.sleep(2000);  

ThreadA a=new ThreadA(service);  

        a.start();  

    }  

}  

运维结果:

威尼斯人娱乐 2

能够见见未有同步锁的objectMethodA方法异步试行了,下边大家将objectMethodA()加上壹道。


package com.zwz.thread.demo2;  

public class ObjectService {  

public synchronized void objectMethodA(){  

System.out.println(“run—-objectMethodA”);  

    }  

public void objectMethodB(){  

synchronized (this) {  

try {  

for (int i = 1; i <= 10; i++) {  

System.out.println(“synchronized thread name:”+Thread.currentThread().getName()+”–>i=”+i);  

Thread.sleep(1000);  

                }  

}catch (InterruptedException e) {  

                    e.printStackTrace();  

            }  

        }  

    }  

}  


运转结果:

威尼斯人娱乐 3

结论:

地方三个小例子大家得以知晓,七个线程调用同四个对象中的不一致名指标synchronized同步方法或synchronized(this)同步代码块时,是联合具名的。

一、synchronized同步方法

壹对其它的synchronized同步方法或synchronized(this)同步代码块调用是杜绝情形;

2同不平日间唯有一个线程实行synchronized同步方法中的代码。

二、synchronized(this)同步代码块

一对其余的synchronized同步方法或synchronized(this)同步代码块调用是杜绝景况;

二同临时间唯有3个线程实行synchronized同步方法中的代码。


三、将随意对象作为指标监视器


package com.zwz.thread.demo3;  

public class ObjectService {  

private String uname;  

private String pwd;  

String lock=new String();  

public void setUserNamePassWord(String userName,String passWord){  

try {  

synchronized (lock) {  

System.out.println(“thread name=”+Thread.currentThread().getName()  

+” 进入代码快:”+System.currentTimeMillis());  

                uname=userName;  

Thread.sleep(3000);  

                pwd=passWord;  

System.out.println(“thread name=”+Thread.currentThread().getName()  

+” 进入代码快:”+System.currentTimeMillis()+”入参uname:”+uname+”入参pwd:”+pwd);  

            }  

}catch (InterruptedException e) {  

            e.printStackTrace();  

        }  

    }  

}  


package com.zwz.thread.demo3;  

public class ThreadA extends Thread {  

private ObjectService objectService;  

public ThreadA(ObjectService objectService) {  

super();  

this.objectService = objectService;  

    }  

@Override  

public void run() {  

objectService.setUserNamePassWord(“a”, “aa”);  

    }  

}  


package com.zwz.thread.demo3;  

public class ThreadB extends Thread {  

private ObjectService objectService;  

public ThreadB(ObjectService objectService) {  

super();  

this.objectService = objectService;  

    }  

@Override  

public void run() {  

objectService.setUserNamePassWord(“b”, “bb”);  

    }  

}  


package com.zwz.thread.demo3;  

public class MainTest {  

public static void main(String[] args) {  

ObjectService service=new ObjectService();  

ThreadA a=new ThreadA(service);  

a.setName(“A”);  

        a.start();  

ThreadB b=new ThreadB(service);  

b.setName(“B”);  

        b.start();  

    }  

}  


运营结果:

威尼斯人娱乐 4

上边小编把String lock=new String();放在方法中:


package com.zwz.thread.demo3;  

public class ObjectService {  

private String uname;  

private String pwd;  

public void setUserNamePassWord(String userName,String passWord){  

try {  

String lock=new String();  

synchronized (lock) {  

System.out.println(“thread name=”+Thread.currentThread().getName()  

+” 进入代码快:”+System.currentTimeMillis());  

                uname=userName;  

Thread.sleep(3000);  

                pwd=passWord;  

System.out.println(“thread name=”+Thread.currentThread().getName()  

+” 进入代码快:”+System.currentTimeMillis()+”入参uname:”+uname+”入参pwd:”+pwd);  

            }  

}catch (InterruptedException e) {  

            e.printStackTrace();  

        }  

    }  


运转结果:

威尼斯人娱乐 5

结论:

四个线程持有对象监视器作为同二个目的的前提下,同不经常间唯有2个线程能够进行synchronized(大4自定义对象)同步代码快。


肆、synchronized(任性自定义对象)与synchronized同步方法共用


package com.zwz.thread.demo4;  

public class ObjectService {  

private String lock=new String();  

public void methodA(){  

try {  

synchronized (lock) {  

System.out.println(“a begin”);  

Thread.sleep(3000);  

System.out.println(“a   end”);  

            }  

}catch (InterruptedException e) {  

            e.printStackTrace();  

        }  

    }  

public synchronized void methodB(){  

System.out.println(“b begin”);  

System.out.println(“b   end”);  

    }  

}  


package com.zwz.thread.demo4;  

public class ThreadA extends Thread {  

private ObjectService objectService;  

public ThreadA(ObjectService objectService) {  

super();  

this.objectService = objectService;  

    }  

@Override  

public void run() {  

        objectService.methodA();  

    }  


package com.zwz.thread.demo4;  

public class ThreadB extends Thread {  

private ObjectService objectService;  

public ThreadB(ObjectService objectService) {  

super();  

this.objectService = objectService;  

    }  

@Override  

public void run() {  

        objectService.methodB();  

    }  

}  


package com.zwz.thread.demo4;  

public class MainTest {  

public static void main(String[] args) {  

ObjectService service=new ObjectService();  

ThreadA a=new ThreadA(service);  

a.setName(“A”);  

        a.start();  

ThreadB b=new ThreadB(service);  

b.setName(“B”);  

        b.start();  

    }  

}  


运作结果:

威尼斯人娱乐 6

结论:

地方methodA持有ObjectService对象锁,methodB持有lock对象锁,不是同二个,所以选择synchronized(任性自定义对象)进行同步操作,对象监视器必须是同1个对象。即使不是同1个,运转就是异步推行了。

5、静态同步synchronized方法


package com.zwz.thread.demo5;  

public class ObjectService {  

public synchronized static void methodA(){  

try {  

System.out.println(“static methodA begin 线程名称:”+Thread.currentThread().getName()+” times:”+System.currentTimeMillis());  

Thread.sleep(3000);  

System.out.println(“static methodA end   线程名称:”+Thread.currentThread().getName()+” times:”+System.current提姆eMillis());  

}catch (InterruptedException e) {  

            e.printStackTrace();  

        }  

    }  

public synchronized static void methodB(){  

System.out.println(“static methodB begin 线程名称:”+Thread.currentThread().getName()+” times:”+System.currentTimeMillis());  

System.out.println(“static methodB end   线程名称:”+Thread.currentThread().getName()+” times:”+System.currentTimeMillis());  

    }  

}  


package com.zwz.thread.demo5;  

public class ThreadA extends Thread {  

@Override  

public void run() {  

        ObjectService.methodA();  

    }  

}  


package com.zwz.thread.demo5;  

public class ThreadB extends Thread {  

@Override  

public void run() {  

        ObjectService.methodB();  

    }  

}  


package com.zwz.thread.demo5;  

public class MainTest {  

public static void main(String[] args) {  

ThreadA a=new ThreadA();  

a.setName(“A”);  

        a.start();  

ThreadB b=new ThreadB();  

b.setName(“B”);  

        b.start();  

    }  

}  


运营结果:

威尼斯人娱乐 7

结论:

synchronized应用在static方法上,那是对当下对应的*.Class举办持锁。


6、synchronized(*.class)代码块


package com.zwz.thread.demo6;  

public class ObjectService {  

public void methodA(){  

try {  

synchronized (ObjectService.class) {  

System.out.println(“methodA begin 线程名称:”+Thread.currentThread().getName()+” times:”+System.currentTimeMillis());  

Thread.sleep(3000);  

System.out.println(“methodA end   线程名称:”+Thread.currentThread().getName()+” times:”+System.currentTimeMillis());  

            }  

}catch (InterruptedException e) {  

            e.printStackTrace();  

        }  

    }  

public void methodB(){  

synchronized (ObjectService.class) {  

System.out.println(“methodB begin 线程名称:”+Thread.currentThread().getName()+” times:”+System.currentTimeMillis());  

System.out.println(“methodB end   线程名称:”+Thread.currentThread().getName()+” times:”+System.currentTimeMillis());  

        }  

    }  

}  


package com.zwz.thread.demo6;  

public class ThreadA extends Thread {  

private ObjectService objectService;  

public ThreadA(ObjectService objectService) {  

super();  

this.objectService = objectService;  

    }  

@Override  

public void run() {  

        objectService.methodA();  

    }  

}  


package com.zwz.thread.demo6;  

public class ThreadB extends Thread {  

private ObjectService objectService;  

public ThreadB(ObjectService objectService) {  

super();  

this.objectService = objectService;  

    }  

@Override  

public void run() {  

        objectService.methodB();  

    }  

}  


package com.zwz.thread.demo6;  

public class MainTest {  

public static void main(String[] args) {  

ObjectService service=new ObjectService();  

ThreadA a=new ThreadA(service);  

a.setName(“A”);  

        a.start();  

ThreadB b=new ThreadB(service);  

b.setName(“B”);  

        b.start();  

    }  

}  


运营结果:

威尼斯人娱乐 8

结论:

同步synchronized(*.class)代码块的效率其实和synchronized
static方法效果一样。Class锁对类的有所指标实例起作用。

相关文章