线程间相互调用 , 主要是wait()和notify()方法的使用.
下面小例子实现了简单的线程同步,两个线程间间隔执行:
增加的类:

public class IncreaseThread extends Thread {
private NumberHolder numberHolder;

public IncreaseThread(NumberHolder numberHolder) {
    this.numberHolder = numberHolder;
}

@Override
public void run() {
    for (int i = 0; i < 20; ++i) {
        // 进行一定的延时
        try {
            Thread.sleep((long) Math.random() * 1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        // 进行增加操作
        numberHolder.increase();
    }
  }
}

减少的类,实现和增加基本一样,只不过一个是加,一个是减:

public class DecreaseThread extends Thread {
  private NumberHolder numberHolder;

  public DecreaseThread(NumberHolder numberHolder) {
    this.numberHolder = numberHolder;
  }
@Override
public void run() {
    for (int i = 0; i < 20; ++i) {
        // 进行一定的延时
        try {
            Thread.sleep((long) Math.random() * 1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        // 进行减少操作
        numberHolder.decrease();
    }
  }
}

方法调用的类:

public class NumberHolder {
// wait 和notify方法必须在同步方法或者同步代码块中进行调用，也就是说必须获得
// 锁才可以调用wait 和notify 方法
private int number = 0;

public synchronized void increase() {
    if (0 != number) {
        try {
            // 调用wait 他会释放锁 ，等待其他线程唤醒
            wait();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    // 能执行到这里说明已经被唤醒
    // 并且number为0
    number++;
    System.out.println(number);
    // 通知在等待的线程
    notify();
}

public synchronized void decrease() {
    if (0 == number) {
        try {
            wait();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    // 能执行到这里说明已经被唤醒
    // 并且number不为0
    number--;
    System.out.println(number);
    notify();
    // notifyAll();
    }
}

测试类:

public static void main(String[] args) {
    NumberHolder numberHolder = new NumberHolder();
    Thread t1 = new IncreaseThread(numberHolder);
    Thread t2 = new DecreaseThread(numberHolder);
    t1.start();
    t2.start();
}