两个线程公用一个Object对象，监控线程先调用Object的wait()，添加线程执行插入，插入之后调用Object的notify()

如此反复

在run方法里加锁synchronizide，同时在锁的内部使用wait方法和notify方法使用就ok了

public class ThreadTest2 {    public static void main(String[] args) {        // 创建任务        // 任务一: 读取数据库,给对象赋值        Person p = new Person();        Input input = new Input(p);        // 任务二:将对象的数据取出,保存到数据中        Output output = new Output(p);          // 创建线程,一个线程读取数据.        Thread t1 = new Thread(input);        // 创建线程,一个线程写出数据        Thread t2 = new Thread(output);          t1.start();        t2.start();    }}  /** * 该任务模拟读取信息并使用对象存储读取的数据. * */class Input implements Runnable {    Person p;      Input(Person p) {        this.p = p;    }      int i = 0;      /**     * 通过循环,模拟线程不停的从数据库中读取数据,并给对象赋值.     */    public void run() {        while (true) {            if (i % 2 == 0) {                p.write("jack", "male");            } else {                p.write("丽丽", "女");            }            i++;        }    }}  /** * 该任务定义读取对象中的数据,并写出到数据库中. */class Output implements Runnable {    Person p;      Output(Person p) {        this.p = p;    }      /**     * 模拟不停=取出对象的数据,并保存到数据中.     */    public void run() {        while (true) {            p.read();        }    }}  class Person {    private String name;    private String gender;      // flag 表示开关,默认是断开    boolean flag = false;      public synchronized void write(String name, String gender) {        // 当开关是断开的时候,该线程给对象赋值.        if (!flag) {            this.name = name;            this.gender = gender;              // 给对象赋值完毕,需要将开关关闭.            flag = true;            notify(); // 线程唤醒机制.唤醒线程.            // 让Input线程给对象赋值完数据,该线程应该等待,不能再执行.            try {                this.wait(); // 可以让当前Input 线程等待. 等待Output 读取对象数据.            } catch (InterruptedException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }        }      }      /**     * 
     *     使用了wait 和notify 方法,实现了线程的通信.     *     wait() 线程等待.  释放cpu ,释放锁     *  notify() 唤醒线程.     * 
     * */    public synchronized void read() {        // 如果开关是关闭,读取对象的数据.        if (flag) {            System.out.println(this.name + "---" + this.gender);            // 取完对象的数据,修改开关,将开关断开.            flag = false;            // 唤醒线程            notify();            // 线程Output 将对象的数据读取完毕后,也应该等待,等待Input再次给对象赋值.            try {                this.wait();            } catch (InterruptedException e) {                e.printStackTrace();            }        }    }}