Распараллелить с помощью критической секции

#include <stdlib.h>
#include <time.h>
#include <iostream>
#include <stdio.h>
#include <process.h>
#include <windows.h>
using namespace std;
int j,i,k,size,n,pot,;
int * arr;
 
DWORD WINAPI Thread(PVOID pParams )
{
 
    for(i=0;i<size;i++)
    {
        arr[i]=rand()%8+1;
        printf("%4d",arr[i]);
    }
 
    cout<<endl;
 
 
    for (i=1; i<=size; i++)
    {
 
        for(j=0;j<size;j++)
        {
            if(arr[j]==i)
            {
                k++;
            }
        }
 
        for (int f=0;f<k;f++)
        {
            cout<<i<<" ";
        }
               
        cout<<endl; 
        k=0;
    }
 
 
return 0;
}
 
int main(void)
{
 
    cout<<"Vvedite razmer massiva\n";
    cin>>size;
    cout<<"Vvedite kol-vo potokov\n";
    cin>>pot;
    arr=(int*)malloc(size*sizeof(int));
 
HANDLE hThread=CreateThread(NULL,0,Thread,(PVOID)0,0,NULL);
    
    system("PAUSE");
    
    free(arr);
    return 0;
 
}

// ThreadSort.cpp: определяет точку входа для консольного приложения.
//
 
#include "stdafx.h"
 
using namespace std;
 
unsigned __stdcall ThreadFunc(void*);
 
typedef struct ARRAYINFO{
    int *ptr; // указатель на массив
    int size; // размер массива
} *PARRAYINFO;
 
 
 
int _tmain(int argc, _TCHAR* argv[])
{
int *arr = NULL, *_arr = NULL, i = 0, j = 0, size_array = 0, _size = 0, num_threads = 0;
unsigned int err = 0;
HANDLE *threads = NULL;
PARRAYINFO ArgList = NULL;
 
    cout<<"Enter size of array: ";
    cin>>size_array;
    if(size_array < 0) return -1;
    cout<<"Enter number of threads: ";
    cin>>num_threads;
 
    arr = (int *)malloc(size_array*sizeof(int));
    if(arr == NULL){
        err = GetLastError();
        return -1;
    }
 
    threads = (HANDLE *)malloc(num_threads*sizeof(HANDLE));
    if(threads == NULL){
        err = GetLastError();
        free(arr);
        return -1;
    }
 
    for(i = 0; i < size_array; i++)
    {
        arr[i]=rand()%8+1;
        printf("%4d",arr[i]);
    }
 
    
    _size = size_array / num_threads;
    _arr = arr; 
    ArgList = (PARRAYINFO)new ARRAYINFO;
    ArgList->ptr = arr;
    ArgList->size = _size;
    i=0;
    do{ 
        threads[i] = (HANDLE)_beginthreadex(NULL, 0, &ThreadFunc, (void *)ArgList, CREATE_SUSPENDED, NULL);     
        i++;        
        if(i == num_threads-1) _size += size_array - _size*num_threads; // коректируем размер последнего массива
        _arr = (int *)((DWORD)_arr+_size);
 
        ArgList = (PARRAYINFO)new ARRAYINFO;
        ArgList->ptr = _arr;
        ArgList->size = _size;
    }while(i < num_threads);
 
    for(i = 0; i < num_threads; i++){
        ResumeThread(threads[i]);
    }
    WaitForMultipleObjects(num_threads, threads, true, INFINITE); 
    free(arr);
    free(threads);
    return 0;
}
 
unsigned __stdcall ThreadFunc(void* pArguments ){
PARRAYINFO pArrayInfo = (PARRAYINFO)pArguments;
// Здесь пишем алгоритм сортировки  
    return 0;
}