Java多线程操作集合的小问题

Question

原来是把List集合用for循环操作，现在想用多线程来弄，想提高点速度。这是先做了个小例子，然后就发现出问题了。停不下来。。。

继承Runnable接口的类里的Run方法是这样的，

 public void run() {

        // TODO Auto-generated method stub

            //

            while (index <list.size()) {

                list.get(index).append("namerate", list.get(index).getString("name")+list.get(index).getString("rate"));

                System.out.println(Thread.currentThread().getName()+ "正在处理"+this.index++);

            }

    }

在main方法是这样用的

 List<Document> list = poitest.getData();

        MyThread myThread = new MyThread(list);

        

         new Thread(myThread, "1号线程").start();

         new Thread(myThread, "2号线程").start();

         new Thread(myThread, "3号线程").start();

         new Thread(myThread, "4号线程").start();

         new Thread(myThread, "5号线程").start();

        while (flag) {

            if (myThread.getIndex() >= list.size()) {

                // System.out.println("最后"+myThread.getIndex());

                flag = false;

            }

            // System.out.println(myThread.getIndex()>= list.size());

            // System.out.println("mainflag:"+flag);

        }

下面的两个无论哪个取消注释，都能停止。但是注释后，就显示还在运行。

我用debug来看线程的话是这样的

Thread [main] (Running) 

Daemon Thread [cluster-ClusterId{value='58083c114d7c9d336ce66915', description='null'}-127.0.0.1:27017] (Running) 

Daemon Thread [pool-2-thread-1] (Running)

不知道为啥会这样，我加断点用F5执行完却也能结束。。。

其实就是想用多线程来处理集合，处理完后再返回，所以我得在main里面判断多线程是否结束，然后才能执行后面的。

可这个问题很是诧异啊。我也是菜鸟，看网上都说用线程池什么的，但我想解决我这个问题。之后再有什么锁的问题到时再看。。。

Answer 1

ExecutorService exec = Executors.newFixedThreadPool(8);for(final Object obj : list){&nbsp; &nbsp; exec.execute(new Runnable() {&nbsp; &nbsp; &nbsp; &nbsp; @Override&nbsp; &nbsp; &nbsp; &nbsp; public void run() {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; process(obj)&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; });}我觉得使用这种方式更好。

Answer 2

java8 parallel stream

Answer 3

你这个run()里面最好采用线程同步

Answer 4

建议给每个线程限定处理集合的索引范围，即分片。比如：&nbsp;一共有5个线程，线程1处理前1/5,线程2处理1/5~2/5...换成直观理解就是，假设有100个元素，线程1的索引范围为0~19，线程2的索引范围为20~39...这样能避免线程之间操作相同数据，避免了可能的线程不安全问题。