Многопоточная сортировка Шелла

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>
 
#define PART_SIZE 10
#define GLOBAL_SIZE 40
 
typedef struct
{
    int *mass;
    int count;
} workpart;
 
void *shellSort(void *args);
void readFromFile(const char* filename,int *array1,int *array2,int *array3,int *array4,size_t size);
void writeToFile(const char* filename, int* array, size_t size);
void workPartInit(workpart part,int *array);
 
//sem_t bin_sem;
 
int main(int argc, const char* argv[])
{
    int threadc,res;
    int *array = (int*)malloc(sizeof(int) * GLOBAL_SIZE);
    void *thread_result;
 
    int arr1[PART_SIZE],arr2[PART_SIZE],arr3[PART_SIZE],arr4[PART_SIZE];
    workpart workpart_1,workpart_2,workpart_3,workpart_4;
    pthread_t thread_1,thread_2,thread_3,thread_4;
 
    if (argc != 4)
    {
        printf("Udage: program <INPUT FILE> <OUTPUT FILE> <THREAD COUNT>\n");
        exit(EXIT_FAILURE);
    }
 
    threadc = atoi(argv[3]);
 
    readFromFile(argv[1],arr1,arr2,arr3,arr4,GLOBAL_SIZE);
    workPartInit(workpart_1,arr1);
    workPartInit(workpart_2,arr2);
    workPartInit(workpart_3,arr3);
    workPartInit(workpart_4,arr4);
 
   /* res = sem_init(&bin_sem,0,0);
    if(res != 0)
    {
        perror("Semaphore init failed");
        exit(EXIT_FAILURE);
    } */
 
    res = pthread_create(&thread_1,NULL,shellSort,(void *)&workpart_1);
    if(res != 0)
    {
        perror("1st thread creation failed");
        exit(EXIT_FAILURE);
    }
 
    res = pthread_create(&thread_2,NULL,shellSort,(void *)&workpart_2);
    if(res != 0)
    {
        perror("2nd thread creation failed");
        exit(EXIT_FAILURE);
    }
 
    res = pthread_create(&thread_3,NULL,shellSort,(void *)&workpart_3);
    if(res != 0)
    {
        perror("3rd thread creation failed");
        exit(EXIT_FAILURE);
    }
 
    res = pthread_create(&thread_4,NULL,shellSort,(void *)&workpart_4);
    if(res != 0)
    {
        perror("4th thread creation failed");
        exit(EXIT_FAILURE);
    }
    printf("Program: All threads were created\n");
 
    res = pthread_join(thread_1,&thread_result);
    if(res != 0)
    {
        perror("1st thread join failed");
        exit(EXIT_FAILURE);
    }
    printf("Program: %s\n",(char *)thread_result);
 
    res = pthread_join(thread_2,&thread_result);
    if(res != 0)
    {
        perror("2nd thread join failed");
        exit(EXIT_FAILURE);
    }
    printf("Program: %s\n",(char *)thread_result);
 
    res = pthread_join(thread_3,&thread_result);
    if(res != 0)
    {
        perror("3rd thread join failed");
        exit(EXIT_FAILURE);
    }
    printf("Program: %s\n",(char *)thread_result);
 
    res = pthread_join(thread_4,&thread_result);
    if(res != 0)
    {
        perror("4th thread join failed");
        exit(EXIT_FAILURE);
    }
    printf("Program: %s\n",(char *)thread_result);
 
    writeToFile(argv[2], arr1, PART_SIZE);
    writeToFile(argv[2], arr2, PART_SIZE);
    writeToFile(argv[2], arr3, PART_SIZE);
    writeToFile(argv[2], arr4, PART_SIZE);
    printf("Program: Sort complete! Check your output file\n");
    free(array);
 
    return EXIT_SUCCESS;
}
 
void workPartInit(workpart curpart,int *array)
{
    curpart.mass = array;
    curpart.count = PART_SIZE;
}
 
void *shellSort(void *curworkpart)
{
    int n = ((workpart *)curworkpart)->count;
    int *a = ((workpart *)curworkpart)->mass;
 
    int step = n / 2;
    int j;
 
    while (step > 0)
    {
        int i = step;
        for (; i < n - step; i++)
        {
            j = i;
            while ((j >= 0) && (a[j]) > a[j + step])
            {
                int buf = a[j];
                a[j] = a[j + step];
                a[j + step] = buf;
                j--;
            }
        }
        step /= 2;
    }
    pthread_exit("Thread exit");
}
 
void readFromFile(const char* filename,int *array1,int *array2,int *array3,int *array4,size_t size)
{
    FILE* fo;
    fo = fopen(filename, "r");
    int i = 1;
 
    if (fo == 0)
    {
        perror(filename);
        exit(EXIT_FAILURE);
    }
 
    while (size--)
    {
        if(i <= 10)
            fscanf(fo, "%d", array1++);
        if(i >= 11 && i <= 20)
            fscanf(fo, "%d", array2++);
        if(i >= 21 && i <= 30)
            fscanf(fo, "%d", array3++);
        if(i >= 31 && i <= 40)
            fscanf(fo, "%d", array4++);
        i++;
    }
 
    fclose(fo);
}
 
void writeToFile(const char* filename, int* array, size_t size)
{
    FILE* fo;
    fo = fopen(filename, "r+");
 
    if (fo == 0)
    {
        perror(filename);
        exit(EXIT_FAILURE);
    }
 
    while (size--)
    {
        fprintf(fo, "%d ", *array++);
    }
 
    fclose(fo);
}

main () {
  FILE *f= fopen ("infile", "rt");
  if (!f) {
    printf ("can not open file %s\n", "infile");
    return -1;
  }
  int n, i, j;
  fscanf (f, "%d", &n);
  int *in= malloc (n * sizeof(int));
  if (!in) {
    printf ("can not allocate memory\n");
    return -1;
  }
  for (i= 0; i < n; i++) fscanf (f, "%d", in+i);
  fclose (f);
  workpart wp[4];
  pthread_t thr[4];
  for (i=0; i < 4; i++) {
    wp[i].data= in + n/4*i;
    wp[i].count= (i<3) ? n/4 : n - n/4*3;
    if (pthread_create(&thr[i], NULL, shellSort,( void *)&wp[i])) {
      printf ("thread %d creation failed", i);
      return -1;
    }
  }
  for (i=0; i < 4; i++) if (pthread_join (thr[i], NULL)) {
    printf ("thread %d join failed", i);
    return -1;
  }
  f= fopen ("outfile", "w");
  if (!f) {
    printf ("can not create file %s", "outfile");
    return -1;
  }
  fprintf (f, "%d\n", n);
  for (i=0; i < 4; i++) for (j=0; j < wp[i].count; j++)
    fprintf (f, "%d\n", wp[i].data[j]);
  fclose (f);
  free (in);
}