2011年软件设计师辅导：并行排序算法（2）

2011年软件设计师辅导：并行排序算法（2） #

　　只要实现一个T类型两两比较的接口，然后调用ParallelSort 的 Sort 方法就可以了，是不是很简单?

　　下面是 ParallelSort类的代码

#

　　using System;

#

　　using System.Collections.Generic;

#

　　using System.Linq; #

　　using System.Text; #

　　using System.Threading; #

　　namespace Sort #

　　{

　　/**/ /// #

　　/// ParallelSort

　　///

#

　　///

　　public class ParallelSort < T >

#

　　{ #

　　enum Status #

　　{

#

　　Idle = 0 ,

#

　　Running = 1 , #

　　Finish = 2 , #

　　} #

　　class ParallelEntity

#

　　{

#

　　public Status Status; #

　　public T[] Array;

　　public IComparer < T > Comparer; #

　　public ParallelEntity(Status status, T[] array, IComparer < T > comparer) #

　　{

　　Status = status; #

　　Array = array; #

　　Comparer = comparer;

#

　　}

#

　　}

#

　　private void ThreadProc(Object stateInfo) #

　　{ #

　　ParallelEntity pe = stateInfo as ParallelEntity;

　　lock (pe)

#

　　{

#

　　pe.Status = ParallelSort < T > .Status.Running;

　　Array.Sort(pe.Array, pe.Comparer);

#

　　pe.Status = ParallelSort < T > .Status.Finish;

#

　　}

　　}

　　public void Sort(T[] array, IComparer < T > comparer) #

　　{ #

　　// Calculate process count

　　int processorCount = Environment.ProcessorCount; #

　　// If array.Length too short, do not use Parallel sort

　　if (processorCount == 1 || array.Length < processorCount)

　　{ #

　　Array.Sort(array, comparer);

#

　　return ;

#

　　} #

　　// Split array

　　ParallelEntity[] partArray = new ParallelEntity[processorCount]; #

　　int remain = array.Length; #

　　int partLen = array.Length / processorCount;

#