黑马程序员技术交流社区

标题: 多线程疑问 [打印本页]
作者: EDDY_Liang    时间: 2014-9-28 12:38
标题: 多线程疑问
本帖最后由 EDDY_Liang 于 2014-9-28 14:26 编辑

为什么我试了很多次就是不出来统一数字生产多次或消费多次的情况啊？？是因为cpu是双核的缘故吗？？
视频里说是会出问题的。。。。
朋友们看一下谢谢！

  1. public class Produce$CustomerDemo {

  3.         public static void main(String[] args) {
  4.                 Resource s = new Resource("烤鸭");
  5.                 Producer p = new Producer(s);
  6.                 Consumer c = new Consumer(s);
  7.         
  8.                 Thread t1 = new Thread(p);
  9.                 Thread t3 = new Thread(p);
  10.                 Thread t2 = new Thread(c);
  11.                 Thread t4 = new Thread(c);
  12.                 t1.start();
  13.                 t3.start();
  14.                 t2.start();
  15.                 t4.start();

  17.         }

  19. }

  21. class Resource {
  22.         String thing;

  24.         Resource(String thing) {
  25.                 this.thing = thing;
  26.         }

  28.         boolean flag = false;
  29.         int count = 1;

  31.         public void set() {
  32.                 while (true)
  33.                         synchronized (this) {
  34.                                 if (!flag) {
  35.                                         System.out.println(thing + ".....生产" + count);
  36.                                         flag = true;
  37.                                 }
  38.                         }

  40.         }

  42.         public void out() {
  43.                 while (true)
  44.                         synchronized (this) {
  45.                                 if (flag) {
  46.                                         System.out.println(thing + "..............消费" + count++);
  47.                                         flag = false;
  48.                                 }
  49.                         }
  50.         }

  52. }

  54. class Producer implements Runnable {
  55.         private Resource R;

  57.         Producer(Resource R) {
  58.                 this.R = R;
  59.         }

  61.         @Override
  62.         public void run() {
  63.                 R.set();

  65.         }

  67. }

  69. class Consumer implements Runnable {
  70.         private Resource R;

  72.         Consumer(Resource R) {
  73.                 this.R = R;
  74.         }

  76.         @Override
  77.         public void run() {
  78.                 R.out();

  80.         }

  82. }
复制代码




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