什么是好的并行程序【用Java线程】？

Question

我正在学习Java中的线程，以便创建一些并行运行的程序。设计具有并行性的程序是我从未在学校编程课上学到的东西。我知道如何创建线程并使其运行，但我不知道如何有效地使用它们。毕竟，我知道实际上并不是使用线程使程序快速，而是一个好的并行设计。所以我做了一些实验来测试我的知识。但是，我的并行版本实际上比无与伦比的版本运行得更慢。我开始怀疑我是否真的明白了。如果你能这么善良，你会介意看看我的以下程序吗：

我做了一个以分而治之的方式填充数组的程序（我知道Java有一个Arrays.fill的实用程序，但我只想测试我在多线程方面的知识）：

public class ParalledFill
{
    private static fill(final double [] array, 
                        final double value, 
                        final int start, 
                        final int size)
    {
        if (size > 1000) 
        { // Each thread handles at most 1000 elements
            Runnable task = new Runnable() { // Fork the task
                public void run() { 
                    fill(array, value, start, 1000); // Fill the first 1000 elements
            }};
            // Create the thread
            Thread fork = new Thread(task);
            fork.start(); 
            // Fill the rest of the array
            fill(array, value, start+1000, size-1000);
            // Join the task
            try {
                fork.join();
            }
            catch (InterruptedException except)
            {
                System.err.println(except);
            }
        }
        else 
        { // The array is small enough, fill it via a normal loop
            for (int i = start; i < size; ++i)
            array[i] = value;
        }
    } // fill

    public static void main(String [] args)
    {
        double [] bigArray = new double[1000*1000];
        double value = 3;
        fill(bigArray, value, 0, bigArray.length);
    }
}

我测试了这个程序，但结果证明它比只做以下事情还要慢：

for (int i = 0; i < bigArray.length; ++i)
    bigArray[i] = value;

我猜，可能是java对使用循环填充数组做了一些优化，这使得它比我的线程版本快得多。但除此之外，我更强烈地感觉到我处理线程/并行的方式可能是错误的。我从未使用线程设计过任何东西（总是依赖于C中的编译器优化或OpenMP）。有人能帮我解释一下为什么我的并行版本没有更快吗？这个程序在设计并行程序方面是否太糟糕了？

谢谢，星。

Answer 1

除非您有多个CPU，或者I/O等长时间运行的任务，否则我猜您所做的只是线程之间的时间切片。如果有一个CPU有这么多工作要做，添加线程不会减少必须完成的工作。由于上下文切换，您最终所做的只是增加开销。

你应该阅读“实践中的Java并发性”。最好学习如何使用现代并发包而不是原始线程来做事情。