Я новичок в разработке ядра Linux. Я пытался изучить создание и синхронизацию потоков. Моя конечная цель - создать два потока, и эти два потока используют общий ресурс, охраняемый семафором.
Код
#include<stdio.h>
#include<string.h>
#include<pthread.h>
#include<stdlib.h>
#include<unistd.h>
#include<semaphore.h>
sem_t sema_obj;
pthread_t tid[2];
int shared_val = 0;
void* doSomeThing(void *arg)
{
unsigned long i = 0;
pthread_t id = pthread_self();
for(i=0;i<5;i++){
printf("\n going to wait %x\n",(unsigned int)id);
sem_wait(&sema_obj);
shared_val++;
sleep(1);
printf("\n %d The value of shared_val is %d in thread %x \n",(int)i, shared_val, (unsigned int)id);
sem_post(&sema_obj);
printf("\n gave up sem %x\n",(unsigned int)id);
}
for(i=0; i<(0xFFFFFFFF);i++);
return NULL;
}
int main(void)
{
int i = 0;
int err;
sem_init(&sema_obj, 0, 1);
while(i < 2)
{
pthread_attr_t attr;
struct sched_param param;
pthread_attr_init(&attr);
pthread_attr_setschedpolicy(&attr, SCHED_FIFO);
param.sched_priority = 50;
pthread_attr_setschedparam(&attr, ¶m);
//sched_setscheduler(current, SCHED_FIFO, ¶m);
err = pthread_create(&(tid[i]), &attr, &doSomeThing, NULL);
//err = pthread_create(&(tid[i]), NULL, &doSomeThing, NULL);
if (err != 0)
printf("\ncan't create thread :[%s]", strerror(err));
else
printf("\n Thread created successfully 0x%X \n",(unsigned int)tid[i]);
i++;
}
enter code here
sleep(60);
return 0;
}
Я компилирую это с
gcc -o threads_op -pthread -lrt threads.c
После запуска кода я вижу:
Thread created successfully 0xB75CBB40
going to wait b75cbb40
Thread created successfully 0xB6DCAB40
going to wait b6dcab40
0 The value of shared_val is 1 in thread b75cbb40
gave up sem b75cbb40
going to wait b75cbb40
1 The value of shared_val is 2 in thread b75cbb40
gave up sem b75cbb40
going to wait b75cbb40
2 The value of shared_val is 3 in thread b75cbb40
gave up sem b75cbb40
going to wait b75cbb40
3 The value of shared_val is 4 in thread b75cbb40
gave up sem b75cbb40
going to wait b75cbb40
4 The value of shared_val is 5 in thread b75cbb40
gave up sem b75cbb40
0 The value of shared_val is 6 in thread b6dcab40
gave up sem b6dcab40
going to wait b6dcab40
1 The value of shared_val is 7 in thread b6dcab40
gave up sem b6dcab40
going to wait b6dcab40
2 The value of shared_val is 8 in thread b6dcab40
gave up sem b6dcab40
going to wait b6dcab40
3 The value of shared_val is 9 in thread b6dcab40
gave up sem b6dcab40
going to wait b6dcab40
4 The value of shared_val is 10 in thread b6dcab40
gave up sem b6dcab40
RTPRIO для этого процесса - '-', S 1000 4551 4338 - 00:00:00 threads_op
Были следующие вопросы,
1) Почему поток не работает в режиме реального времени и принимает приоритет, который я устанавливаю?
2) Почему семафор не блокируется поочередно двумя потоками и не обновляет общую переменную? У двух потоков одинаковый приоритет.
Если вы знаете пошаговое руководство, чтобы понять темы ядра Linux, поделитесь.