黑马程序员技术交流社区

标题: 线程安全问题 [打印本页]

---

作者: 范明正    时间: 2011-8-6 09:49
标题: 线程安全问题
为什么执行不出结果，哪出现了问题呢？

public class ThreadMain {
        public static void main(String args[]) {
                Q q = new Q();
                new Thread(new Producer(q)).start();
                new Thread(new Cousumer(q)).start();
        }
}

class Producer implements Runnable {
        Q q;

        public Producer(Q q) {
                super();
                this.q = q;
        }

        @Override
        public void run() {
                int i = 0;
                while (true) {
                        if (i == 0) {
                                q.put("zheng", "male");
                        } else {
                                q.put("zhao", "female");
                        }
                        i = (i + 1) % 2;
                }
        }

}

class Q {
        private String name = "unkown";
        private String sex = "unkown";
        private boolean bFull = false;

        public synchronized void put(String name, String sex) {
                if (bFull) {
                        try {
                                wait();
                        } catch (Exception e) {
                                // TODO: handle exception
                        }
                        this.name = name;
                        try {
                                Thread.sleep(1);
                        } catch (Exception e) {
                                // TODO: handle exception
                        }
                        this.sex = sex;
                        bFull = true;
                        notify();
                }
        }

        public synchronized void get() {
                if (!bFull) {
                        try {
                                wait();
                        } catch (Exception e) {
                                // TODO: handle exception
                        }
                        System.out.println(name);
                        System.out.println("：" + sex);
                        bFull = false;
                        notify();
                }
        }
}

class Cousumer implements Runnable {
        Q q;

        public Cousumer(Q q) {
                super();
                this.q = q;
        }

        @Override
        public void run() {
                while (true) {
                        q.get();
                }
        }

}

---

作者: 匿名    时间: 2011-8-7 16:15
标题: 线程问题
使用Thread类创建线程对象时语句应该是这样的吧！
Thread thread = new Thread();
thread.start();

---

作者: 匿名    时间: 2011-8-7 16:17
标题: 回复 沙发 的帖子
Q q = new Q();
new Thread(new Producer(q)).start();
这样跟你说的不是一样的吗，只是形式不太一样而已。

---

作者: 匿名    时间: 2011-8-7 16:24
多线程操作一般情况下不需要接受用户的指令.

---

作者: 匿名    时间: 2011-8-8 11:56
我认真读了你的程序，程序让人看起来有点晕。为什么得不到结果，大概你没有认真读你的程序吧。
你的程序运行过程是这样的：
有两个线程，一个生产者，一个消费者。
Cousumer线程执行到get方法中的wait(),会wait住，也就是睡死过去，要等到其他线程调用notify()方法才会醒过来。
Producer线程执行put方法时，由于bFull是false，所以if语句内容是不会执行的。
由于Cousumer线程没有得到其它线程调用notfiy()方法，所以后面代码肯定得不到执行，并且Producer线程bFull一直是false，所以if语句的里的notfiy方法一直得不到执行，故两个线程一直僵在那里。

---

作者: 匿名    时间: 2011-8-8 12:55
楼上说的很对，昨天时间仓促，没看清楚，今天仔细看了一下，你是让线程每sleep(1)然后打印zheng:mage和zhao:femate吧！
看看下面的代码如何，是不是输出你想要的结果：

public class ThreadMain {
    public static void main(String [] args){
            Q q = new Q();
            new Thread(new Producer(q)).start();
            new Thread(new Cousumer(q)).start();       
}
class Q {
           private String name = "unknown";
           private String sex = "unknown";
           private boolean bFull = false;
           //使用同步方法
           public synchronized void put(String name,String sex){
                   notify();// 线程重新运行
                       
                        this.name = name;
                        try {
                                Thread.sleep(1);
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                        this.sex = sex;
                        bFull = true;
                        try {
                                wait();// 线程中断运行
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                }          
        public synchronized void get() {
                notify();

                System.out.println(name);
                System.out.println(":" + sex);
                bFull = false;
                try {
                        wait();
                } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }
          
        }
class Producer implements Runnable {

         Q q;
    public Producer(Q q){
            super();
            this.q = q;
    }
    //覆盖public void run()方法；
        public void run() {
                // TODO Auto-generated method stub
     
     int i=0;
     while(true){
             if(i==0){
                     q.put("zheng","mate");
             }else{
                     q.put("zhao","femate");
             }
             i = (i+1)%2;
     }
        }
}
class Cousumer implements Runnable {
    Q q;
    public Cousumer(Q q){
            super();
            this.q=q;
    }
        public void run() {
                // TODO Auto-generated method stub
                while(true){
                q.get();
                }
               
        }

}

---

作者: 匿名    时间: 2011-8-8 14:05
这问题我昨天看了半天也看不出毛病，原来是这样子啊

---

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

黑马程序员IT技术论坛 X3.2