深入理解Java多线程

本文主要就Hollis深入理解Java多线程系列文章的总结。原文详见[HollisChuang's Blog,欢迎大家关注!

Synchronized实现原理

public class SynchronizedTest {

    public synchronized void doSth(){
        System.out.println("Hello World");
    }

    public void doSth1(){
        synchronized (SynchronizedTest.class){
            System.out.println("Hello World");
        }
    }
}

同步代码块使用monitorentermonitorexit两个指令实现。执行monitorenter指令加锁,执行monitorexit指令释放锁。
同步方法使用ACC_SYNCHRONIZED关键字隐式的对方法加锁,当线程执行的方法被标上ACC_SYNCHRONIZED时,需要先获得锁才能执行该方法。
每个对象维护一个计数器,记录对象被锁次数,当一个线程获得锁时,该计数器自增1,当同一个线程释放锁是,该计数器减1。

Java对象模型

每一个Java类在被JVM加载的时候,JVM会为这个类创建一个instanceKlass,保存在方法区,用于在JVM层表示该Java类。当我们使用new创建一个对象时,JVM会创建一个instanceOopDesc对象,包含两部分信息:对象头及元数据。对象头中有一些运行时数据,其中包括多线程相关锁的信息。元数据维护的指针指向对象所属类的instanceKlass

Java对象头

class oopDesc {
    friend class VMStructs;
    private:
    volatile markOop  _mark;
    union _metadata {
        wideKlassOop    _klass;
        narrowOop       _compressed_klass;
  } _metadata;
}

markword设计是将存储空间划分为多个比特位,并在不同对象状态下赋予比特位含义。下图为32为虚拟机


2018-12-12.16.04.25-ObjectHead.png

Monitor实现原理

同步方法和同步代码块都是基于monitor实现的。

操作系统中管程

管程是一种程序结构,结构内多个多个子程序(对象或模块)形成多个共享线程互斥访问共享资源。这些共享资源一般是硬件资源或者共享变量。管程实现了在一个时间点最多只有一个线程执行管程中某个子程序。

Java线程同步相关之Monitor

对象的所有方法互斥执行,一个monitor只有一个运行许可,任一线程进入任何方法都需要获得这个许可,离开时归还许可。提供singal机制,允许正在持有许可的线程放弃许可,等待某个条件成立后当前线程可以通知等待这个条件变量的线程去重新获取许可。

Monitor实现

Java虚拟机(HotSpot)的monitor是基于C++实现的,主要数据结构如下

 ObjectMonitor() {
    _header       = NULL;
    _count        = 0;
    _waiters      = 0,
    _recursions   = 0;
    _object       = NULL;
    _owner        = NULL;
    _WaitSet      = NULL;
    _WaitSetLock  = 0 ;
    _Responsible  = NULL ;
    _succ         = NULL ;
    _cxq          = NULL ;
    FreeNext      = NULL ;
    _EntryList    = NULL ;
    _SpinFreq     = 0 ;
    _SpinClock    = 0 ;
    OwnerIsThread = 0 ;
  }

关键属性如下:

_owner      // 指向持有ObjectMonitor对象的线程
_WaitSet    // 存放处于wait状态的线程队列
_EntryList  // 存在处于wait状态的线程队列
_recursion  // 锁的重入次数
_count      // 用来记录该线程获取锁的次数

当多个线程同时访问一段同步代码时,会首先进入EntryList 队列中,当某个线程获取到对象的monitor后进入Owner 区域并把ower 变量设置为当前线程,同时monitor中计数器加1。即线程获得锁。
当持有monitor的线程调用wait() 方法,将释放当前持有monitor,owner变量恢复为null,count减1,同时WaitSet集合中等待线程会被唤醒。当前线程执行完毕也会释放monitor。如下图所示。

2018-12-12.17.11.38-monitor.png

获取锁

void ATTR ObjectMonitor::enter(TRAPS) {
    Thread * const Self = THREAD ;
    void * cur ;
    //通过CAS尝试把monitor的`_owner`字段设置为当前线程
    cur = Atomic::cmpxchg_ptr (Self, &_owner, NULL) ;
    //获取锁失败
    if (cur == NULL) {assert (_recursions == 0, "invariant") ;
         assert (_owner      == Self, "invariant") ;
         // CONSIDER: set or assert OwnerIsThread == 1
         return ;
    }
    // 如果旧值和当前线程一样,说明当前线程已经持有锁,此次为重入,_recursions自增,并获得锁。
    if (cur == Self) { 
        // TODO-FIXME: check for integer overflow!  BUGID 6557169.
        _recursions ++ ;
        return ;
    }

    // 如果当前线程是第一次进入该monitor,设置_recursions为1,_owner为当前线程
    if (Self->is_lock_owned ((address)cur)) { 
        assert (_recursions == 0, "internal state error");
        _recursions = 1 ;
        // Commute owner from a thread-specific on-stack BasicLockObject address to
        // a full-fledged "Thread *".
        _owner = Self ;
        OwnerIsThread = 1 ;
        return ;
    }

    // 省略部分代码。
    // 通过自旋执行ObjectMonitor::EnterI方法等待锁的释放
    for (;;) {
      jt->set_suspend_equivalent();
      // cleared by handle_special_suspend_equivalent_condition()
      // or java_suspend_self()

      EnterI (THREAD) ;

      if (!ExitSuspendEquivalent(jt)) break ;

      //
      // We have acquired the contended monitor, but while we were
      // waiting another thread suspended us. We don't want to enter
      // the monitor while suspended because that would surprise the
      // thread that suspended us.
      //
          _recursions = 0 ;
      _succ = NULL ;
      exit (Self) ;

      jt->java_suspend_self();
    }
}
2018-12-12.17.13.35-lockenter.png

释放锁

void ATTR ObjectMonitor::exit(TRAPS) {
   Thread * Self = THREAD ;
   //如果当前线程不是Monitor的所有者
   if (THREAD != _owner) { 
     if (THREAD->is_lock_owned((address) _owner)) { // 
       // Transmute _owner from a BasicLock pointer to a Thread address.
       // We don't need to hold _mutex for this transition.
       // Non-null to Non-null is safe as long as all readers can
       // tolerate either flavor.
       assert (_recursions == 0, "invariant") ;
       _owner = THREAD ;
       _recursions = 0 ;
       OwnerIsThread = 1 ;
     } else {
       // NOTE: we need to handle unbalanced monitor enter/exit
       // in native code by throwing an exception.
       // TODO: Throw an IllegalMonitorStateException ?
       TEVENT (Exit - Throw IMSX) ;
       assert(false, "Non-balanced monitor enter/exit!");
       if (false) {
          THROW(vmSymbols::java_lang_IllegalMonitorStateException());
       }
       return;
     }
   }
    // 如果_recursions次数不为0.自减
   if (_recursions != 0) {
     _recursions--;        // this is simple recursive enter
     TEVENT (Inflated exit - recursive) ;
     return ;
   }

   //省略部分代码,根据不同的策略(由QMode指定),从cxq或EntryList中获取头节点,通过ObjectMonitor::ExitEpilog方法唤醒该节点封装的线程,唤醒操作最终由unpark完成。
2018-12-12.17.13.53-lockexit.png

注意 sychronized操作是重量级操作,需要将用户态转换到内核态。

Java虚拟机锁优化技术

线程状态

分为以下五种,分别为:初始状态(New)就绪状态(Runnable)运行状态(Running)阻塞状态(Blocked)死亡状态(Dead)。各种状态间转换如下图所示:

2018-12-12.17.27.29-thread.png

自旋锁

线程不放弃处理器执行时间,等待共享资源可访问后继续执行,自旋锁只是将当前线程不停执行循环体并检查共享资源,不改变线程状态。

注意:线程数不停增加是导致性能下降。

锁消除

在使用synchronized时,如果使用JIT逃逸分析发现并无线程安全问题,则会使用锁消除。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 213,014评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,796评论 3 386
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,484评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,830评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,946评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,114评论 1 292
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,182评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,927评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,369评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,678评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,832评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,533评论 4 335
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,166评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,885评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,128评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,659评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,738评论 2 351

推荐阅读更多精彩内容