专栏首页IT笔记分享Java多线程学习(三)——synchronized(下)

Java多线程学习(三)——synchronized(下)

synchronized同步语句块

本文代码:GitHub

用关键字synchronized声明方法是有弊端的。比如线程A调用同步方法执行一个长时间任务,那么线程B就要等较长时间才能调用。

下面看一个例子:

public class Task {    private String getData1;    private String getData2;    public synchronized void longTimeTask(){        try {            System.out.println("begin task");            Thread.sleep(3000);            getData1 = "长时间处理任务后从远程返回的值1 threadName=" + Thread.currentThread().getName();            getData2 = "长时间处理任务后从远程返回的值2 threadName=" + Thread.currentThread().getName();            System.out.println(getData1);            System.out.println(getData2);            System.out.println("end task");        }catch (InterruptedException e){            e.printStackTrace();        }    }}
public class Utils {    public static long begainTime1;    public static long endTime1;    public static long begainTime2;    public static long endTime2;}
public class MyThread extends Thread{    private Task task;    private String name;    public MyThread(Task task, String name){        super();        this.task=task;        this.name=name;        super.setName(name);    }    @Override    public void run() {        super.run();        if ("A".equals(name)){            Utils.begainTime1 = System.currentTimeMillis();            task.longTimeTask();            Utils.endTime1 = System.currentTimeMillis();        }else {            Utils.begainTime2 = System.currentTimeMillis();            task.longTimeTask();            Utils.endTime2 = System.currentTimeMillis();        }    }}
public class Main {    public static void main(String[] args){        Task task = new Task();        MyThread myThread = new MyThread(task, "A");        MyThread myThread1 = new MyThread(task, "B");        myThread.start();        myThread1.start();        try {            Thread.sleep(10000);        }catch (InterruptedException e){            e.printStackTrace();        }        long beginTime = Utils.begainTime1;        if (Utils.begainTime2<Utils.begainTime1){            beginTime = Utils.begainTime2;        }        long endTime = Utils.endTime1;        if (Utils.endTime2>Utils.endTime1){            endTime = Utils.endTime2;        }        System.out.println("耗时:" + (endTime-beginTime)/1000 + "s");    }}

输出内容:

begin task长时间处理任务后从远程返回的值1 threadName=A长时间处理任务后从远程返回的值2 threadName=Aend taskbegin task长时间处理任务后从远程返回的值1 threadName=B长时间处理任务后从远程返回的值2 threadName=Bend task耗时:6s

从运行时间上来看,synchronized方法的问题很明显。可以使用synchronized同步块来解决这个问题。但是要注意synchronized同步块的使用方式,如果synchronized同步块使用不好的话并不会带来效率的提升。

将上文的Task.class文件修改如下:

public void longTimeTask(){        try {            System.out.println("begin task");            Thread.sleep(3000);            String data1 = "长时间处理任务后从远程返回的值1 threadName=" + Thread.currentThread().getName();            String data2 = "长时间处理任务后从远程返回的值2 threadName=" + Thread.currentThread().getName();            synchronized (this){                getData1 = data1;                getData2 = data2;            }            System.out.println(getData1);            System.out.println(getData2);            System.out.println("end task");        }catch (InterruptedException e){            e.printStackTrace();        }    }

输出如下:

begin taskbegin task长时间处理任务后从远程返回的值1 threadName=B长时间处理任务后从远程返回的值2 threadName=Aend task长时间处理任务后从远程返回的值1 threadName=A长时间处理任务后从远程返回的值2 threadName=Aend task耗时:3s

从上面代码可以看出当一个线程访问一个对象的synchronized同步代码块时,另一个线程任然可以访问该对象非synchronized同步代码块。不在synchronized块中的就是异步执行,在synchronized块中就是同步执行。

synchronized代码块之间的同步性

当一个线程访问一个对象的synchronized(this)同步代码块时,其他线程对同一个object中的其他synchronized(this)同步代码块访问将被阻塞。

如果在一个类中有很多个synchronized方法,这是虽然能实现同步,但会受到阻塞。如果使用同步代码块锁非this对象,则synchronized(非this)代码块中的程序与同步方法是异步的,不与其他this同步方法争抢this锁。

静态同步synchronized方法与synchronized(class)代码块

关键字synchronized还可以在static方法是使用,是对当前的*.java文件的Class类进行加锁。非静态的synchronized关键字是给对象加锁。

public static void printA() {        synchronized (Service.class) {            try {                System.out.println(                        "线程名称为:" + Thread.currentThread().getName() + "在" + System.currentTimeMillis() + "进入printA");                Thread.sleep(3000);                System.out.println(                        "线程名称为:" + Thread.currentThread().getName() + "在" + System.currentTimeMillis() + "离开printA");            } catch (InterruptedException e) {                e.printStackTrace();            }        }    }    synchronized public static void printB() {        System.out.println("线程名称为:" + Thread.currentThread().getName() + "在" + System.currentTimeMillis() + "进入printB");        System.out.println("线程名称为:" + Thread.currentThread().getName() + "在" + System.currentTimeMillis() + "离开printB");    }    synchronized public void printC() {        System.out.println("线程名称为:" + Thread.currentThread().getName() + "在" + System.currentTimeMillis() + "进入printC");        System.out.println("线程名称为:" + Thread.currentThread().getName() + "在" + System.currentTimeMillis() + "离开printC");    }
public class Main {    public static void main(String[] args){        Service service = new Service();        new Thread(Service::printA, "A").start();        new Thread(Service::printB, "B").start();        new Thread(() -> service.printC(), "C").start();    }}

输出内容:

线程名称为:A在1552262297299进入printA线程名称为:C在1552262297300进入printC线程名称为:C在1552262297300离开printC线程名称为:A在1552262300301离开printA线程名称为:B在1552262300301进入printB线程名称为:B在1552262300301离开printB

从运行结果可以看出:静态同步synchronized方法与synchronized(class)代码块持有的锁一样,都是Class锁,Class锁对对象的所有实例起作用。synchronized关键字加到非static静态方法上持有的是对象锁。线程A,B和线程C持有的锁不一样,所以A和B运行同步,但是和C运行不同步。

数据类型String的常量池特性

JVM具有String常量池缓存的功能,将synchronized(string)与String联合使用时会出现一些问题。

 String s1 = "a";    String s2="a";    System.out.println(s1==s2);//true

比如两个同步方法都是synchronized("abc"){}那么多线程会持有相同的锁,所以大多数同步代码块不用String作为锁。

本文分享自微信公众号 - IT笔记分享(xiaosen_javashare),作者:xiaosen L

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-03-11

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Java多线程学习(三)——synchronized(上)

    在前两节的《Java多线程学习(一)——多线程基础》和《Java多线程学习(二)——Thread类的方法介绍》中我们接触了线程安全和非线程安全的概念,这节就来学...

    小森啦啦啦
  • Java多线程学习(五)——等待通知机制

    方法wait()的作用是使当前线程进行等待,wait()方法是Object类的方法,该方法用来将当前线程放到“预执行队列”,并在wait()所在的代码处停止执行...

    小森啦啦啦
  • Java多线程学习(二)——Thread类的方法使用

    停止线程意味着在线程处理完任务之前停掉正在做的操作,也就是放弃当前操作。有以下三种方法终止正在运行中的线程:

    小森啦啦啦
  • java线程池ThreadPoolExecutor 如何与 AsyncTask() 组合使用

    简单说下Executors类,提供的一系列创建线程池的方法: 他们都有两个构造方法 1. --------newFixedThreadPool (创建一个定长线...

    xiangzhihong
  • java 线程池ThreadPoolExecutor 如何与 AsyncTask() 组合使用。

    转载请声明出处谢谢!https://cloud.tencent.com/developer/user/1148436/activities 这里主要使用Exec...

    林冠宏-指尖下的幽灵
  • 自定义注解与常用设计模式

    注解分为:内置注解,自定义注解。内置注解就是JDK 自带的,而自定义注解则是自己定义的比如许多框架(spring) 用到的

    斯文的程序
  • 关于Java多线程的一些常考知识点

    用户2032165
  • Java并发锁(一):悲观锁与乐观锁

    今天我们来聊下线程中的悲观锁和乐观锁,首先提到"悲观锁","乐观锁"提到这两个名词,大家可能会先想到数据库。注意啦,我们这里讲的是多线程中的锁,而不是数据库中的...

    Spark学习技巧
  • 【快学springboot】10.使用@Async注解创建多线程,自定义线程池

    使用@Async注解创建多线程非常的方便,还可以通过配置,实现线程池。比直接使用线程池简单太多。而且在使用上跟普通方法没什么区别,加上个@Async注解即可实现...

    Happyjava
  • 一个 Java 线程池bug引发的 GC 机制思考

    本文中的模拟代码已经问题都是在HotSpot java8 (1.8.0_221)版本下模拟&出现的

    黄泽杰

扫码关注云+社区

领取腾讯云代金券