目的
本文只针对synchronized的使用进行描述以及代码演示。具体原理不做深入探讨
简介
synchronized 在多线程并发环境下,通过加锁的形式保证了数据的一致性,锁存在Java对象头里。如果对象是数组类型,则虚拟机用3个Word(字宽)存储对象头,如果对象是非数组类型,则用2字宽存储对象头。在32位虚拟机中,一字宽等于四字节,即32bit。
对象锁、代码块锁的使用
先看一段示例代码
代码块一
public class T {private Integer count = 0;private Object o = new Object();public void m() {//任何线程要执行下面的代码,必须先拿到o的锁synchronized (o) {for (int i = 0; i < 100000; i++) {count++;}}}public static void main(String[] args) throws InterruptedException {// 采用 CountDownLatch 保证了所有线程同时开始,同时结束CountDownLatch start = new CountDownLatch(1);CountDownLatch end = new CountDownLatch(10);T t = new T();for (int i = 0; i < 10; i++) {new Thread(() -> {try {start.await();t.m();} catch (InterruptedException e) {e.printStackTrace();} finally {end.countDown();}}).start();}start.countDown();end.await();System.out.println(Thread.currentThread().getName() + " count = " + t.count);}}输出结果:main count = 1000000结果正确。
结论:我们在多线程并发环境下,为了保证所有线程对某个对象、基本类型的操作保持唯一性,需要去拿到一个全局不变的唯一锁,只有锁对象不变才能保证计算变量的唯一性。
以上写法还可以直接锁当前对象不需要new 一个object
代码块二
public class T {private Integer count = 0;public void m() {//任何线程要执行下面的代码,必须先拿到当前对象的锁//锁的是当前对象synchronized (this) {for (int i = 0; i < 100000; i++) {count++;}}}public static void main(String[] args) throws InterruptedException {// 采用 CountDownLatch 保证了所有线程同时开始,同时结束CountDownLatch start = new CountDownLatch(1);CountDownLatch end = new CountDownLatch(10);T t = new T();for (int i = 0; i < 10; i++) {new Thread(() -> {try {start.await();t.m();} catch (InterruptedException e) {e.printStackTrace();} finally {end.countDown();}}).start();}start.countDown();end.await();System.out.println(Thread.currentThread().getName() + " count = " + t.count);}}
上面的代码 还可以直接在m 方法上加锁,同样锁的是当前对象,如下代码
代码块三
public class T {private Integer count = 0;public synchronized void m() {//任何线程要执行下面的代码,必须先拿到当前对象的锁//锁的是当前对象for (int i = 0; i < 100000; i++) {count++;}}public static void main(String[] args) throws InterruptedException {// 采用 CountDownLatch 保证了所有线程同时开始,同时结束CountDownLatch start = new CountDownLatch(1);CountDownLatch end = new CountDownLatch(10);T t = new T();for (int i = 0; i < 10; i++) {new Thread(() -> {try {start.await();t.m();} catch (InterruptedException e) {e.printStackTrace();} finally {end.countDown();}}).start();}start.countDown();end.await();System.out.println(Thread.currentThread().getName() + " count = " + t.count);}}
此代码块与代码块2 一样,锁的都是当前对象,代码块1为可自由锁定根据实际情况定的对象,一般采用代码块1 的方法进行代码块的锁定,这样减少了锁定的范围提高了代码的性能。通俗理解只要保证每次拿到的是同一个锁即可,对象变了锁也就变了。
以下代码为错误的例子**
public class T {private Integer count = 0;public void m() {//任何线程要执行下面的代码,必须先拿到当前对象的锁//锁的是当前对象synchronized (count) {for (int i = 0; i < 100000; i++) {count++;}}}public static void main(String[] args) throws InterruptedException {// 采用 CountDownLatch 保证了所有线程同时开始,同时结束CountDownLatch start = new CountDownLatch(1);CountDownLatch end = new CountDownLatch(10);T t = new T();for (int i = 0; i < 10; i++) {new Thread(() -> {try {start.await();t.m();} catch (InterruptedException e) {e.printStackTrace();} finally {end.countDown();}}).start();}start.countDown();end.await();System.out.println(Thread.currentThread().getName() + " count = " + t.count);}}输出结果:main count = 185200 错误的结果,我们想要的是 1000000
