java本身的观察者模式

import java.util.Observable;
import java.util.Observer;

/**
 * 一个观察者观察多个被观察者
 * @author zengst
 * @date
 */
public class ObserverTest {
 public static void main(String args[]){
  
  BeingWatched2 bw2 = new BeingWatched2();
  BeingWatched1 bw1 = new BeingWatched1();
  Watch w = new Watch();
  bw2.addObserver(w);
  bw1.addObserver(w);
  
  bw2.counter2();
  bw1.counter1();
 }
}

class Watch implements Observer{
 
 //这里的args是被观察者调用notifyObservers方法时传递的参数
 //这里的o是被观察者的父类，因为一个观察者可以观者多个被观察者
 //所以这里无法直接通过o调用某一个被观察者定义的方法
 @Override
 public void update(Observable o, Object arg) {
  
  if(o instanceof BeingWatched2){
   
   BeingWatched2 w = (BeingWatched2) o;
   System.out.println("我是第二个被观察者"+arg);
   System.out.println("################"+w.cry());
   System.out.println("@@@@@@@@@@@@@@@@"+o.toString());
   
  }else if(o instanceof BeingWatched1){
   
   BeingWatched1 w = (BeingWatched1) o;
   System.out.println("我是第一个被观察者"+arg);
   System.out.println("################"+w.cry());
   System.out.println("@@@@@@@@@@@@@@@@"+o.toString());
  }
  
 }
}
class BeingWatched2 extends Observable{
 public int j =888;
 
 public int cry(){
  System.out.println("I am crying--"+j);
  return j;
 }
 void counter2(){
  try{
   for(int i=0; i<5;i++){
    setChanged();
    notifyObservers(i+"第二个被观察者");
    Thread.sleep(1000);
   }
  }catch(Exception e){
   e.printStackTrace();
  }
 }
}

class BeingWatched1 extends Observable{
 public int j =999;
 
 public int cry(){
  System.out.println("I am crying--"+j);
  return j;
 }
 void counter1(){
  try{
   for(int i=0; i<5;i++){
    setChanged();
    notifyObservers(i+"第一个被观察者");
    Thread.sleep(1000);
   }
  }catch(Exception e){
   e.printStackTrace();
  }
 }
}