这是多线程排序的可接受解决方案吗？答案

【问题标题】：Is this an acceptable solution of Multithreaded Sorting?这是多线程排序的可接受解决方案吗？
【发布时间】：2013-08-25 02:11:10
【问题描述】：

请查看代码并提供您的 cmets。我要实现的是多线程合并排序。它可以更并行地完成吗？

我有点担心我提出的两个“加入”电话。因为它们会妨碍并行性。

使用以下逻辑：
1) 使用多个线程递归地划分左数组。
2) 使用多个线程递归地划分右数组。
3) 等待两个线程完成。
4) 最后对所有内容进行合并和排序。

public class MergeSort {

static public void merge(int[] numbers, int left, int mid, int right) {
    int[] temp = new int[130];
    int i, left_end, num_elements, tmp_pos;

    left_end = (mid - 1);
    tmp_pos = left;
    num_elements = (right - left + 1);

    while ((left <= left_end) && (mid <= right)) {
        if (numbers[left] <= numbers[mid])
            temp[tmp_pos++] = numbers[left++];
        else
            temp[tmp_pos++] = numbers[mid++];
    }

    while (left <= left_end)
        temp[tmp_pos++] = numbers[left++];

    while (mid <= right)
        temp[tmp_pos++] = numbers[mid++];

    for (i = 0; i < num_elements; i++) {
        numbers[right] = temp[right];
        right--;
    }
}

static public void mergeSort(final int[] numbers, final int left,
        final int right) {

    if (right > left) {
        final int mid = (right + left) / 2;
        Thread t = new Thread() {
            @Override
            public void run() {
                mergeSort(numbers, left, mid);
            }
        };
        t.start();

        Thread t1 = new Thread() {

            @Override
            public void run() {
                mergeSort(numbers, (mid + 1), right);
            }
        };

        t1.start();

        try {
            t.join();
            t1.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        merge(numbers, left, (mid + 1), right);
    }
}

public static void main(String[] args) {
    int[] numbers = new int[] { 1, 4, 5, 2, 5, 67, 89, 34, 5, 56, 555, 655,
            33, 2, 34, 45, 5, 1, 2, 2334, 5, 55, 5, 577, 788, 99, 0, 9, 86,
            98, 1, 2, 3, 3, 344, 4, 3443, 343434, 34334343, 443, 3442, 55,
            6, 778, 86, 66, 67778, 8, 88, 9, 9, 999, 8, 900 };

    int len = numbers.length;
    mergeSort(numbers, 0, len - 1);
    for (int i = 0; i < len - 1; i++)
        System.out.println(numbers[i]);

}

}

【问题讨论】：

标签： java multithreading sorting data-structures merge

【解决方案1】：

如果有的话，您的代码已经太并行了......尽管在实际意义上它根本不是非常并行。

第一个问题是创建线程很昂贵。非常贵。您的代码可能会执行 2 个（或更多）数量级的指令来创建线程，而不是线程将执行有用的工作。

第二个问题是，无论您创建多少线程，您的实际并行度都将受到您正在使用的硬件上的物理处理器/内核数量的限制。如果线程数多于内核数，那么大部分时间线程将处于等待运行的队列中。

如果您认真对待并行排序，则需要阅读有关如何正确执行此操作的信息。仅仅创建大量线程（就像您目前正在做的那样）是行不通的。此外，除非您有 100,000 个或更多元素要排序，否则可能甚至不值得费心进行并行化（使用线程）。

参考资料：

Sorting in Parallel in Java

【讨论】：