摘要：前言方法是早期提供的一種基于的線程同步方法，本文先介紹相關(guān)的數(shù)據(jù)結(jié)構(gòu)類，然后從方法的內(nèi)部實(shí)現(xiàn)入手，簡(jiǎn)單分析相關(guān)的原理和實(shí)現(xiàn)類用于實(shí)現(xiàn)的定待和喚醒，不同平臺(tái)操作系統(tǒng)平臺(tái)對(duì)應(yīng)的定義在文件類的分配和釋放使用了對(duì)象緩存，靜態(tài)字段用于緩存當(dāng)前

Object wait/notify 方法是早期 JVM 提供的一種基于 Object Monitor 的線程同步方法，本文先介紹相關(guān)的數(shù)據(jù)結(jié)構(gòu)（類），然后從 wait/notify 方法的內(nèi)部實(shí)現(xiàn)入手，簡(jiǎn)單分析 Object Monitor 相關(guān)的原理和實(shí)現(xiàn)

Per-thread blocking support for JSR166. Basically, park acts like wait, uppark like notify

Park 類用于實(shí)現(xiàn) JavaThread 的定待（park/wait）和喚醒（unpark/notify），不同平臺(tái)（操作系統(tǒng)）

linux 平臺(tái)對(duì)應(yīng)的 PlatformParker 定義在 hotspot/src/os/linux/vm/os_linux.hpp 文件

class PlatformParker : public CHeapObj {
 protected:
  enum {
    REL_INDEX = 0,
    ABS_INDEX = 1
  };
  int _cur_index;  // which cond is in use: -1, 0, 1
  pthread_mutex_t _mutex[1];
  pthread_cond_t  _cond[2]; // one for relative times and one for abs.

 public:       // TODO-FIXME: make dtor private
  ~PlatformParker() { guarantee(0, "invariant"); }

 public:
  PlatformParker() {
    int status;
    status = pthread_cond_init(&_cond[REL_INDEX], os::Linux::condAttr());
    assert_status(status == 0, status, "cond_init rel");
    status = pthread_cond_init(&_cond[ABS_INDEX], NULL);
    assert_status(status == 0, status, "cond_init abs");
    status = pthread_mutex_init(_mutex, NULL);
    assert_status(status == 0, status, "mutex_init");
    _cur_index = -1; // mark as unused
  }
};

Parker 類的分配和釋放使用了對(duì)象緩存，靜態(tài)字段 FreeList 用于緩存當(dāng)前所有可用的 Parker，ListLock 用于實(shí)現(xiàn)對(duì) FreeList 鎖，靜態(tài)方法 Allocate 和 Release 用于分配和釋放 Parker

class Parker {
    ...
public:
    ...
    static Parker *Allocate(JavaThread *t);
    static void Release(Parker *e);
private:
    static Parker *volatile FreeList;
    static volatile int ListLock;
}

Allocate 方法首先嘗試從 FreeList 中獲取 Parker，在此之前要先獲取 ListLock;如果分配失敗則嘗試 new 一個(gè)新的 parker，最后設(shè)置 Parker 的 AssociatedWith 字段將 Parker 和 JavaThread 關(guān)聯(lián)

Parker * Parker::Allocate (JavaThread * t) {
  guarantee (t != NULL, "invariant") ;
  Parker * p ;

  // Start by trying to recycle an existing but unassociated
  // Parker from the global free list.
  // 8028280: using concurrent free list without memory management can leak
  // pretty badly it turns out.
  Thread::SpinAcquire(&ListLock, "ParkerFreeListAllocate");
  {
    p = FreeList;
    if (p != NULL) {
      FreeList = p->FreeNext;
    }
  }
  Thread::SpinRelease(&ListLock);

  if (p != NULL) {
    guarantee (p->AssociatedWith == NULL, "invariant") ;
  } else {
    // Do this the hard way -- materialize a new Parker..
    p = new Parker() ;
  }
  p->AssociatedWith = t ;          // Associate p with t
  p->FreeNext       = NULL ;
  return p ;
}

Object 類中的很多方法都是 native 方法，wait 也不例外

public final void wait() throws InterruptedException {
    wait(0);
}

public final native void wait(long timeout) throws InterruptedException;

wait 方法對(duì)應(yīng)的 native 函數(shù)為 JVM_MonitorWait

JVM_ENTRY(void, JVM_MonitorWait(JNIEnv* env, jobject handle, jlong ms))
  JVMWrapper("JVM_MonitorWait");
  Handle obj(THREAD, JNIHandles::resolve_non_null(handle));
  JavaThreadInObjectWaitState jtiows(thread, ms != 0);
  if (JvmtiExport::should_post_monitor_wait()) {
    JvmtiExport::post_monitor_wait((JavaThread *)THREAD, (oop)obj(), ms);

    // The current thread already owns the monitor and it has not yet
    // been added to the wait queue so the current thread cannot be
    // made the successor. This means that the JVMTI_EVENT_MONITOR_WAIT
    // event handler cannot accidentally consume an unpark() meant for
    // the ParkEvent associated with this ObjectMonitor.
  }
  ObjectSynchronizer::wait(obj, ms, CHECK);
JVM_END

它首先調(diào)用 JNIHandles::resolve_non_null 函數(shù)將 jobject 類型的 handle 轉(zhuǎn)化為 oop（關(guān)于 oop 和 Handle 概念可以參考之前的系列文章），然后調(diào)用 ObjectSynchronizer 類的靜態(tài)方法 wait，這里出現(xiàn)了第一個(gè)和 Object Monitor 相關(guān)的類 ObjectSynchronizer，先做個(gè)標(biāo)記，接著往下看

int ObjectSynchronizer::wait(Handle obj, jlong millis, TRAPS) {
  if (UseBiasedLocking) {
    BiasedLocking::revoke_and_rebias(obj, false, THREAD);
    assert(!obj->mark()->has_bias_pattern(), "biases should be revoked by now");
  }
  if (millis < 0) {
    TEVENT(wait - throw IAX);
    THROW_MSG_0(vmSymbols::java_lang_IllegalArgumentException(),
        "timeout value is negative");
  }
  ObjectMonitor* monitor = ObjectSynchronizer::inflate(THREAD,
                                                       obj(),
                                                       inflate_cause_wait);

  DTRACE_MONITOR_WAIT_PROBE(monitor, obj(), THREAD, millis);
  monitor->wait(millis, true, THREAD);

  // This dummy call is in place to get around dtrace bug 6254741.  Once
  // that"s fixed we can uncomment the following line, remove the call
  // and change this function back into a "void" func.
  // DTRACE_MONITOR_PROBE(waited, monitor, obj(), THREAD);
  return dtrace_waited_probe(monitor, obj, THREAD);
}

這里出現(xiàn)了第二個(gè)類 ObjectMonitor（主角），通過(guò) ObjectSynchronizer::inflate 方法獲取對(duì)象的 ObjectMonitor 后調(diào)用 monitor 的 wait 方法.