Создание нескольких потоков в цикле for в C
Я работаю над алгоритмом банкиров и использую цикл для создания своих потоков. Проблема заключается в том, что цикл создает только 4 потока, когда 5 из них должны были быть созданы. Я проверил свою петлю, и все кажется правильным, если я что-то упустил.
/* these may be any values >= 0 */
#define NUMBER_OF_CUSTOMERS 5
#define NUMBER_OF_RESOURCES 3
/* the available amount of each resource */
int available[NUMBER_OF_RESOURCES];
/*the maximum demand of each customer */
int maximum[NUMBER_OF_CUSTOMERS][NUMBER_OF_RESOURCES];
/* the amount currently allocated to each customer */
int allocation[NUMBER_OF_CUSTOMERS][NUMBER_OF_RESOURCES];
/* the remaining need of each customer */
int need[NUMBER_OF_CUSTOMERS][NUMBER_OF_RESOURCES];
int release_resources(int customer_num, int release[]){
allocation[customer_num][NUMBER_OF_RESOURCES];
return 1;
}
pthread_mutex_t mutex;
int main(int argc, char *argv[]){
pthread_mutex_init(&mutex, NULL);
pthread_t threads [3];
int result;
unsigned index;
for(index = 0; index < NUMBER_OF_RESOURCES; index++){
available[index] = strtol(argv[index+1], NULL,10);
}
for(index = 0; index < NUMBER_OF_CUSTOMERS; ++index){
printf("\nCreating thead %d", index);
result = pthread_create(&threads[index],NULL,release_resources,1);
}
//printf("Done");
return 0;
}
1 ответ
Как я вижу, в вашем главном есть ошибка:
int main(int argc, char *argv[]){
//...
pthread_t threads [3];
int result;
unsigned index;
//...
for(index = 0; index < NUMBER_OF_CUSTOMERS; ++index){
printf("\nCreating thead %d", index);
result = pthread_create(&threads[index],NULL,release_resources,1);
}
//...
return 0;
}
В этом случае массив threads
имеет размер 3 элемента, и ваш индекс, из цикла for, имеет диапазон от 0 до 4 (размер 5 элементов), запомните вашу константу #define NUMBER_OF_CUSTOMERS 5
, Я удивлен, что вы получаете 4 потока, когда он должен был создать 3 до нарушения доступа к памяти.
Вы должны переопределить поток массива с правильным размером и используя константу NUMBER_OF_CUSTOMERS, как: pthread_t threads [NUMBER_OF_CUSTOMERS];