等待代码:

@Override

public void run() {
  try {

   while (isStart) {
    if (msg != null) {
     System.out.println("msg:"+msg);
     oos.writeObject(msg);
     oos.flush();

     if (msg.getType() == TranObjectType.LOGOUT) {
      // 如果是发送下线的消息，就直接跳出循环
      break;
     }
     synchronized (this) {
      wait();// 发送完消息后，线程进入等待状态
     }

    }

   }

   oos.close();// 循环结束后，关闭输出流和socket
   if (socket != null && !socket.isClosed())
    socket.close();
  } catch (InterruptedException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  }
 }
 

唤醒代码:

public void setMsg(TranObject msg) {
  this.msg = msg;
  synchronized (this) {
   notify();
  }
 }