黑马程序员技术交流社区

标题: 【记录】代码练习-线程间通信 [打印本页]
作者: Kevin.Kang    时间: 2015-8-5 14:44
标题: 【记录】代码练习-线程间通信
本帖最后由 Kevin.Kang 于 2015-8-5 15:03 编辑

针对同一资源有不同的线程进行操作
例如：卖票，需要有卖票的进程，还需要有生产票的进程
          通过对学生信息的设置和获取，写一个简单的线程间通信案例

测试类：StudentDemo
  1. package com.kxg_13;
  2. /*
  3. * 资源类：Student
  4. * 设置学生信息：SetThread
  5. * 获取学生信息：GetThread
  6. * 测试类：StudentDemo
  7. *
  8. * 注意：
  9. *                 设置和获取线程使用的资源应该是同一个，所以把这个资源在外界创建出来，通过构造方法传递给其他类。
  10. *
  11. */
  12. public class StudentDemo {
  13.         public static void main(String[] args) {
  14. //                创建资源
  15.                 Student s = new Student();

  17. //                创建Set和Get对象
  18.                 SetThread st = new SetThread(s);
  19.                 GetThread gt = new GetThread(s);

  21. //                创建线程
  22.                 Thread t1 = new Thread(st);
  23.                 Thread t2 = new Thread(gt);

  25. //                开启线程
  26.                 t1.start();
  27.                 t2.start();
  28.         }
  29. }
复制代码
资源类：Student
  1. package com.kxg_13;
  2. /*
  3. * 定义学生类
  4. */
  5. public class Student {
  6.         String name;
  7.         int age;
  8. }
复制代码
设置学生信息：SetThread
  1. package com.kxg_13;

  3. /*
  4. * 设置学生信息的线程
  5. */
  6. public class SetThread implements Runnable {

  8.         private Student s;

  10.         public SetThread(Student s) {
  11.                 this.s = s;
  12.         }
  13.         @Override
  14.         public void run() {
  15.                 s.name = "小明";
  16.                 s.age = 5;
  17.         }
  18. }
复制代码
获取学生信息：GetThread
  1. package com.kxg_13;

  3. /*
  4. * 设置获取学生信息的线程
  5. */
  6. public class GetThread implements Runnable {

  8.         private Student s;

  10.         public GetThread(Student s) {
  11.                 this.s = s;
  12.         }
  13.         @Override
  14.         public void run() {
  15.                 System.out.println(s.name + "：" + s.age);
  16.         }
  17. }
复制代码



作者: Kevin.Kang    时间: 2015-8-5 18:13
最终版：
测试类：
  1. package com.kxg_03;
  2. public class StudentDemo {
  3.         public static void main(String[] args) {
  4.                 // 创建资源
  5.                 Student s = new Student();

  7.                 // 创建SetThread和GetThread对象
  8.                 SetThread st = new SetThread(s);
  9.                 GetThread gt = new GetThread(s);

  11.                 // 创建线程
  12.                 Thread t1 = new Thread(st);
  13.                 Thread t2 = new Thread(gt);

  15.                 // 开启线程
  16.                 t1.start();
  17.                 t2.start();
  18.         }
  19. }
复制代码
资源类：
  1. package com.kxg_03;
  2. /*
  3. * 定义学生类
  4. */
  5. public class Student {
  6.         String name;
  7.         int age;
  8.         boolean flag;// 用来判断是否存在资源，默认是flash，没有资源

  10.         public synchronized void set(String name, int age) {
  11.                 // 生产者，如果有数据就等待
  12.                 if (!this.flag) {
  13.                         try {
  14.                                 this.wait();
  15.                         } catch (InterruptedException e) {
  16.                                 e.printStackTrace();
  17.                         }
  18.                 }
  19.                 // 设置数据
  20.                 this.name = name;
  21.                 this.age = age;
  22.                 // 修改标记
  23.                 this.flag = false;
  24.                 // 唤醒线程
  25.                 this.notify();
  26.         }

  28.         public synchronized void get() {
  29.                 if (this.flag) {
  30.                         try {
  31.                                 this.wait();
  32.                         } catch (InterruptedException e) {
  33.                                 e.printStackTrace();
  34.                         }
  35.                 }
  36.                 System.out.println(this.name + ":" + this.age);
  37.                 // 修改标记
  38.                 this.flag = true;
  39.                 // 唤醒线程
  40.                 this.notify();
  41.         }
  42. }
复制代码
设置类：
  1. package com.kxg_03;

  3. /*
  4. * 设置学生信息的线程
  5. */
  6. public class SetThread implements Runnable {

  8.         private Student s;
  9.         private int i;

  11.         public SetThread(Student s) {
  12.                 this.s = s;
  13.         }
  14.         @Override
  15.         public void run() {
  16.                 while (true) {
  17.                         if (i % 2 == 0) {
  18.                                 s.set("小明", 5);
  19.                         } else {
  20.                                 s.set("汪汪", 2);
  21.                         }
  22.                         i++;
  23.                 }
  24.         }
  25. }
复制代码
获取类：
  1. package com.kxg_03;

  3. /*
  4. * 设置获取学生信息的线程
  5. */
  6. public class GetThread implements Runnable {

  8.         private Student s;

  10.         public GetThread(Student s) {
  11.                 this.s = s;
  12.         }
  13.         @Override
  14.         public void run() {
  15.                 while (true) {
  16.                         s.get();
  17.                 }
  18.         }
  19. }
复制代码







欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2