黑马程序员技术交流社区

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

---

作者: 周敏2011nc    时间: 2011-12-20 12:04
标题: 多线程问题


如有一个主线程和一个子线程，首先主线程执行50次，然后子线程执行10次，就这样循环50次，这样的题好解决（用到wait和notify就可以），如果再有一个子线程也要加入这个循环（该线程执行20次），如何实现？

该贴已经同步到 周敏2011nc的微博

---

作者: yunqiangshan    时间: 2011-12-20 21:28
用join()方法插入这个子线程，等到执行20次的子线程执行完，执行权回到主线程手里的时候，用join（）方法让主线程等待此子线程执行20次。

---

作者: 刘健    时间: 2011-12-20 21:57
楼主既然知道wait那也应该知道join()啊，用这个方法就可以实现啊

---

作者: 海中的游弋草    时间: 2011-12-20 22:13


毕老师的视频中讲到过这个问题的！你这里可以使用join()方法；在多线程中join可以用来临时加入线程执行。比如：当A线程执行到了B线程的.join()方法时，A就会等待，等B线程都执行完，A才会执行。

---

作者: 周敏2011nc    时间: 2011-12-21 09:37
谢谢各位  

---

作者: 周敏2011nc    时间: 2011-12-22 09:02


在网上找到一个新的办法，和大家分享分享：
package com.jx.thread.test;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ThreadConditionTest {

        /**
         * @param args
         * 在执行的时候发现这样一个问题：
         * 那就是这几个线程执行循环的次数以最少的循环次数那个线程为准
         * 这里就是三次过后就会不再输出了，所以在一般的情况下外层的循环
         * 次数一般情况下是一样的，不然可能会达不到效果，具体的次数要求可以在内部循环中完成
         */
        public static void main(String[] args) {
                // TODO Auto-generated method stub

                final Outputer outputer = new Outputer();

                new Thread(new Runnable() {
                        public void run() {

                                try {
                                        for (int i = 0; i < 3; i++) {
                                                outputer.output1();
                                        }
                                } catch (Exception e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                        }
                }).start();

                new Thread(new Runnable() {
                        public void run() {
                                try {
                                        for (int i = 0; i < 5; i++) {
                                                outputer.output2();
                                        }
                                } catch (Exception e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                        }
                }).start();
                for (int i = 0; i < 7; i++) {
                        outputer.output3();
                }
        }
}

class Outputer {
   
        Lock lock = new ReentrantLock();
        Condition condition1 = lock.newCondition();
        Condition condition2 = lock.newCondition();
        Condition condition3 = lock.newCondition();
        private int envent = 3;

        public void output1() {
                lock.lock();
                try {
                        while (envent != 1) {
                                try {
                                        condition1.await();
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                        }
                        for (int i = 0; i < 10; i++) {
                                System.out.println("this is first print");
                        }
                        envent = 2;
                        condition2.signal();
                } finally {
                        lock.unlock();
                }
        }

        public void output2() {
                lock.lock();
                try {
                        while (envent != 2) {
                                try {
                                        condition2.await();
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                        }
                        for (int i = 0; i < 20; i++) {
                                System.out.println("this is second print");
                        }
                        envent = 3;
                        condition3.signal();
                } finally {
                        lock.unlock();
                }
        }
        public void output3() {
                lock.lock();
                try {
                        while (envent != 3) {
                                try {
                                        condition3.await();
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                        }
                        for (int i = 0; i < 30; i++) {
                                System.out.println("this is third print");
                        }
                        envent = 1;
                        condition1.signal();
                } finally {
                        lock.unlock();
                }
        }
}

---

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

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