尽管已同步，Vector仍会抛出ConcurrentModificationException

Question

我有一个由多个线程操作的ArrayList，由于ArrayList没有同步，所以无法工作。按照教授的指示，我把列表换成了向量。向量是同步的，但我抛出了与同步相关的异常。

为什么会发生这种情况，我如何避免代码中的并发异常？我不想只是玩玩，直到有东西起作用，我想做最好的事情。谢谢！

例外情况：

Exception in thread "Thread-3" java.util.ConcurrentModificationException
    at java.util.Vector$Itr.checkForComodification(Vector.java:1184)
    at java.util.Vector$Itr.next(Vector.java:1137)
    at BytePe4D$ReadInts.run(BytePe4D.java:64)

代码：

import java.io.*;
import java.util.Vector;

public class BytePe4D {
    private Vector<Integer> numbers;

    public static void main(String[] args) {
        new BytePe4D();
    }

    public BytePe4D() {
        // Create ArrayList and reset sum
        numbers = new Vector<Integer>();

        // Call addInts 8 times, with filenames integer1.dat through integer8.dat
        for (int i = 1; i <= 8; i++) {
            File file = new File("PE Data/integer" + i + ".dat");
            ReadInts thread = new ReadInts(file);
            thread.start();
        }
    }

    /** Represents a Thread instance */
    class ReadInts extends Thread {
        File file;

        public ReadInts(File _file) {
            file = _file;
        }

        @Override
        public void run() {
            int count = 0;  // track number of records read
            int sum = 0;

            try {
                // Open stream to binary data file integer1.dat
                FileInputStream in = new FileInputStream(file);
                // Buffer the stream
                BufferedInputStream bin = new BufferedInputStream(in);
                // Access the primitive data
                DataInputStream din = new DataInputStream(bin);

                try {
                    // Read file until end reached
                    while (true) {
                        numbers.add(din.readInt());
                        count++;
                    }
                } catch (EOFException eof) {
                    // System.out.println("End of file reached.");
                } finally {
                    // Close streams
                    din.close();
                }
            } catch (FileNotFoundException fnf) {
                System.out.println("File does not exist: " + file.getName());
                return;
            } catch (IOException ioe) {
                ioe.printStackTrace();
            }

            // Calculate sum of numbers read
            for (int num : numbers) {
                sum += num;
            }

            // Write info
            System.out.println(
                String.format("%s%s%-5s%s%-8d%-5s%s%-12d%-5s%s%d",
                "Filename = ", file.getName(), "",
                "Count = ", count, "",
                "Sum = ", sum, "",
                "In List = ", numbers.size()));
        }
    }

}

Answer 1

来自文档：

如果在创建迭代器后的任何时候，以迭代器自己的remove或add方法之外的任何方式对向量进行结构修改，迭代器将抛出ConcurrentModificationException。

下面的代码在幕后创建了一个迭代器：

for (int num : numbers) {
    sum += num;
}

因此，当一个线程（通过添加元素）修改向量，而另一个向量正在迭代它时，您将看到一个ConcurrentModificationException

解决这个问题有不同的方法，一种方法是从一个文件读入另一个向量，读取完成后，将另一个向量分配给数字（因为分配是一个原子操作）。请记住，为了使更改对其他线程可见，您需要将numbers声明为volatile。

Answer 2

你的代码似乎错了。

如果每个线程都要计算单个文件中记录的总和，我不明白为什么需要共享向量。另一方面，如果要计算所有文件的记录之和，应该在每个线程完成后进行。

根据需要，您可以1）为每个线程创建一个向量并计算每个文件的总和，或者2）在主线程中，等待所有线程完成，然后计算所有文件的总和。