java多线程（转载）三

那么如何解决呢？

1）加入同步

2）加入等待和唤醒

先来看看加入同步会是如何。

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99

class Info {           public String getName() {         return name;     }       public void setName(String name) {         this.name = name;     }       public int getAge() {         return age;     }       public void setAge(int age) {         this.age = age;     }       public synchronized void set(String name, int age){         this.name=name;         try{             Thread.sleep(100);         }catch (Exception e) {             e.printStackTrace();         }         this.age=age;     }           public synchronized void get(){         try{             Thread.sleep(100);         }catch (Exception e) {             e.printStackTrace();         }         System.out.println(this.getName()+"<===>"+this.getAge());     }     private String name = "Rollen";     private int age = 20; }   /**  * 生产者  * */ class Producer implements Runnable {     private Info info = null;       Producer(Info info) {         this.info = info;     }       public void run() {         boolean flag = false;         for (int i = 0; i < 25; ++i) {             if (flag) {                                   this.info.set("Rollen", 20);                 flag = false;             } else {                 this.info.set("ChunGe", 100);                 flag = true;             }         }     } }   /**  * 消费者类  * */ class Consumer implements Runnable {     private Info info = null;       public Consumer(Info info) {         this.info = info;     }       public void run() {         for (int i = 0; i < 25; ++i) {             try {                 Thread.sleep(100);             } catch (Exception e) {                 e.printStackTrace();             }             this.info.get();         }     } }   /**  * 测试类  * */ class hello {     public static void main(String[] args) {         Info info = new Info();         Producer pro = new Producer(info);         Consumer con = new Consumer(info);         new Thread(pro).start();         new Thread(con).start();     } }

【运行结果】：

Rollen<===>20

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

Rollen<===>20

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

从运行结果来看，错乱的问题解决了，现在是Rollen 对应20，ChunGe对于100

，但是还是出现了重复读取的问题，也肯定有重复覆盖的问题。如果想解决这个问题，就需要使用Object类帮忙了、

，我们可以使用其中的等待和唤醒操作。

要完成上面的功能，我们只需要修改Info类饥渴，在其中加上标志位，并且通过判断标志位完成等待和唤醒的操作，代码如下：

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119

class Info {           public String getName() {         return name;     }       public void setName(String name) {         this.name = name;     }       public int getAge() {         return age;     }       public void setAge(int age) {         this.age = age;     }       public synchronized void set(String name, int age){         if(!flag){             try{                 super.wait();             }catch (Exception e) {                 e.printStackTrace();             }         }         this.name=name;         try{             Thread.sleep(100);         }catch (Exception e) {             e.printStackTrace();         }         this.age=age;         flag=false;         super.notify();     }           public synchronized void get(){         if(flag){             try{                 super.wait();             }catch (Exception e) {                 e.printStackTrace();             }         }                   try{             Thread.sleep(100);         }catch (Exception e) {             e.printStackTrace();         }         System.out.println(this.getName()+"<===>"+this.getAge());         flag=true;         super.notify();     }     private String name = "Rollen";     private int age = 20;     private boolean flag=false; }   /**  * 生产者  * */ class Producer implements Runnable {     private Info info = null;       Producer(Info info) {         this.info = info;     }       public void run() {         boolean flag = false;         for (int i = 0; i < 25; ++i) {             if (flag) {                                   this.info.set("Rollen", 20);                 flag = false;             } else {                 this.info.set("ChunGe", 100);                 flag = true;             }         }     } }   /**  * 消费者类  * */ class Consumer implements Runnable {     private Info info = null;       public Consumer(Info info) {         this.info = info;     }       public void run() {         for (int i = 0; i < 25; ++i) {             try {                 Thread.sleep(100);             } catch (Exception e) {                 e.printStackTrace();             }             this.info.get();         }     } }   /**  * 测试类  * */ class hello {     public static void main(String[] args) {         Info info = new Info();         Producer pro = new Producer(info);         Consumer con = new Consumer(info);         new Thread(pro).start();         new Thread(con).start();     } }

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27

【程序运行结果】： Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 ChunGe<===>100 Rollen<===>20 先在看结果就可以知道，之前的问题完全解决。