Задача
Редактировать: Как указано в комментариях, я допустил ошибку с pthread_cond_wait, из-за которой он никогда не выходил из потока.
Я работаю над многопоточным назначением в C, где мне нужно использовать несколько потоков для сортировки массива 4x4 с shearsort , но я не могу зайти так далеко, потому что всякий раз, когда я использую pthread_join, приложение никогда не заканчивается и никогда не присоединяется. Приложение просто остается там, где оно есть, пока я не контролирую C, чтобы завершить его. Я испортил свой pthread_cond_wait, означая, что некоторые потоки никогда не будут продолжаться.
Наверное, я спрашиваю, как мне использовать pthread_wait_cond, потому что, когда у меня есть обе стороны оператора if / else, есть pthread_wait_cond, он ничего не выводит и просто застревает.
Кроме того, теперь это является частью основной проблемы, но я видел, как многие люди запускали pthreads в цикле for, но когда я пытался, чтобы переменная I, переданная в функцию, казалась заданной случайным образом, иногда она была правильной с каждый поток получает свой номер, но иногда потоки создаются с одинаковым номером. Нужно ли мне использовать мьютекс какого-то типа, чтобы pthread_create происходил атомарно, и как мне это сделать?
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <sched.h>
#include <fcntl.h>
#include <pthread.h>
#define N 4
void intSwap(int *a, int *b);
void *shearSort(void *rowCol);
pthread_cond_t sort0 = PTHREAD_COND_INITIALIZER;
pthread_cond_t sort1 = PTHREAD_COND_INITIALIZER;
pthread_cond_t sort2 = PTHREAD_COND_INITIALIZER;
pthread_cond_t sort3 = PTHREAD_COND_INITIALIZER;
pthread_cond_t writeArray = PTHREAD_COND_INITIALIZER;
pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
int array[N][N];
pthread_t thread[N];
void *shearSort(void *rowCol) {
int x = 0, y = 0;
printf("rowCol = %d", ((int)*(int*)rowCol));
pthread_mutex_lock(&lock);
if (((int)*(int*)rowCol)%2 == 0) {
for(x = 0; x < N-1; x++) {
for (y = 0; y < N-x-1; y++) {
//pthread_cond_wait(&writeArray, &lock);
if (array[((int)*(int*)rowCol)][y] > array[((int)*(int*)rowCol)][y+1]) {
printf("rowCol = %d, i = %d, j = %d Swapping %d & %d\n", ((int)*(int*)rowCol), x, y, array[((int)*(int*)rowCol)][y], array[((int)*(int*)rowCol)][y+1]);
intSwap(&array[((int)*(int*)rowCol)][y], &array[((int)*(int*)rowCol)][y+1]);
}
//pthread_cond_signal(&writeArray);
}
}
}
else {
for(x = 0; x < N-1; x++) {
for (y = 0; y < N-x-1; y++) {
//pthread_cond_wait(&writeArray, &lock);
if (array[((int)*(int*)rowCol)][y] < array[((int)*(int*)rowCol)][y+1]) {
printf("rowCol = %d, i = %d, j = %d Swapping %d & %d\n", ((int)*(int*)rowCol), x, y, array[((int)*(int*)rowCol)][y], array[((int)*(int*)rowCol)][y+1]);
intSwap(&array[((int)*(int*)rowCol)][y], &array[((int)*(int*)rowCol)][y+1]);
}
//pthread_cond_signal(&writeArray);
}
}
}
pthread_mutex_unlock(&lock);
if(((int)*(int*)rowCol) == 1) {
//pthread_join(thread[0], NULL);
}
if(((int)*(int*)rowCol) == 2) {
//pthread_join(thread[0], NULL);
//pthread_join(thread[1], NULL);
}
if(((int)*(int*)rowCol) == 3) {
//pthread_join(thread[0], NULL);
//pthread_join(thread[1], NULL);
//pthread_join(thread[2], NULL);
}
pthread_exit(NULL);
}
void intSwap(int *a, int *b) {
int temp = *a;
*a = *b;
*b = temp;
}
int main () {
FILE *input;
int i = 0, j = 0;
input = fopen("input.txt" , "r");
if (input != NULL) {
for (i = 0; i < N; i++) {
for (j = 0; j < N; j++) {
fscanf(input, "%d, ", &array[i][j]);
printf("%d, ", array[i][j]);
}
printf("\n");
}
printf("\n");
}
else {
perror( "There's a problem with the input.txt file, it doesn't seem to be there.");
exit( EXIT_FAILURE );
}
// for (i = 0; i < N; i++) {
// pthread_create(&thread[i], NULL, shearSort, (void *)&i);
// }
// for (i = 0; i < N; i++) {
// pthread_join(thread[i], NULL);
// }
int num0 = 0, num1 = 1, num2 = 2, num3 = 3;
pthread_create(&thread[0], NULL, shearSort, (void *)&num0);
pthread_create(&thread[1], NULL, shearSort, (void *)&num1);
pthread_create(&thread[2], NULL, shearSort, (void *)&num2);
pthread_create(&thread[3], NULL, shearSort, (void *)&num3);
pthread_join(thread[num0], NULL);
pthread_join(thread[1], NULL);
pthread_join(thread[2], NULL);
pthread_join(thread[3], NULL);
for (i = 0; i < N; i++) {
for (j = 0; j < N; j++) {
printf("%d, ", array[i][j]);
}
printf("\n");
}
return 0
}
Когда я запускал приведенный выше код без комментариев на pthread_cond_wait, в остальном я получал этот вывод из командной строки, тогда он просто останавливался.
5, 3, 9, 10,
2, -3, 11, 8,
20, 17, 19, 30,
24, 21, -2, 16,
rowCol = 0rowCol = 0, i = 0, j = 0 Swapping 5 & 3
rowCol = 1rowCol = 2rowCol = 2, i = 0, j = 0 Swapping 20 & 17
rowCol = 2, i = 0, j = 1 Swapping 20 & 19
^C
Теперь, когда я запускаю код как есть, я получаю этот вывод:
5, 3, 9, 10,
2, -3, 11, 8,
20, 17, 19, 30,
24, 21, -2, 16,
rowCol = 0rowCol = 0, i = 0, j = 0 Swapping 5 & 3
rowCol = 1rowCol = 1, i = 0, j = 1 Swapping -3 & 11
rowCol = 1, i = 0, j = 2 Swapping -3 & 8
rowCol = 1, i = 1, j = 0 Swapping 2 & 11
rowCol = 1, i = 1, j = 1 Swapping 2 & 8
rowCol = 2rowCol = 2, i = 0, j = 0 Swapping 20 & 17
rowCol = 2, i = 0, j = 1 Swapping 20 & 19
rowCol = 3rowCol = 3, i = 0, j = 2 Swapping -2 & 16
3, 5, 9, 10,
11, 8, 2, -3,
17, 19, 20, 30,
24, 21, 16, -2,