如何让两个线程同时运行如何让两个线程同时运行

【如何让两个线程同时运行】两个线程公用一个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(); } } } }

转载于:https://www.cnblogs.com/clarke157/p/8289789.html