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

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

#

　　// Copy data to splited array

　　for ( int i = 0 ; i < processorCount; i ++ )

#

　　{ #

　　if (i == processorCount - 1 )

　　{ #

　　partArray[i] = new ParallelEntity(Status.Idle, new T[remain], comparer);

　　} #

　　else #

　　{

#

　　partArray[i] = new ParallelEntity(Status.Idle, new T[partLen], comparer); #

　　remain -= partLen;

　　}

#

　　Array.Copy(array, i * partLen, partArray[i].Array, 0 , partArray[i].Array.Length); #

　　} #

　　// Parallel sort #

　　for ( int i = 0 ; i < processorCount - 1 ; i ++ )

　　{

　　ThreadPool.QueueUserWorkItem( new WaitCallback(ThreadProc), partArray[i]); #

　　} #

　　ThreadProc(partArray[processorCount - 1 ]); #

　　// Wait all threads finish

#

　　for ( int i = 0 ; i < processorCount; i ++ )

　　{

　　while ( true )

　　{ #

　　lock (partArray[i]) #

　　{ #

　　if (partArray[i].Status == ParallelSort < T > .Status.Finish) #

　　{

　　break ;

#

　　} #

　　}

#

　　Thread.Sleep( 0 );

#

　　} #

　　}