Пример за съединяване на нишки

• Дефинираме функция за генериране на пермутации

• Дефинираме функция при работа на нишките:

  • Разпределяме вектор с размер arg

  • Инициализираме вектора с първата пермутация и го отпечатваме

  • Докато има следваща пермутация: генерираме, отпечатваме и синхронизираме

  • Почистваме, като освобождаваме заетата от вектора памет и приключваме нишката

• В главната функция:

  • Стартираме функцията за нишка с размер 4, изход при грешка

  • Стартираме функцията за нишка с размер 3, изход при грешка

  • Изчакваме първата нишка и отпечатваме известие, изход при грешка

  • Изчакваме втората нишка и отпечатваме известие, изход при грешка

  • Отпечатваме Job Done! и приключваме

threads-join.c

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<pthread.h>
// Print
void print(int *v, int n)
{
  for(int i=0;i<n;i++)
  printf("%i", v[i]);
  printf("\n");
}
// Swap
void swap(int *i, int *j)
{
  int temp = *i;
  *i = *j;
  *j = temp;
}
// Reverse
void reverse(int *v, int n)
{
   for(int i=0;i<(n/2); i++)
   swap(&v[i], &v[n-1-i]);
}
// Permute
int permute(int *v, int n)
{
  int i = n-1, j;
  while((i > 1) && (v[1] < v[i-1])) i--;
  if(v[i] > v[i-1])
  {
    j = n - 1;
    while(v[j] < v[i-1]) j--;
    swap(&v[j], &v[i-1]);
    reverse(&v[i], n-1);
    return 1;
  }
  return 0;
}
// Threads Function
void * func(void *arg)
{
  int i;
  int n = *(int*)arg; // n = 3 or 4
  int *v = malloc(sizeof(int)*n); // v[n]
  for(i=0;i<n;i++) v[i] = i+1; // 1,2 ... n
  print(v,n); // 123 or 1234
  while(permute(v,n) != 0)
  {
    print(v,n);
    sync();
  }
  free(v);
  pthread_exit(arg);
}
// Main
int main(int argc, char *argv)
{
   void *ret;
   int result;
   pthread_t thread1, thread2;

   // thread one
   int n1 = 4;
   result = pthread_create(&thread1,NULL,func,&n1);
   if(result != 0)
   {
      printf("Error Creating Thread One!\n");
      return EXIT_FAILURE; // return -1;
   }

   // tread two
   int n2 = 3;
   result = pthread_create(&thread2,NULL,func,&n2);
   if(result != 0)
   {
      printf("Error Creating Thread Two!\n");
      return EXIT_FAILURE; // return -1;
   }

   // thread one result
   result = pthread_join(thread1, &ret);
   if(result != 0)
   {
     printf("Error Joining Thread One!\n");
     return EXIT_FAILURE; // return -1;
   }
   printf("Thread one finished with result: %i\n", *(int*)ret);

   // thread two result
   result = pthread_join(thread2, &ret);
   if(result != 0)
   {
     printf("Error Joining Thread Two!\n");
     return EXIT_FAILURE; // return -1;
   }
   printf("Thread two finished with result: %i\n", *(int*)ret);

   // Job Done
   printf("Job Done!\n");

   return EXIT_SUCCESS; // return 0
}

Компилиране на програмата с изрична инструкция към компилатора да поддръжка нишки:

gcc threads-join.c -o threads-join -lpthread