多线程 Collection.sort() 中的 NullpointerException

Question

我有一个 class 应该使用多线程测试我的斐波那契函数

public class PerformanceTesterImpl implements PerformanceTester{
    public static List<Long> executionTimesList = new ArrayList();
    public static List<Runnable> tasksList = new ArrayList();
    public int fib;
    public PerformanceTestResult performanceTestResult;

    @Override
    public PerformanceTestResult runPerformanceTest(Runnable task, int calculationCount, int threadPoolSize) {

        for(int i=0; i<calculationCount; i++){
            tasksList.add(createTask(fib));
        }

        ExecutorService executor = Executors.newFixedThreadPool(threadPoolSize);
        for(Runnable r : tasksList){
            executor.execute(r);
        }
        executor.shutdown();  

        try {
            executor.awaitTermination(1, TimeUnit.MINUTES);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        // Here all threads should complete all work. Is it OK?
        mapValues();
        return performanceTestResult;
    }

    private PerformanceTestResult mapValues(){
        Collections.sort(executionTimesList);
        performanceTestResult = new PerformanceTestResult(getSum(executionTimesList), (Long)executionTimesList.get(0), (Long)executionTimesList.get(executionTimesList.size()-1));
        return performanceTestResult;
    }


    public  Runnable createTask (final int n) {
        fib = n;
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                long startTime = System.currentTimeMillis();
                FibCalc fibCalc = new FibCalcImpl();
                fibCalc.fib(n);
                long executionTime = System.currentTimeMillis() - startTime;
                executionTimesList.add(executionTime);
            }
        };
        return runnable;
    }


    private static long getSum(List<Long> executionTimes){
        long sum = 0;
        for(long l : executionTimes){
            sum += l;
        }
        return sum;
    }
}

但 NULL 不时出现在我的集合中，当我尝试对 executionTimeList 进行排序时，我收到 NullpointerException。我认为执行线程有问题。我应该怎么做才能更正此异常？

Answer 1

ArrayList 不是线程安全的。

来自 Javadoc :

 * If multiple threads access an <tt>ArrayList</tt> instance concurrently,
 * and at least one of the threads modifies the list structurally, it
 * <i>must</i> be synchronized externally.  (A structural modification is
 * any operation that adds or deletes one or more elements, or explicitly
 * resizes the backing array; merely setting the value of an element is not
 * a structural modification.)  This is typically accomplished by
 * synchronizing on some object that naturally encapsulates the list.

 * If no such object exists, the list should be "wrapped" using the
 * {@link Collections#synchronizedList Collections.synchronizedList}
 * method.  This is best done at creation time, to prevent accidental
 * unsynchronized access to the list:<pre>
 *   List list = Collections.synchronizedList(new ArrayList(...));</pre>

当您从多个线程调用 add 时，ArrayList 可能不一致 state.You 应该同步访问它。

尝试：

        public void run() {
            long startTime = System.currentTimeMillis();
            FibCalc fibCalc = new FibCalcImpl();
            fibCalc.fib(n);
            long executionTime = System.currentTimeMillis() - startTime;
            synchronized (this) {
                executionTimesList.add(executionTime);
            }
        }

Answer 2

executionTimesList 在所有线程之间共享。他们运行在您的代码中并发，没有同步。因此，如果一个线程在列表上工作但尚未完成其工作并且 cpu 将优先级赋予也在列表上工作的另一个线程，则出现任何不一致状态是合乎逻辑的，第一个线程将处于不一致状态什么时候重启。您必须同步对静态字段 executionTimesList 的访问

多线程 Collection.sort() 中的 NullpointerException

NullpointerException in Collection.sort() with multithreading

java

multithreading

nullpointerexception

executorservice