1. //main
   
2. public class ThreadTest {
   
3.         public static void main(String[] args) throws InterruptedException {
   
4.                 //临界资源 共享数组
   
5.                 int[] arr = new int[6];
   
6.                 ArrIndex ai = new ArrIndex();
   
7.                 Thread t1 = new Thread(new InputArr(arr, ai), "线程A");
   
8.                 Thread t2 = new Thread(new InputArr(arr, ai), "线程B");
   
9.                 t1.start();
   
10.                 t2.start();
    
11.                 t1.join();
    
12.                 t2.join();
    
13. 
    
14.         }
    
15. }
    
16. public class ArrIndex extends Thread {
    
17.         //数组index
    
18.         public int index;
    
19. 
    
20. }
    
21. 
    
22. import java.util.Random;
    
23. 
    
24. public class InputArr implements Runnable {
    
25.         private int[] arr;
    
26.         private int count;
    
27.         private ArrIndex ai;
    
28. 
    
29.         InputArr(int[] arr, ArrIndex ai) {
    
30.                 this.arr = arr;
    
31.                 this.ai = ai;
    
32.         }
    
33. 
    
34.         @Override
    
35.         public void run() {
    
36.                 //每一个线程为数组添加3个数据即可
    
37.                 while (count < 3) {
    
38.                         //生成随机数
    
39.                         int x = new Random().nextInt(5);
    
40.                         synchronized (InputArr.class) {
    
41.                                 try {
    
42.                                         System.out.println(Thread.currentThread().getName() + "等待"
    
43.                                                         + x + "秒");
    
44.                                         //两个线程分别隔一段时间
    
45.                                         Thread.sleep(x * 1000);
    
46.                                 } catch (InterruptedException e) {
    
47.                                         e.printStackTrace();
    
48.                                 }
    
49.                                 //给数组添加数据
    
50.                                 arr[ai.index] = x;
    
51.                                 System.out.println(Thread.currentThread().getName() + "添加数据："
    
52.                                                 + arr[ai.index]);
    
53.                                 for (int i = 0; i < arr.length; i++) {
    
54.                                         System.out.println(arr[i]);
    
55.                                 }
    
56.                                 count++;
    
57.                                 ai.index++;
    
58.                         }
    
59.                 }
    
60.         }
    
61. 
    
62. }

复制代码

把ArrIndex类改变为在main函数定义一个基本数据类型int ptr=0的变量传入线程 为什么不能实现角标的共享？求高人解答 谢谢

1. //main
   
2. public class ThreadTest {
   
3.         public static void main(String[] args) throws InterruptedException {
   
4.                 //临界资源 共享数组
   
5.                 int[] arr = new int[6];
   
6.                 ArrIndex ai = new ArrIndex();
   
7.                 Thread t1 = new Thread(new InputArr(arr, ai), "线程A");
   
8.                 Thread t2 = new Thread(new InputArr(arr, ai), "线程B");
   
9.                 t1.start();
   
10.                 t2.start();
    
11.                 t1.join();
    
12.                 t2.join();
    
13. 
    
14.         }
    
15. }
    
16. public class ArrIndex extends Thread {
    
17.         //数组index
    
18.         public int index;
    
19. 
    
20. }
    
21. 
    
22. import java.util.Random;
    
23. 
    
24. public class InputArr implements Runnable {
    
25.         private int[] arr;
    
26.         private int count;
    
27.         private ArrIndex ai;
    
28. 
    
29.         InputArr(int[] arr, ArrIndex ai) {
    
30.                 this.arr = arr;
    
31.                 this.ai = ai;
    
32.         }
    
33. 
    
34.         @Override
    
35.         public void run() {
    
36.                 //每一个线程为数组添加3个数据即可
    
37.                 while (count < 3) {
    
38.                         //生成随机数
    
39.                         int x = new Random().nextInt(5);
    
40.                         synchronized (InputArr.class) {
    
41.                                 try {
    
42.                                         System.out.println(Thread.currentThread().getName() + "等待"
    
43.                                                         + x + "秒");
    
44.                                         //两个线程分别隔一段时间
    
45.                                         Thread.sleep(x * 1000);
    
46.                                 } catch (InterruptedException e) {
    
47.                                         e.printStackTrace();
    
48.                                 }
    
49.                                 //给数组添加数据
    
50.                                 arr[ai.index] = x;
    
51.                                 System.out.println(Thread.currentThread().getName() + "添加数据："
    
52.                                                 + arr[ai.index]);
    
53.                                 for (int i = 0; i < arr.length; i++) {
    
54.                                         System.out.println(arr[i]);
    
55.                                 }
    
56.                                 count++;
    
57.                                 ai.index++;
    
58.                         }
    
59.                 }
    
60.         }
    
61. 
    
62. }

复制代码

把ArrIndex类改变为在main函数定义一个基本数据类型int ptr=0的变量传入线程 为什么不能实现角标的共享？求高人解答 谢谢