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

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 王士铭 黑马帝   /  2011-8-3 00:20  /  2687 人查看  /  4 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

要求是这个样子的 分别给线程取名字,Thread-a,Thread-b,然后就交替打印数字,我同学给我的一道笔试题,我怎么写都写不出这样子的效果
Thread-a....1
Thread-b....2
Thread-a....3
Thread-b....4
    *
    *
    *
Thread-a....99
Thread-b....100

评分

参与人数 1技术分 +2 收起 理由
admin + 2

查看全部评分

4 个回复

倒序浏览
黑马网友  发表于 2011-8-3 07:14:03
沙发
常见的线程通信问题…直接用wait,和notify或者用Condition里功能都可以…建议先看视频,基础或者线程并发库里的都可以。直接拿到代码不是好事

评分

参与人数 1技术分 +1 收起 理由
admin + 1

查看全部评分

回复 使用道具 举报
黑马网友  发表于 2011-8-3 08:26:50
藤椅

你看这个可以波?

[code=java]package Thread;
public class ThreadAB  extends Thread{
   int i=0;
    private static int count=0;
  private static Object o=new Object();

    public ThreadAB(String ID){
        currentThread().setName(ID);
    }
    public void run() {
        synchronized (o) {
            while(true){
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                if(count%2==0&&currentThread().getName().equals("a")){
                    o.notify();
                  
                    count++;
                    System.out.println("Thread--"+currentThread().getName()+"...."+count);
                    try {
                        o.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                else if (count%2==1&&currentThread().getName().equals("b")) {
                    o.notify();
                  
                    count++;
                    System.out.println("Thread--"+currentThread().getName()+"...."+count);
                    try {
                        o.wait();
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }

                }
            }
        }

   
        public static void main(String[] args) {
             ThreadAB b=new ThreadAB("b");
             ThreadAB a=new ThreadAB("a");
            a.setName("a");
            b.setName("b");
            a.start();
            b.start();
           
        }
}[/code]设定一个两个线程的公共变量count。线程启动时第一件事情就是去获得该变量的值,线程a只能在变量为双数时执行,线程b只能在变量为单数时执行,执行完毕后将该数字加一并notify。虽然ab线程会去竞争该变量,但是当a执行完以后如果继续获得变量的控制权,因为数字已经变了。所以a线程继续notify,直到b获取该变量,执行后加一才能轮到a继续执行。

评分

参与人数 1技术分 +3 收起 理由
admin + 3 辛苦了

查看全部评分

回复 使用道具 举报

回复 藤椅 的帖子

学习了,继续等,一定还有更简单的!修改了一下循环条件还是可以用的while (count<100)
明白,但是也敲一遍, 有个地方不是很明白synchronized里面的while(true)里面就不是很明白了,因为Synchronized同步了while(true) 进去后是怎么跳出来的呢?线程A进去了他一直在循环 他就没法跳出来其他线程就没法进去了不知道怎么调出来
[ 本帖最后由 王士铭 于 2011-08-05  14:42 编辑 ]

评分

参与人数 1技术分 +1 收起 理由
admin + 1 没错

查看全部评分

回复 使用道具 举报
黑马网友  发表于 2011-8-3 12:00:38
报纸
我也是对线程同步问题很困惑,看来半天的视频有又看看书,依葫芦画瓢能出了一下代码:
[code=java]package com.threadtest;

public class ThreadTest {

        /**
         * @param args
         */
        public static void main(String[] args) {
               
                Temp temp=new Temp();
                Thread1 th1 = new Thread1(temp);
                Thread2 th2 = new Thread2(temp);
                Thread t = new Thread(th1);
                Thread t2 = new Thread(th2);
                t.start();
                t2.start();
        }

}

class Thread1 implements Runnable {
        int num = 100;
        Temp temp;
        public Thread1(Temp temp) {
                super();
                this.temp = temp;
        }

        @Override
        public void run() {
                // TODO Auto-generated method stub
                while (num > 0) {
                        if(temp.isFlag()==true){
                                try {
                                        Thread.sleep(1);
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                                System.out.println("Thread1 running "
                                                + num--);
                                temp.flagfalse();
                                
                        }

                }
        }
}

class Thread2 implements Runnable {

        int num = 100;
        Temp temp;
        
        public Thread2(Temp temp) {
                super();
                this.temp = temp;
        }
        @Override
        public void run() {
                // TODO Auto-generated method stub
                while (num > 0) {
                        if(temp.isFlag()==false){
                                try {
                                        Thread.sleep(1);
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                                System.out.println("Thread2 running " + num--);
                                temp.flagtrue();
                        }
                }
        }

}

class Temp {
        private   boolean flag = false;

        public boolean isFlag() {
                return flag;
        }

        public synchronized void flagtrue() {
                this.flag = true;
        }

        public synchronized void flagfalse() {
                this.flag = false;
        }
}[/code]
运行结果跟要求的一样 自己拿去测一下。用到的Temp类中的flag相当于一个公共信号灯一样一个负责开一个负责关

评分

参与人数 1技术分 +3 收起 理由
admin + 3 辛苦了

查看全部评分

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