a

1. /**
   
2. * 两个线程轮流给数组添加随机数
   
3. */
   
4. public class T23 {
   
5.         private static int[] arr = new int[6];//共享的数据
   
6.         private static int index = 0;//数组下表指针
   
7.         private static boolean flag = false;
   
8.         public static void main(String[] args) throws InterruptedException {
   
9.                 final Object lock = new Object();
   
10.                 new Thread() {
    
11.                         public void run() {
    
12.                                 synchronized (lock) {
    
13.                                         while (index < 6) {//index指示，数组是否已经添加结束
    
14.                                                 while (flag) {
    
15.                                                         try {
    
16.                                                                 lock.wait();
    
17.                                                         } catch (InterruptedException e) {
    
18.                                                                 e.printStackTrace();
    
19.                                                         }
    
20.                                                 }
    
21.                                                 int num = (int) (Math.random() * 10 + 1);
    
22.                                                 add1(num);
    
23.                                                 flag = flag^true;//flag取反
    
24.                                                 lock.notifyAll();
    
25.                                         }
    
26.                                 }
    
27.                         };
    
28.                 }.start();
    
29.                 new Thread() {
    
30.                         public void run() {
    
31.                                 synchronized (lock) {
    
32.                                         while (index < 6) {
    
33.                                                 while (!flag) {
    
34.                                                         try {
    
35.                                                                 lock.wait();
    
36.                                                         } catch (InterruptedException e) {
    
37.                                                                 e.printStackTrace();
    
38.                                                         }
    
39.                                                 }
    
40.                                                 int num = (int) (Math.random() * 10 + 1);
    
41.                                                 add1(num);
    
42.                                                 flag = false;
    
43. //                                                flag = flag^true;
    
44.                                                 lock.notifyAll();
    
45.                                         }
    
46.                                 }
    
47.                         };
    
48.                 }.start();
    
49.                 while(index<6){
    
50.                         Thread.sleep(1);
    
51.                 }
    
52.                 for(int i:arr)//遍历输出数组
    
53.                         System.out.print(i+" ");
    
54.         }
    
55.         public static void add1(int i){
    
56.                 if(index<6){
    
57.                         arr[index] = i;//对共享数据进行操作需要进行同步
    
58.                         System.out.println("arr["+index+"] = "+i
    
59.                                         +"..."+Thread.currentThread().getName());
    
60.                         index++;
    
61.                 }
    
62.         }
    
63. }
    

复制代码

1. arr[0] = 3...Thread-0
   
2. arr[1] = 2...Thread-1
   
3. arr[2] = 7...Thread-0
   
4. arr[3] = 7...Thread-1
   
5. arr[4] = 6...Thread-0
   
6. arr[5] = 9...Thread-1
   
7. 3 2 7 7 6 9

复制代码

a

1. /**
   
2. * 两个线程轮流给数组添加随机数
   
3. */
   
4. public class T23 {
   
5.         private static int[] arr = new int[6];//共享的数据
   
6.         private static int index = 0;//数组下表指针
   
7.         private static boolean flag = false;
   
8.         public static void main(String[] args) throws InterruptedException {
   
9.                 final Object lock = new Object();
   
10.                 new Thread() {
    
11.                         public void run() {
    
12.                                 synchronized (lock) {
    
13.                                         while (index < 6) {//index指示，数组是否已经添加结束
    
14.                                                 while (flag) {
    
15.                                                         try {
    
16.                                                                 lock.wait();
    
17.                                                         } catch (InterruptedException e) {
    
18.                                                                 e.printStackTrace();
    
19.                                                         }
    
20.                                                 }
    
21.                                                 int num = (int) (Math.random() * 10 + 1);
    
22.                                                 add1(num);
    
23.                                                 flag = flag^true;//flag取反
    
24.                                                 lock.notifyAll();
    
25.                                         }
    
26.                                 }
    
27.                         };
    
28.                 }.start();
    
29.                 new Thread() {
    
30.                         public void run() {
    
31.                                 synchronized (lock) {
    
32.                                         while (index < 6) {
    
33.                                                 while (!flag) {
    
34.                                                         try {
    
35.                                                                 lock.wait();
    
36.                                                         } catch (InterruptedException e) {
    
37.                                                                 e.printStackTrace();
    
38.                                                         }
    
39.                                                 }
    
40.                                                 int num = (int) (Math.random() * 10 + 1);
    
41.                                                 add1(num);
    
42.                                                 flag = false;
    
43. //                                                flag = flag^true;
    
44.                                                 lock.notifyAll();
    
45.                                         }
    
46.                                 }
    
47.                         };
    
48.                 }.start();
    
49.                 while(index<6){
    
50.                         Thread.sleep(1);
    
51.                 }
    
52.                 for(int i:arr)//遍历输出数组
    
53.                         System.out.print(i+" ");
    
54.         }
    
55.         public static void add1(int i){
    
56.                 if(index<6){
    
57.                         arr[index] = i;//对共享数据进行操作需要进行同步
    
58.                         System.out.println("arr["+index+"] = "+i
    
59.                                         +"..."+Thread.currentThread().getName());
    
60.                         index++;
    
61.                 }
    
62.         }
    
63. }
    

复制代码

1. arr[0] = 3...Thread-0
   
2. arr[1] = 2...Thread-1
   
3. arr[2] = 7...Thread-0
   
4. arr[3] = 7...Thread-1
   
5. arr[4] = 6...Thread-0
   
6. arr[5] = 9...Thread-1
   
7. 3 2 7 7 6 9

复制代码