【Java并发编程】深入分析synchronized(三)
内部锁的重进入,synchronized代码块,synchronized方法2016-07-22
synchronized在网络游戏中应用还是比较多的,像购买商品、某场景NPC刷新、玩家之间建立婚姻关系、活动抢金币等等。如果这几个应用场景没有使用synchronized会有什么后果?
Java提供了强制性的锁机制:synchronized,可用来给对象和方法或者代码块加锁,当它锁定一个方法或者一个代码块的时候,同一时刻最多只有一个线程执行这段代码。当两个并发线程访问同一个对象object中的这个加锁同步代码块时,一个时间内只能有一个线程得到执行。另一个线程必须等待当前线程执行完这个代码块以后才能执行该代码块。然而,当一个线程访问object的一个加锁代码块时,另一个线程仍然可以访问该object中的非加锁代码块。
synchronized 包括两种用法:synchronized方法和
synchronized 块。
public static synchronized void inc() { .... }
synchronized方法控制多个线程对该方法内的成员的并发访问,我们将inc方法申明为synchronized,所以同一时间只有一个线程可以访问inc方法。当第一个玩家进来后,会对inc方法加一把锁不让别的玩家访问,玩家二如果也想访问inc方法只能排队等候直到玩家一访问结束释放锁后,效果如下图。 虽然它现在是线程安全的了,但是这种方法过于极端,它的性能非常差。因为有时候我们需要共享的只是方法内的部分数据,其它数据是可以自由访问的,那么这个时候我们应该在项目中使用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++; } }
一、当两个并发线程访问同一个对象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并发编程实战】
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++); } }