如何让两个线程同时运行

Posted 2020-10-21 奔跑的蜗牛-

两个线程公用一个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();
            }
        }
  
    }
  
    /**
     * <pre>
     *     使用了wait 和notify 方法,实现了线程的通信.
     *     wait() 线程等待.  释放cpu ,释放锁
     *  notify() 唤醒线程.
     * </pre>
     * */
    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();
            }
        }
    }
}