微信扫一扫

028-83195727 , 15928970361
business@forhy.com

【Java并发编程】深入分析synchronized(三)

内部锁的重进入,synchronized代码块,synchronized方法2016-07-22

写在前面

   synchronized在网络游戏中应用还是比较多的,像购买商品、某场景NPC刷新、玩家之间建立婚姻关系、活动抢金币等等。如果这几个应用场景没有使用synchronized会有什么后果?

  • 购买商品:当多个玩家在同一时间购买某某商品时,如果没有加synchronized会使一个商品被多个玩家竞争,而竞争的结果是多个玩家购买到了同一商品。
  • 玩家之间建立婚姻关系:网络游戏中和现实世界一样,每一个玩家只能和另外一个玩家结婚,不支持一夫多妻或一妻多夫制的(土豪:我给你100万我要娶多个老婆 Game:我们的游戏是不会为了钱破坏游戏规则的 土豪:1000万 Game:请不要以为钱是万能的 土豪:10个亿 Game:银行卡号:xxxxxxxx ,我们把游戏卖给你啦!)。可以想想如果没有使用synchronized,当一个男性玩家同时和多个女性玩家结婚时,最后的结果会是怎么样...是的!废除了多年的一夫多妻制可能在今天花不了多少钱就能实现了
  • 活动抢金币:这个比较重要了,假如系统安排的活动金币数量是100万,如果没有加synchronized,结果是玩家抢到了1000万金币。那么你的leader会找到你,说:“XXX,你明天可以不用来上班了”。货币的重要性在游戏里和现实一样,游戏里也是一个独立的小世界,你的一个小小的失误可能会导致游戏内货币的通货膨胀,让玩家的经济受到损失而造成玩家的流失。

一、synchronized简介

  Java提供了强制性的锁机制:synchronized,可用来给对象和方法或者代码块加锁,当它锁定一个方法或者一个代码块的时候,同一时刻最多只有一个线程执行这段代码。当两个并发线程访问同一个对象object中的这个加锁同步代码块时,一个时间内只能有一个线程得到执行。另一个线程必须等待当前线程执行完这个代码块以后才能执行该代码块。然而,当一个线程访问object的一个加锁代码块时,另一个线程仍然可以访问该object中的非加锁代码块。

 synchronized 包括两种用法:synchronized方法和 synchronized 块。

二、synchronized的使用

    2.1 synchronized方法

public static synchronized void inc() {
    ....
}

  synchronized方法控制多个线程对该方法内的成员的并发访问,我们将inc方法申明为synchronized,所以同一时间只有一个线程可以访问inc方法。当第一个玩家进来后,会对inc方法加一把锁不让别的玩家访问,玩家二如果也想访问inc方法只能排队等候直到玩家一访问结束释放锁后,效果如下图。 虽然它现在是线程安全的了,但是这种方法过于极端,它的性能非常差。因为有时候我们需要共享的只是方法内的部分数据,其它数据是可以自由访问的,那么这个时候我们应该在项目中使用synchronized块。 

   


    2.2 synchronized代码块

  synchronized代码块控制线程访问的数据在synchronized(obj)或synchronized(this){}里面,同一时间也只能有一个线程可以访问,别的请求线程将被阻塞在 synchronized(obj){}外边,这样可以不影响别的线程访问不需要共享的数据。比如:inc() 玩家等级小于30 ,不满足条件程序直接return不用让线程也阻塞在synchronized代码块外边。

public void inc(Object obj) {
	if(obj == null)
	{
	<span style="white-space:pre">	</span>return;
	}
	synchronized (obj) {
		count++;
	}
}


public void inc(int lvl) {
       if(lvl < 30)//玩家等级小于30 返回
	{
		return;
	}
	synchronized (this) {
		count++;
	}
}

    2.3 对synchronized(this)的理解

一、当两个并发线程访问同一个对象object中的这个synchronized(this)同步代码块时,一个时间内只能有一个线程得到执行。另一个线程必须等待当前线程执行完这个代码块以后才能执行该代码块。

二、然而,另一个线程仍然可以访问该object中的非synchronized(this)同步代码块。
三、尤其关键的是,当一个线程访问object的一个synchronized(this)同步代码块时,其他线程对object中所有其它synchronized(this)同步代码块的访问将被阻塞。
四、第三个例子同样适用其它同步代码块,它就获得了这个object的对象锁。结果,其它线程对该object对象所有同步代码部分的访问都被暂时阻塞。
五、以上规则对其它对象锁同样适用。

以上是摘自百度百科对synchronized的理解,详细使用参考这篇文章:http://www.cnblogs.com/GnagWang/archive/2011/02/27/1966606.html

三、内部锁的重进入

  当一个线程请求其它线程已经占有的锁时,请求线程将被阻塞。然而内部锁是可重进入的,因此线程在试图获得它自己占有的锁时,请求会成功。重进入意味着锁的请求是基于“每线程”,而不是基于“每调用”的。重进入的实现是通过每个锁关联一个请求计数和一个占有它的线程。当计数为0时,认为锁时未被占有的。线程请求一个未被占有的锁时,JVM将记录锁的占有者,并且将请求计数置为1。如果同一线程再次请求这个锁,计数将递增;每次占用线程退出同步块,计数器值将递减。直到计数器达到0时,锁被释放。

【摘自JAVA并发编程实战】

  3.1代码示例


package com.game.lll.syn;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;


public class UnsafeCount {
	public static int count = 0;
	static LoggingWidget loggingWidget = new LoggingWidget();
	public static void inc() {
		loggingWidget.doSomething();
	}

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

		ExecutorService service=Executors.newFixedThreadPool(Integer.MAX_VALUE);

		for (int i = 0; i < 10; i++) {
			service.execute(new Runnable() {
				@Override
				public void run() {
					UnsafeCount.inc();
				}
			});
		}

		service.shutdown();
		//避免出现main主线程先跑完而子线程还没结束,在这里给予一个关闭时间
		service.awaitTermination(3000,TimeUnit.SECONDS);
		System.out.println("运行结果:UnsafeCount.count=" + UnsafeCount.count);
	}
}

package com.game.lll.syn;


public class LoggingWidget extends Widget{
	public synchronized void doSomething()
	{
		System.out.println("LoggingWidget"+UnsafeCount.count++);
		super.doSomething();
	}
}

package com.game.lll.syn;


public class Widget {
   public synchronized void doSomething()
   {
	   System.out.println("Widget"+UnsafeCount.count++);
   }
}


    3.2运行结果

LoggingWidget0
Widget1
LoggingWidget2
Widget3
LoggingWidget4
Widget5
LoggingWidget6
Widget7
LoggingWidget8
Widget9
LoggingWidget10
Widget11
LoggingWidget12
Widget13
LoggingWidget14
Widget15
LoggingWidget16
Widget17
LoggingWidget18
Widget19
运行结果:UnsafeCount.count=20

   3.3代码分析

 重进入方便了锁行为的封装,因此简化了面向对象并发代码的开发。上面代码子类覆写了父类的synchronized类型的方法,并调用父类中的方法。如果没有可重入的锁,这段代码将会产生死锁。因为Weight和 loggingWeight中的soSomething方法都是synchronized类型的,都会在处理前试图获得weight的锁。倘若内部锁不是可重入的,super.doSomething的调用者就永远无法得到weight的锁,因为锁已经被占有,导致线程会永久的延迟,等待着一个永远无法获得的锁。