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){
    exec.execute(new Runnable() {
        @Override
        public void run() {
            process(obj)
        }
    });
}

我觉得使用这种方式更好。

Answer 2

java8 parallel stream

Answer 3

成员变量 index是多线程共享变量，你需要加volatile保证多线程中这个变量的可见性，声明代码改为如下：

private volatile int index = 0;

具体为什么请学习java并发编程相关基础知识

Answer 4

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

Answer 5

建议给每个线程限定处理集合的索引范围，即分片。
比如：
一共有5个线程，线程1处理前1/5,线程2处理1/5~2/5...
换成直观理解就是，假设有100个元素，线程1的索引范围为0~19，线程2的索引范围为20~39...

这样能避免线程之间操作相同数据，避免了可能的线程不安全问题。