zoukankan      html  css  js  c++  java
  • [置顶] 深入探析Java线程锁机制

    今天在iteye上提了一个关于++操作和线程安全的问题,一位朋友的回答一言点醒梦中人,至此我对Java线程锁有了更加深刻的认识。在这里也做个总结供大家参考。

          先看几段代码吧!

       代码一:

    1. public class TestMultiThread2 implements Runnable{  
    2.   
    3.     private static Object o = new Object();  
    4.       
    5.     private static Integer si = 0;  
    6.       
    7.     private static AtomicInteger flag = new AtomicInteger();  
    8.       
    9.     @Override  
    10.     public void run() {  
    11.         for(int k=0;k<2000000;k++){  
    12.             synchronized(si){  
    13.                 si++;  
    14.             }  
    15.         }  
    16.         flag.incrementAndGet();  
    17.     }  
    18.     public static void main(String[] args) throws InterruptedException{  
    19.         TestMultiThread2 t1 = new TestMultiThread2();  
    20.         TestMultiThread2 t2 = new TestMultiThread2();  
    21.         ExecutorService exec1 = Executors.newCachedThreadPool();  
    22.         ExecutorService exec2 = Executors.newCachedThreadPool();  
    23.         exec1.execute(t1);  
    24.         exec2.execute(t2);  
    25.         while(true){  
    26.             if(flag.intValue()==2){  
    27.                 System.out.println("si>>>>>"+si);      
    28.                 break;  
    29.             }  
    30.             Thread.sleep(50);  
    31.         }  
    32.   
    33.           
    34.     }     
    35.       
    36. }  

       为了方便看,重复的就不插入了,从代码二到代码四只插入run()方法中的代码,其他地方都一样

      代码二:

    1. public void run() {    
    2.     for(int k=0;k<2000000;k++){    
    3.         synchronized(o){    
    4.             si++;    
    5.         }    
    6.     }    
    7.     flag.incrementAndGet();    
    8. }    

      代码三:

    1. public void run() {    
    2.     for(int k=0;k<2000000;k++){    
    3.         synchronized(o){    
    4.             si++;    
    5.             o = new Object();    
    6.         }    
    7.     }    
    8.     flag.incrementAndGet();    
    9. }    

        代码四: 

    1. public void run() {    
    2.      for(int k=0;k<2000000;k++){    
    3.          synchronized(o){    
    4.              si++;    
    5.              Object temp = o;    
    6.              o = new Object();    
    7.              o = temp;    
    8.          }    
    9.      }    
    10.      flag.incrementAndGet();    
    11.  }    

      有了这四段代码我想问题大概可以说明白了,这里说一下输出吧。

      代码一:<4000000

      代码二:=4000000

      代码三:<4000000

      代码四:<4000000(PS:这个结果非常接近4000000)

          这里说明一下我测试中碰到的问题,代码四一直没有跑出我想要的结果,主要是开始我设的循环次数太少,其实这里如果要这个现象更加明显一些可以在中间多new 几个Object 如下面的代码五,这样现象就比较明显了.

      代码五:

    1. public void run() {    
    2.     for(int k=0;k<2000000;k++){    
    3.         synchronized(o){    
    4.             si++;    
    5.             Object temp = o;    
    6.             for(int m=0;m<10;m++){    
    7.                 o = new Object();    
    8.             }    
    9.             o = temp;    
    10.         }    
    11.     }    
    12.     flag.incrementAndGet();    
    13. }    

     为什么会出现上面的现象:

         代码一:当si做++操作后(可以直接看字节码,这里不贴了),在putstatic之前有几步操作,就是我们常说的非原子操作,而这时候si已经不是原来的对象了,这样锁对另外一个线程来说就失效了,我想代码三和代码四就是最好的佐证,代码四更有说服力。当时因为没有出现预想的情况困惑了挺久。

        其实这里用字节码来解释还不是很严谨,最好的当然直接是汇编代码

        如有什么问题还希望各位读者指正。

    zhuanzi:http://blog.csdn.net/luohuacanyue/article/details/8307617

  • 相关阅读:
    Docker-CentOS系统安装Docker
    Docker-准备Docker环境
    Docker系列-文章汇总
    商品订单库存一致性问题的思考
    java模板、工厂设计模式在项目中的重构
    2018Java年底总结
    java的AQS中enp没有同步代码块为啥是原子操作
    java使用awt包在生产环境docker部署时出现中文乱码的处理
    初探装饰器模式
    开灯问题
  • 原文地址:https://www.cnblogs.com/pricks/p/3877133.html
Copyright © 2011-2022 走看看