前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Android开发笔记(八十八)同步与加锁

Android开发笔记(八十八)同步与加锁

作者头像
aqi00
发布2019-01-18 14:06:03
4910
发布2019-01-18 14:06:03
举报
文章被收录于专栏:老欧说安卓老欧说安卓

同步synchronized

同步方法

synchronized可用来给方法或者代码块加锁,当它修饰一个方法或者一个代码块的时候,同一时刻最多只有一个线程执行这段代码。这就意味着,当两个并发线程同时访问synchronized代码块时,两个线程只能是排队做串行处理,另一个线程要等待前一个线程执行完该代码块后,才能再次执行synchronized代码块。 使用synchronized修饰某个方法,该方法便成为一个同步方法,在同一时刻只能有一个线程执行该方法。可是,synchronized的锁机制太重量级,不但整个同步方法的代码都加锁,就连该方法用到的所有类变量也一并加锁。因此,同步方法覆盖的代码越多,加锁操作对效率的影响就越严重。

显式指纹(同步代码块)

为缩小同步方法的影响方法,我们可让synchronized只修饰某个代码块,而不必修饰整个方法,synchronized修饰后的代码块叫做同步代码块。同步代码块要先指定该代码块的密钥对象,这个对象可以是任意相关类的实例,它相当于一个指纹,每个线程执行同步代码块时都要先验证指纹,指纹相同的线程进入同一个队列依次排队,若指纹不同则进入另外的执行队列。 下面是同步方法和同步代码块的代码示例:

代码语言:javascript
复制
public class TestCode {
	
	public static void main(String[] args) {
		TestCode1 t1 = new TestCode1();
		TestCode2 t2 = new TestCode2();
		TestCode3 t3 = new TestCode3();
		Thread ta = new Thread(t1, "A");
		Thread tb = new Thread(t2, "B");
		Thread tc = new Thread(t3, "C");
		ta.start();
		tb.start();
		tc.start();
	}
	
	private static TestCode test = new TestCode();

	public static class TestCode1 implements Runnable {
		public synchronized void run() {
			for (int i = 0; i < 5; i++) {
				try {
					Thread.sleep(1000);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println(Thread.currentThread().getName()+" synchronized loop "+i);
			}
		}
	}
	
	public static class TestCode2 implements Runnable {
		public void run() {
			synchronized (test) {  //这里如果使用this则表示新实例,就不与其他代码块搞在一起
				for (int i = 0; i < 5; i++) {
					try {
						Thread.sleep(1000);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					System.out.println(Thread.currentThread().getName()+" synchronized loop "+i);
				}
			}
		}
	}

	public static class TestCode3 implements Runnable {
		public void run() {
			synchronized (test) {  //这里如果使用this则表示新实例,就不与其他代码块搞在一起
				for (int i = 0; i < 5; i++) {
					try {
						Thread.sleep(1000);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					System.out.println(Thread.currentThread().getName()+" synchronized loop "+i);
				}
			}
		}
	}
	
}

下面是该示例代码的执行结果:

代码语言:javascript
复制
B synchronized loop 0
A synchronized loop 0
A synchronized loop 1
B synchronized loop 1
B synchronized loop 2
A synchronized loop 2
B synchronized loop 3
A synchronized loop 3
A synchronized loop 4
B synchronized loop 4
C synchronized loop 0
C synchronized loop 1
C synchronized loop 2
C synchronized loop 3
C synchronized loop 4

从输出结果可以看出,同步代码块如果加锁的是同一个对象实例,那么这两个同步代码块也被看作是互相排他的,同一时刻也只能有两个代码块的其中之一被执行,因此日志显示:线程B的同步代码块都执行完了,才开始执行线程C的同步代码块,即使两个代码块是在不同的地方。

隐式指纹

前面说到,synchronized会对同步代码内部的类变量加锁,这样一来,如果两个同步代码都使用了某个类变量,那也会产生排队等待的情况。因为某线程执行第一个同步代码时,会给类变量上锁;然后另一线程执行第二个同步代码,也准备给类变量上锁,结果发现类变量已经上锁无法再次上锁;所以后面的线程只好等待前面的线程执行完成。这种情况下,两个同步代码使用同一个类变量,我们可将其当作隐式指纹;而同步代码块事先指定密钥对象,可称作是显式指纹。 下面是隐式指纹的代码示例:

代码语言:javascript
复制
public class TestSynchronized {

	private int count = 0;

	public synchronized void plus() {
		System.out.println("begin plus count="+count);
		count++;
		try {
			Thread.sleep(2000);
			System.out.println("end plus count="+count);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public synchronized void minus() {
		System.out.println("begin minus count="+count);
		count--;
		System.out.println("end minus count="+count);
	}

	public void print() {
		try {
			Thread.sleep(1000);
			System.out.println("print count="+count);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public static void main(String[] args) throws Exception {
		final TestSynchronized ts = new TestSynchronized();
		Thread thread_plus = new Thread("thread_plus") {
			public void run() {
				System.out.println("Thread:" + super.getName());
				ts.plus();
			}
		};

		final Thread thread_minus = new Thread("thread_minus") {
			public void run() {
				System.out.println("Thread:" + super.getName());
				//改变ts.sub和ts.print的执行顺序,看看是什么情况
				ts.minus();
				ts.print();
				// ts.minus();
			}
		};
		thread_plus.start();
		Thread.sleep(1000);
		thread_minus.start();
	}
	
}

下面是该示例代码的执行结果:

代码语言:javascript
复制
Thread:thread_plus
begin plus count=0
Thread:thread_minus
end plus count=1
begin minus count=1
end minus count=0
print count=0

从输出结果可以看出,minus线程总是在plus线程结束之后才开始执行,虽然两个线程的同步方法并没有指定加锁的对象,但两个方法内部都使用了类变量count,因此这两个方法成为了拥有同一个隐式指纹的排他方法。

加锁Lock

因为synchronized是重量级的加锁,对程序效率影响大,而且容易偏离预期,所以从jdk1.5开始,java引入了Lock接口,用来实现轻量级的加锁操作。Lock接口主要有两个派生类,分别是普通的重入锁ReentrantLock,以及读写锁ReentrantReadWriteLock。

重入锁ReentrantLock

ReentrantLock是不区分类型的普通锁,在lock与unlock之间的代码就是被锁保护的代码块。 ReentrantLock的常用方法如下: lock : 加锁。该操作不允许中断,重复加锁时会一直等待。 unlock : 解锁。 lockInterruptibly : 允许中断的加锁。允许在等待时由其它线程调用等待线程的Thread.interrupt方法来中断等待线程的等待而直接返回,这时不用获取锁,而会抛出一个InterruptedException tryLock : 尝试锁。若之前未锁则加锁,并返回true;若之前已被当前线程锁,也返回true;若之前已被其他线程锁,则返回false。 getHoldCount : 获取当前线程的加锁次数。 isLocked : 判断是否加锁。 getQueueLength : 获取等待队列的长度。

读写锁ReentrantReadWriteLock

ReentrantReadWriteLock是区分了读锁和写锁的混合锁,读锁是共享锁,写锁是排它锁。 ReentrantReadWriteLock的常用方法如下: readLock : 获得读锁对象ReentrantReadWriteLock.ReadLock writeLock : 获得写锁对象ReentrantReadWriteLock.WriteLock isWriteLocked : 判断是否加了写锁。 getReadHoldCount : 获取加读锁的次数。 getWriteHoldCount : 获取加写锁的次数。 getQueueLength : 获取等待队列的长度。 下面是ReentrantReadWriteLock.ReadLock的常用方法: lock : 加读锁。 lockInterruptibly : 允许中断的加锁。 tryLock : 尝试加读锁。 unlock : 解除读锁。 下面是ReentrantReadWriteLock.WriteLock的常用方法: lock : 加写锁。 lockInterruptibly : 允许中断的加锁。 tryLock : 尝试加写锁。 unlock : 解除写锁。

匿名内部类的加锁

匿名内部类使用synchronized要小心,虽然看起来同步代码只有一个,但是匿名内部类每次使用都是创建新类并实例化,所以多次使用匿名内部类其实是调用不同的类,不同类的内部同步方法,自然是互不影响的了。这就是匿名内部类时常令人迷惑的一个地方,遇到这种情况,建议采用Lock加锁,而不要用synchronized加锁。匿名内部类的说明参见《Android开发笔记(八十六)几个特殊的类》。 下面是同时采用两种加锁方式的示例代码:

代码语言:javascript
复制
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.locks.ReentrantLock;

public class TestAnonymous {

	public static String getNowDateTime() {
		SimpleDateFormat s_format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		Date d_date = new Date();
		String s_date = "";
		s_date = s_format.format(d_date);
		return s_date;
	}

	private static void runSync() {
		for (int i = 0; i < 5; i++) {
			final int pos = i;
			Thread t = new Thread() {
				@Override
				public synchronized void run() {
					try {
						Thread.sleep(1000);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					System.out.println(getNowDateTime() + " runSync pos=" + pos);
				}
			};
			t.start();
		}
	}

	private final static ReentrantLock lock = new ReentrantLock();

	private static void runLock() {
		for (int i = 0; i < 5; i++) {
			final int pos = i;
			Thread t = new Thread() {
				@Override
				public void run() {
					try {
						lock.lock();
						Thread.sleep(1000);
						System.out.println(getNowDateTime() + " runLock pos=" + pos);
					} catch (InterruptedException e) {
						e.printStackTrace();
					} finally {
						lock.unlock();
					}
				}
			};
			t.start();
		}
	}

	public static void main(String[] args) {
		runSync();
		runLock();
	}

}

下面是该示例代码的执行结果:

代码语言:javascript
复制
2016-04-20 11:25:36 runSync pos=1
2016-04-20 11:25:36 runSync pos=4
2016-04-20 11:25:36 runSync pos=2
2016-04-20 11:25:36 runSync pos=3
2016-04-20 11:25:36 runSync pos=0
2016-04-20 11:25:36 runLock pos=0
2016-04-20 11:25:37 runLock pos=1
2016-04-20 11:25:38 runLock pos=2
2016-04-20 11:25:39 runLock pos=3
2016-04-20 11:25:40 runLock pos=4

从输出结果可以看出,在匿名内部类中,synchronized的加锁操作不符合预期结果,各线程仍是乱序执行。相比之下,Lock的加锁操作符合预期,各线程按顺序依次执行。 点此查看Android开发笔记的完整目录

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2016年04月20日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 同步synchronized
    • 同步方法
      • 显式指纹(同步代码块)
        • 隐式指纹
        • 加锁Lock
          • 重入锁ReentrantLock
            • 读写锁ReentrantReadWriteLock
            • 匿名内部类的加锁
            领券
            问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档