RPC网络同步设计

public Object get() {         synchronized (this) { // 旋锁             while (!isDone) { // 是否有结果了                 wait(); //没结果是释放锁，让当前线程处于等待状态             }         } }

1 2 3 4 5 6 7

private void setDone(Response res) {         this.res = res;         isDone = true;         synchronized (this) { //获取锁，因为前面wait()已经释放了callback的锁了             notifyAll(); // 唤醒处于等待的线程         }     }