Основы программирования в Linux
Основы программирования в Linux читать книгу онлайн
Внимание! Книга может содержать контент только для совершеннолетних. Для несовершеннолетних чтение данного контента СТРОГО ЗАПРЕЩЕНО! Если в книге присутствует наличие пропаганды ЛГБТ и другого, запрещенного контента - просьба написать на почту [email protected] для удаления материала
Следующая пара функций управляет значением семафора и объявляется следующим образом.
<b>#include <semaphore.h></b><b>int sem_wait(sem_t* sem);</b><b>int sem_post(sem_t* sem);</b>Обе они принимают указатель на объект-семафор, инициализированный вызовом
sem_initФункция
sem_postФункция
sem_waitsem_waitsem_waitsem_waitЕсть и другая функция семафора
sem_trywaitsem_waitПоследняя функция семафоров —
sem_destroy<b>#include <semaphore.h></b><b>int sem_destroy(gem_t* sem);</b>И снова эта функция принимает указатель на семафор и очищает любые ресурсы, которые у него могли быть. Если вы попытаетесь уничтожить семафор, которого дожидается какой-либо поток, то получите ошибку.
Как и большинство других, функций, все перечисленные функции возвращают 0 в случае успешного завершения.
А теперь выполните упражнение 12.3.
Текст этой программы thread3.c также основан на тексте программы thread1.c. Поскольку изменения значительны, мы приводим новый вариант полностью.
#include <stdio.h>#include <unistd.h>#include <stdlib.h>#include <string.h>#include <pthread.h>#include <semaphore.h>void *thread_function(void *arg);sem_t bin_sem;#define WORK_SIZE 1024char work_area[WORK_SIZE];int main() { int res; pthread_t a_thread; void *thread result; res = sem_init(&bin_sem, 0, 0); if (res != 0) { perror("Semaphore initialization failed"); exit(EXIT_FAILURE); } res = pthread_create(&a_thread, NULL, thread_function, NULL); if (res != 0) { perror("Thread creation failed"); exit(EXIT_FAILURE); } printf("Input some text. Enter 'end' to finishn"); while (strncmp("end", work_area, 3) != 0) { fgets(work_area, WORK_SIZE, stdin); sem_post(&bin_sem); } printf("nWaiting for thread to finish...n"); res = pthread_join(a_thread, &thread_result); if (res != 0) { perror("Thread join failed"); exit(EXIT_FAILURE); } printf("Thread joinedn"); sem_destroy(&bin_sem); exit(EXIT_SUCCESS);}void *thread function(void *arg) { sem_wait(&bin_sem); while(strncmp("end", work area, 3) != 0) { printf("You input %d charactersn", strlen(work_area)-1); sem_wait(&bin_sem); } pthread_exit(NULL);}Первое важное изменение — включение файла semaphore.h для обеспечения доступа к функциям семафоров. Далее вы объявляете семафор и несколько переменных и инициализируете семафор перед тем, как создать новый поток.
sem_t bin_sem;#define WORK_SIZE 1024char work_area[WORK_SIZE];int main() { int res; pthread_t a_thread; void *thread_result; res = sem_init(&bin_sem, 0, 0); if (res != 0) { perror("Semaphore initialization failed");
