黑马程序员技术交流社区

标题: 多线程问题 [打印本页]
作者: 遗忘    时间: 2014-12-19 13:49
标题: 多线程问题
本帖最后由 遗忘 于 2014-12-26 10:02 编辑

下面是我自己的的代码， 感觉有些麻烦，有没有更简单的？

  1. import java.util.Random;
  2. public class ShareArrayDemo {

  4.         /**
  5.          * 声明一个共享数组，起两个线程，两个线程分别隔一段时间(可以写一个随机数)，
  6.          * 给数组中添加数据，每一个线程为数组添加3个数据即可。
  7.          * @param args
  8.          */
  9.         public static void main(String[] args) {
  10.                 // TODO Auto-generated method stub
  11.                 //获取拥有数组的对象
  12.                 final ShareArray shareArray = ShareArray.getInstance();
  13.                 //创建线程
  14.                 Thread tA = new Thread(new Runnable(){
  15.                         public void run(){
  16.                                 for (int i = 0; i < 3; i++) {
  17.                                         shareArray.addInfoFirst();
  18.                                 }
  19.                         }
  20.                 });
  21.                 Thread tB = new Thread(new Runnable(){
  22.                         public void run(){
  23.                                 for (int i = 0; i < 3; i++) {
  24.                                         shareArray.addInfoSecond();
  25.                                 }
  26.                         }
  27.                 });
  28.                 //给线程命名
  29.                 tA.setName("线程A");
  30.                 tB.setName("线程B");
  31.                 //开启线程并运行
  32.                 tA.start();
  33.                 tB.start();
  34.         }

  36. }

  38. //因为数组是共享数据，设计为单例
  39. class ShareArray{
  40.         private static ShareArray arr = null;
  41.         private ShareArray(){}
  42.         //定义数组
  43.         private String[] strs = new String[6];
  44.         //定义线程等待标记
  45.         private boolean flag = true;
  46.         //定义标记，用于接收每个线程给数组添加元素的个数
  47.         private int count1 = 1,count2 =1;
  48.         public static ShareArray getInstance() {
  49.                 if(arr == null)
  50.                 {
  51.                         synchronized(ShareArray.class){
  52.                                 if (arr==null) {
  53.                                         arr = new ShareArray();
  54.                                 }
  55.                         }
  56.                 }
  57.                 return arr;
  58.         }
  59.         //显示数组元素信息
  60.         public void showArrayInfo()
  61.         {
  62.                 System.out.println("此时数组中元素列表：");
  63.                 for (int i = 0; i < strs.length; i++) {
  64.                         System.out.println("角标："+i+":"+ strs[i]);
  65.                 }
  66.         }
  67.         //第一个线程添加元素方法
  68.         public synchronized void addInfoFirst(){
  69.                 //判断标记
  70.                 while (!flag) {
  71.                         try {
  72.                                 this.wait();
  73.                         } catch (Exception e) {
  74.                                 // TODO: handle exception
  75.                         }
  76.                 }
  77.                 //遍历数组 ，如果数组该角标位元素值不为null，则添加元素并退出循环，否则进行下一次循环；
  78.                 for (int i = 0; i < strs.length; i++) {
  79.                         if (strs[i]==null) {
  80.                                 strs[i] = Thread.currentThread().getName()+
  81.                                                 "添加的第"+ count1+"个元素";
  82.                                 System.out.println(Thread.currentThread().getName()+
  83.                                                 "给数组添加的第"+(i+1)+"个元素："+ strs[i]);
  84.                                 //显示当前数组元素信息
  85.                                 showArrayInfo();
  86.                                 //记录添加元素的个数加一
  87.                                 count1++;
  88.                                 break;
  89.                         }else
  90.                                 continue;
  91.                 }
  92.                 try {
  93.                         //让两个线程随机时间间隔执行
  94.                         Thread.sleep((new Random().nextInt(100)+1)*100);
  95.                 } catch (Exception e) {
  96.                         // TODO: handle exception
  97.                 }
  98.                 //修改标记
  99.                 flag = false;
  100.                 //唤醒线程
  101.                 this.notify();
  102.         }
  103.         //第二个线程添加数组元素的方法
  104.         public synchronized void addInfoSecond(){
  105.                 while (flag) {
  106.                         try {
  107.                                 this.wait();
  108.                         } catch (Exception e) {
  109.                                 // TODO: handle exception
  110.                         }
  111.                 }
  112.                 for (int i = 0; i < strs.length; i++) {
  113.                         if (strs[i]==null) {
  114.                                 strs[i] = Thread.currentThread().getName()+
  115.                                                 "添加的第"+ count2+"个元素";
  116.                                 System.out.println(Thread.currentThread().getName()+
  117.                                                 "给数组添加的第"+(i+1)+"个元素："+ strs[i]);
  118.                                 showArrayInfo();
  119.                                 count2++;
  120.                                 break;
  121.                         }else
  122.                                 continue;
  123.                 }
  124.                 try {
  125.                         Thread.sleep((new Random().nextInt(100)+1)*100);
  126.                 } catch (Exception e) {
  127.                         // TODO: handle exception
  128.                 }
  129.                 flag = true;
  130.                 this.notify();
  131.         }
  132. }
复制代码




作者: duluhua    时间: 2014-12-19 14:20
好多。。



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