com.ideaaedi.commonds.sort

类 MergeSortCompleter<T extends Comparable<T>>

java.lang.Object

java.util.concurrent.ForkJoinTask<T>

java.util.concurrent.CountedCompleter<Void>

com.ideaaedi.commonds.sort.MergeSortCompleter<T>

所有已实现的接口:

Serializable, Future<Void>

public class MergeSortCompleter<T extends Comparable<T>>
extends CountedCompleter<Void>

Fork/Join之CountedCompleter实现 多线程归并排序 P.S. 好吧，我写的归并算法的实现， 没有把归并算法的最佳性能发挥出来。。。。。。 简单测试发现: 当 数据量处于(0, 1万]时， Collections.sort性能优于MergeSortCompleter 当 数据量处于(1万, 100万]时， MergeSortCompleter性能优于Collections.sort 当 数据量处于(100万, 2000万]时， Collections.sort性能优于MergeSortCompleter 。。。

从以下版本开始:

1.0.0

作者:

JustryDeng

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
MergeSortCompleter(MergeSortCompleter parent, Comparable<T>[] data, int startIndex, int endIndex)
MergeSortCompleter(MergeSortCompleter parent, Comparable<T>[] data, int startIndex, int endIndex, boolean asc)
MergeSortCompleter(MergeSortCompleter parent, Comparable<T>[] data, int startIndex, int endIndex, int forkThreshold, boolean asc) 构造器

方法概要

限定符和类型	方法和说明
void	compute()
void	doSort(Comparable<T>[] data, int start, int end, boolean asc) 归并排序
void	onCompletion(CountedCompleter<?> caller) 触发onCompletion逻辑
void	splitAndMerge(Comparable<T>[] originArray, int left, int right, boolean asc) (两路)拆分、归并 数组

从类继承的方法 java.util.concurrent.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, decrementPendingCountUnlessZero, exec, firstComplete, getCompleter, getPendingCount, getRawResult, getRoot, helpComplete, nextComplete, onExceptionalCompletion, propagateCompletion, quietlyCompleteRoot, setPendingCount, setRawResult, tryComplete

从类继承的方法 java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MergeSortCompleter

public MergeSortCompleter(MergeSortCompleter parent,
                          Comparable<T>[] data,
                          int startIndex,
                          int endIndex)

另请参阅:

this#MergeSortCompleter(MergeSortCompleter, Comparable[], int, int, int, boolean)

MergeSortCompleter

public MergeSortCompleter(MergeSortCompleter parent,
                          Comparable<T>[] data,
                          int startIndex,
                          int endIndex,
                          boolean asc)

另请参阅:

this#MergeSortCompleter(MergeSortCompleter, Comparable[], int, int, int, boolean)

MergeSortCompleter

public MergeSortCompleter(MergeSortCompleter parent,
                          Comparable<T>[] data,
                          int startIndex,
                          int endIndex,
                          int forkThreshold,
                          boolean asc)

构造器

参数:

parent - 父任务

data - 数据容器

startIndex - 要被排序的数据的起始索引

endIndex - 要被排序的数据的结尾引

forkThreshold - 进行fork的数组长度阈值

asc - true-升序; false-降序

方法详细资料

compute

public void compute()

指定者:

compute 在类中 CountedCompleter<Void>

onCompletion

public void onCompletion(CountedCompleter<?> caller)

触发onCompletion逻辑

覆盖:

onCompletion 在类中 CountedCompleter<Void>

参数:

caller - 触发调用onCompletion方法的对象

doSort

public void doSort(Comparable<T>[] data,
                   int start,
                   int end,
                   boolean asc)

归并排序

参数:

data - 数据容器

start - 要被排序的数据的起始索引

end - 要被排序的数据的结尾引

asc - true-升序; false-降序

splitAndMerge

public void splitAndMerge(Comparable<T>[] originArray,
                          int left,
                          int right,
                          boolean asc)

(两路)拆分、归并 数组

参数:

originArray - 数组

left - 数组的起始元素索引

right - 数组的结尾元素索引

asc - 升序/降序。 true-升序; false-降序