黑马程序员技术交流社区

标题: 让2个线程按顺序打印 [打印本页]

---

作者: 吴光新    时间: 2014-2-15 03:12
标题: 让2个线程按顺序打印

public class Test1 { private A a; private B b; public static void main(String[] args){   Test1 t = new Test1();   t.show(); } public void show(){   a = new A();   b = new B();   a.start();   b.start(); } class A extends Thread{   @Override   public void run() {    for (int i = 1; i < 100; i+=2) {     System.out.println("A=" + i);    }   } } class B extends Thread{   @Override   public void run() {    for (int i = 0; i < 100; i+=2) {     System.out.println("B=" + i);    }   } } }

打印结果是
A=1
A=3
A=5
B=0
A=7
A=9
A=11
A=13
....

请修改程序，让两个线程同时打印
A=1
B=2
A=3
B=4
A=5
B=6
......

回答正确，前三名 各奖励2技术分

---

作者: 小Zeor………    时间: 2014-2-15 08:35


抢沙发，应该是线程加锁的问题。占个位置一会贴出来解答，有技术分 ，哇咔咔

1. public class Test1 {
   
2.         private A a;
   
3.         private B b;
   
4.         private R r;
   
5. 
   
6.         public static void main(String[] args) {
   
7.                 Test1 t = new Test1();
   
8.                 t.show();
   
9.         }
   
10. 
    
11.         public void show() {
    
12.                 r = new R();
    
13.                 a = new A();
    
14.                 b = new B();
    
15.                 Thread t1 = new Thread(a);
    
16.                 Thread t2 = new Thread(b);
    
17.                 t1.start();
    
18.                 t2.start();
    
19.         }
    
20. 
    
21.         class R {
    
22.                 boolean flag = true;
    
23.         }
    
24. 
    
25.         class A extends Thread {
    
26.                 @Override
    
27.                 public void run() {
    
28.                         int i = 0;
    
29.                         while (i < 100) {
    
30.                                 {
    
31.                                         if (r.flag) {
    
32.                                                 synchronized(r){System.out.println("A=" + i);
    
33.                                                 i++;
    
34.                                                 i++;
    
35.                                                 r.flag = false;
    
36.                                                 }
    
37.                                         }
    
38.                                 }
    
39.                         }
    
40.                 }
    
41.         }
    
42. 
    
43.         class B extends Thread {
    
44.                 @Override
    
45.                 public void run() {
    
46.                         int i = 1;
    
47.                         while (i < 100) {
    
48.                                 if (!r.flag) {
    
49.                                         synchronized (r) {
    
50.                                                 System.out.println("B=" + i);
    
51.                                                 i++;
    
52.                                                 i++;
    
53.                                                 r.flag = true;
    
54.                                         }
    
55.                                 }
    
56. 
    
57.                         }
    
58.                 }
    
59.         }
    
60. }

复制代码

---

作者: 分解式    时间: 2014-2-15 09:05
求技术分

---

作者: 奋斗的小胖子    时间: 2014-2-15 09:17

1. public class Test1
   
2. {
   
3.          public static void main(String[] args)
   
4.          {
   
5.                  show s1=new show();
   
6.                  A a1=new A(s1);
   
7.                  B b1=new B(s1);
   
8.                  Thread t1=new Thread(a1);
   
9.                  Thread t2=new Thread(b1);
   
10.                  t1.start();
    
11.                  t2.start();
    
12.                  
    
13.          }
    
14.                
    
15. }
    
16.          
    
17.          
    
18. class show
    
19. {
    
20.         private show s;
    
21.         int num=0;
    
22.         private boolean flag=false;
    
23.         show(){}
    
24.         Lock lock=new ReentrantLock();
    
25.         Condition  A_lock=lock.newCondition();
    
26.         Condition  B_lock=lock.newCondition();
    
27.         public void showA()
    
28.         {
    
29.                 lock.lock();
    
30.                 try {
    
31.                        
    
32.                        
    
33.                         while(flag==true)
    
34.                         {
    
35.                                 A_lock.await();
    
36.                                 if(num<100)
    
37.                                 {
    
38.                                         num++;
    
39.                                         System.out.println("A="+num);
    
40.                                 }
    
41.                         }
    
42.                         flag=true;
    
43.                         B_lock.signal();
    
44.                 }
    
45.                 catch (InterruptedException e) {
    
46.                         // TODO Auto-generated catch block
    
47.                         e.printStackTrace();
    
48.                 }
    
49.                 finally
    
50.                 {
    
51.                         lock.unlock();
    
52.                 }
    
53.         }
    
54. 
    
55.         public void showB()
    
56.         {
    
57.                 lock.lock();
    
58.                 try {
    
59.                        
    
60.                        
    
61.                         while(flag==false)
    
62.                         {
    
63.                                 B_lock.await();
    
64.                                 if(num<100)
    
65.                                 {
    
66.                                         num++;
    
67.                                         System.out.println("B="+num);
    
68.                                 }
    
69.                         }
    
70.                         flag=false;
    
71.                         A_lock.signal();
    
72.                 }
    
73.                 catch (InterruptedException e) {
    
74.                         // TODO Auto-generated catch block
    
75.                         e.printStackTrace();
    
76.                 }
    
77.                 finally
    
78.                 {
    
79.                         lock.unlock();
    
80.                 }
    
81.         }
    
82. }
    
83. class A implements Runnable
    
84. {
    
85.         show s;
    
86.         public A(show s)
    
87.         {
    
88.                 this.s=s;
    
89.         }
    
90.         public void run()
    
91.         {
    
92.                 while(true)
    
93.                 {
    
94.                         s.showA();
    
95.                 }
    
96.         }
    
97. }
    
98. class B implements Runnable
    
99. {
    
100.         show s;
     
101.         public B(show s)
     
102.         {
     
103.                 this.s=s;
     
104.         }
     
105.         public void run()
     
106.         {
     
107.                 while(true)
     
108.                 {
     
109.                         s.showB();
     
110.                 }
     
111.         }
     
112. }

复制代码

我是参考生产消费的例子写的，为了抢楼没写注释，就先发了

---

作者: LSCZ3633    时间: 2014-2-15 09:29

1. package com.itheima;
   
2. /*
   
3. * 使两个线程一个一个有序进行
   
4. *
   
5. * 思路：定义一个标签boolean  判断哪个线程应该执行
   
6. * 定义一个公共变量i
   
7. * 加入一个同步代码块 synchronized(r)
   
8. *
   
9. *
   
10. *
    
11. * */
    
12. 
    
13. 
    
14. public class Test1 {
    
15. private A a;
    
16. private B b;
    
17. private R r;
    
18. public static void main(String[] args){
    
19.          
    
20.     Test1 t = new Test1();
    
21.    t.show();
    
22. }
    
23. 
    
24. public void show(){
    
25.    r=new R();
    
26.          a = new A(r);
    
27.    b = new B(r);
    
28.   
    
29.    a.start();
    
30.    b.start();
    
31. }
    
32. }
    
33. class R{
    
34.         int i=1;
    
35.         boolean flag=true;
    
36.        
    
37.         R(){}
    
38.        
    
39. }
    
40. class A extends Thread{
    
41.          private R r;
    
42.          A(R r){
    
43.                  this.r=r;
    
44.          }
    
45.          @Override
    
46.    public void run() {
    
47.    
    
48.                  for (; r.i < 100; ) {
    
49.                          
    
50.                          if(r.flag){
    
51.                                  synchronized(r){
    
52.                                          System.out.println("A=" + r.i++);
    
53.                                          r.flag=false;
    
54.                                  }
    
55.                                  
    
56.                                  }
    
57.    
    
58.      
    
59.     }
    
60.    }
    
61. }
    
62. 
    
63. class B extends Thread{
    
64.          private R r;
    
65.          B(R r){
    
66.                  this.r=r;
    
67.          }
    
68.          @Override
    
69.    public void run() {
    
70.     for (; r.i < 100; ) {
    
71.             if(!r.flag){
    
72.                      synchronized(r){
    
73.                     System.out.println("B=" + r.i++);
    
74.                      r.flag=true;
    
75.                      }
    
76.             }
    
77.    
    
78.    
    
79.     }
    
80.    }
    
81. }
    

复制代码

---

作者: LuckyQS    时间: 2014-2-15 09:45
public class Test1 {
        private A a;
        private B b;
        private R r;
        public static void main(String[] args){
                Test1 t = new Test1();
                t.show();
        }
        public void show(){
                r=new R();
                a = new A(r);
                b = new B(r);
                a.start();
                b.start();
        }
}
class R{
        int i=1;
        boolean flag=true;
        R(){}      
}
class A extends Thread{
        private R r;
        A(R r){
                this.r=r;
        }
        @Override
        public void run() {
                while(r.i<100) {   
                        if(r.flag){
                                synchronized(r){
                                        System.out.println("A="+r.i++);
                                        r.flag=false;
                                }                        
                        }
                }
        }
}
class B extends Thread{
        private R r;
        B(R r){
                this.r=r;
        }
        @Override
        public void run() {
        while(r.i<100) {
                if(!r.flag){
                        synchronized(r){
                                System.out.println("B="+r.i++);
                                r.flag=true;
                                }
                        }
                }
        }
}
只要让两个线程控制同一份元素,定义一个boolean变量来改变线程的执行权

---

作者: 倉促、尋找你    时间: 2014-2-15 09:47
手机回复，就不贴代码了，线程同步建议使用实现Runnable接口的方法去做这个题目不难，你搜一下资料应该就搞定了

---

作者: 孤独的天奇    时间: 2014-2-15 11:15

奋斗的小胖子 发表于 2014-2-15 09:17
我是参考生产消费的例子写的，为了抢楼没写注释，就先发了

嗯，我觉得，就应该是这样子。

---

作者: 孤独的天奇    时间: 2014-2-15 19:20
package com.itheima;

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

public class Resource {
       
        Lock lock = new ReentrantLock();
        boolean flag = false;
        Condition conditionA = lock.newCondition();
        Condition conditionB = lock.newCondition();
       
        public void printA(){
                lock.lock();
                try {
                        for (int i = 1; i <= 100; i+=2) {
                                while(flag)
                                        conditionA.await();
                            System.out.println("A=" + i);
                            flag = true;
                            conditionB.signal();
                           }
                } catch (Exception e) {
                        // TODO: handle exception
                }finally{
                        lock.unlock();
                }
               
        }
package com.itheima;

public class A implements Runnable{
       
        private Resource res;
       
        public A(Resource res){
                this.res = res;
        }

        @Override
        public void run() {
                res.printA();
               
        }
}

package com.itheima;

public class B implements Runnable {

        private Resource res;
       
        public B(Resource res){
                this.res = res;
        }
       
        @Override
        public void run() {
                res.printB();
        }

}

package com.itheima;

public class Test {

        /**
         * @param args
         */
        public static void main(String[] args) {
                Resource res = new Resource();
                new Thread(new A(res)).start();
                new Thread(new B(res)).start();

        }

}

---

作者: 孤独的天奇    时间: 2014-2-15 19:22
package com.itheima;

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

public class Resource {
       
        Lock lock = new ReentrantLock();
        boolean flag = false;
        Condition conditionA = lock.newCondition();
        Condition conditionB = lock.newCondition();
       
        public void printA(){
                lock.lock();
                try {
                        for (int i = 1; i <= 100; i+=2) {
                                while(flag)
                                        conditionA.await();
                            System.out.println("A=" + i);
                            flag = true;
                            conditionB.signal();
                           }
                } catch (Exception e) {
                        // TODO: handle exception
                }finally{
                        lock.unlock();
                }
               
        }
       
        public void printB(){
                lock.lock();
                try {
                        for (int i = 2; i <= 100; i += 2) {
                                while(!flag)
                                        conditionB.await();
                                System.out.println("B=" + i);
                                flag = false;
                            conditionA.signal();
                        }
                } catch (Exception e) {
                        lock.unlock();
                }
        }
}

Resource 类没有发全，补上

---

作者: 小Zeor………    时间: 2014-2-15 20:37
@吴光新 求加分。。。。要下一步考试。。

---

作者: 奋斗的小胖子    时间: 2014-2-19 20:06
QQ多少啊？  什么奖励啊？

---

作者: 奋斗的小胖子    时间: 2014-2-19 20:16
没有权限啊

---

作者: 奋斗的小胖子    时间: 2014-2-19 20:19


请修改我的权限

---

作者: wh963572516    时间: 2014-2-21 15:45
自己写的，不知道对不对，我自己验证的是和你要求的一样

1. //公共资源
   
2. class Resource
   
3. {
   
4.         public int i = 1;
   
5. }
   
6. 
   
7. //线程 1
   
8. class Thread1 implements Runnable {
   
9.         private Resource r;
   
10. 
    
11.         public Thread1(Resource r) {  
    
12.                 this.r = r;
    
13.         }
    
14. 
    
15.         public void run() {  
    
16.                         synchronized (r) {   
    
17.                                 while(r.i<100){
    
18.                                         System.out.println("A="+r.i);
    
19.                                         r.i++;
    
20.                                         r.notify();//唤醒
    
21.                                         try{
    
22.                                                 r.wait();//等待
    
23.                                         }catch (InterruptedException e) {     
    
24.                                                 e.printStackTrace();
    
25.                                         }
    
26.                                 }
    
27.                         }
    
28.         }
    
29. }
    
30. 
    
31. //线程2
    
32. class Thread2 implements Runnable {
    
33.         private  Resource r;
    
34.         public Thread2(Resource r) {
    
35.                 this.r = r;
    
36.         }
    
37.         public void run() {
    
38.                 synchronized (r) {
    
39.                         while(r.i <100){  
    
40.                                 System.out.println("B="+r.i);
    
41.                                 r.i++;
    
42.                                 r.notify();//唤醒
    
43.                                 try {
    
44.                                         r.wait();//等待
    
45.                                 }catch (InterruptedException e) {     
    
46.                                         e.printStackTrace();
    
47.                                 }
    
48.                         }
    
49.                 }
    
50.         }
    
51. }
    
52. 
    
53. //主线程
    
54. public class ThreadDemo6{
    
55.         public static void main(String[] args){
    
56.                 Resource r =new Resource();
    
57.                 Thread t1=new Thread(new Thread1(r));
    
58.                 Thread t2=new Thread(new Thread2(r));
    
59.                 t1.start();
    
60.                 t2.start();
    
61.         }
    
62. }

复制代码

---

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

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