黑马程序员技术交流社区

标题: 线程共享问题 [打印本页]

作者: 在学野马 时间: 2014-10-4 15:08
标题: 线程共享问题
本帖最后由在学野马于 2014-10-5 07:36 编辑

public class xiancheng {
      public static int[]arr=new int[6];
      public  int dex=0;
      public static void main(String[] args) throws Exception {

      new Thread(new thread()).start();
      new Thread(new thread()).start();
      Thread.sleep(2200);
      for(int a:arr){
            System.out.println(a);
      }
      }

}
class thread implements Runnable{
      int[]arr=new int[6];
      int dex=0;
      @Override
      public void run() {
            try {
                     Thread.sleep(3000);
            } catch (InterruptedException e) {
                     // TODO Auto-generated catch block
                     e.printStackTrace();
            }
            for(int i=0;i<3;i++){
                     int num=(int) (Math.random()*10+1);
                     synchronized(xiancheng.class){
                     arr[dex]=num;
                     System.out.println(arr[dex]);
                     dex++;
                     }
            }
      }

}
没有达到效果这是哪的问题

作者: 水竹 时间: 2014-10-4 15:38
没看出来你想要什么效果，三个线程各自操作各自的数组，不涉及任何对共享资源的操作，三个线程还有一段时间在同时睡觉。两个新线程循环体里面数组角标变化明明和循环码子完全相同，还是弄成了两个变量。主线程数组默认初始化，所以打印六个零，两个新线程各自打印数组中前三个元素，这样的输出不是理所当然么，根本看不出你期望的效果是什么。

作者: 在学野马 时间: 2014-10-4 16:01

水竹发表于 2014-10-4 15:38
没看出来你想要什么效果，三个线程各自操作各自的数组，不涉及任何对共享资源的操作，三个线程还有一段时间 ...

package lianxi;

public class xiancheng implements Runnable{
private static int[] arr=new int[6];
int number=0;
public static void main(String[] args) throws Exception{
new Thread(new xiancheng()).start();
new Thread(new xiancheng()).start();
Thread.sleep(2000);
for(int i:arr){
System.out.println(i);
}

}

@Override
public void run() {

try {
Thread.sleep(500);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
for(int i=0;i<3;i++){
int sum=(int) (Math.random()*10+1);
synchronized(xiancheng.class){
arr[number]=sum;
System.out.println(arr[number]);
number++;
}
}
}
}
这样呢怎么也没有共享

作者: 水竹 时间: 2014-10-4 16:39

在学野马发表于 2014-10-4 16:01
package lianxi;

public class xiancheng implements Runnable{

number并不是static的，所以两个新线程中都各有一个number，所以其实他们操作的都是数组中的前三个元素，先执行的线程写入的内容被后执行的线程重新赋值了。要想把数组写满，把number修饰为static的即可。

作者: 在学野马 时间: 2014-10-4 16:49

水竹发表于 2014-10-4 16:39
number并不是static的，所以两个新线程中都各有一个number，所以其实他们操作的都是数组中的前三个元素， ...

当我把睡眠时间改了以后为什么会出现好几个0的现象

作者: JerryJava 时间: 2014-10-4 16:56
这样吧，楼主先看一遍多线程部分的银行存钱的例子，思路是一样的。
以下是我的代码，参考下吧～希望能帮到你。

package com.JerryJava;
import java.util.Random;
public class interview_04_2 {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
myArrayAdd ma = new myArrayAdd();
// ma.run();
new Thread(ma).start();
new Thread(ma).start();
new Thread(ma).start();
new Thread(ma).start();
}
}
class myArray
{
private int[] arr = new int[15];
private int pos = 0 ;
public synchronized void add(int num)
{
int time = new Random().nextInt(10)+1;
try {
Thread.sleep(time*200);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
arr[pos]= num;
//System.out.println("arr::"+pos+"__"+arr[2]);
System.out.println("arr"+pos+"=::"+arr[pos]);
pos++;
}
}
class myArrayAdd implements Runnable
{
private myArray ma = new myArray();
public void run(){
for(int i=1 ; i<=3 ; i++)
{
int num = new Random().nextInt(20);
//System.out.println(num);
ma.add(num);
}
}
}

复制代码

作者: 水竹 时间: 2014-10-4 17:39

在学野马发表于 2014-10-4 16:49
当我把睡眠时间改了以后为什么会出现好几个0的现象

是说又改了还是说上面的？
如果是number加上static后又改了睡眠时间的话，就要看主线程打印的时候其余两个线程是否已经执行完毕，若没有则会输出0.
如果说的上面的，是因为两个线程修改的都是数组前三个元素的值。

作者: 在学野马 时间: 2014-10-4 18:32

JerryJava 发表于 2014-10-4 16:56
这样吧，楼主先看一遍多线程部分的银行存钱的例子，思路是一样的。
以下是我的代码，参考下吧～希望能帮 ...

这个不算是共享吧

作者: JerryJava 时间: 2014-10-4 19:05

在学野马发表于 2014-10-4 18:32
这个不算是共享吧

我的思路：
1.将数组【15】，操作数组的指针 pos ，和向数组中添加元素的方法add 封装成一个类myArray.
2.建立一个Runnable的实现类myArrayAdd, 此类中初始就有一个myArray资源，run方法中分3次调用add方法，即向数组中存随机数。
3.主函数中建立一个myArrayAdd对象ma（只有一个），建立4个线程操作，注意由于只有一个对象，所以操作的是同一个数组。只是调用了4次run（），即向数组中add了12次随机数。

希望有用。

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

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