A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 周敏2011nc 黑马帝   /  2011-12-20 12:04  /  2149 人查看  /  5 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

本帖最后由 周敏2011nc 于 2011-12-23 07:32 编辑

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

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

5 个回复

倒序浏览
用join()方法插入这个子线程,等到执行20次的子线程执行完,执行权回到主线程手里的时候,用join()方法让主线程等待此子线程执行20次。

评分

参与人数 1技术分 +1 收起 理由
吴上储 + 1

查看全部评分

回复 使用道具 举报
刘健 黑马帝 2011-12-20 21:57:02
藤椅
楼主既然知道wait那也应该知道join()啊,用这个方法就可以实现啊
回复 使用道具 举报
本帖最后由 海中的游弋草 于 2011-12-20 22:15 编辑

毕老师的视频中讲到过这个问题的!你这里可以使用join()方法;在多线程中join可以用来临时加入线程执行。比如:当A线程执行到了B线程的.join()方法时,A就会等待,等B线程都执行完,A才会执行。
回复 使用道具 举报
谢谢各位  
回复 使用道具 举报
本帖最后由 周敏2011nc 于 2011-12-22 09:05 编辑

在网上找到一个新的办法,和大家分享分享:
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();
                }
        }
}

评分

参与人数 1技术分 +1 收起 理由
吴上储 + 1

查看全部评分

回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马