Удаление pthread mutex/rwlock в обработчике сигнала

@iRomul · Регистрация: 17.10.2012

Студворк — интернет-сервис помощи студентам

Необходимо удалить мьютекс в обработчике сигнала. Т.е. есть главный поток, выполняющий какую-то задачу в бесконечном цикле, есть несколько производных потоков, выполняюзий аналогичные задачи над массивом. Управление доступом к массиву определяется с помощью pthread мьютексов и rwlock. Но уничтожить его не получается - удалить заблокированный мьтекс нельзя (точнее в доке это описывается как UB), но если его разблокировать, то какой-то из потоков, естественно, тут же его блокирует. Если оставить все как есть, то при повторном запуске программы на экран выводится некорректный результат. Код:

C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
#include <unistd.h>
#include <stdio.h>
#include <pthread.h>
#include <string.h>
#include <ctype.h>
#include <sys/types.h>
#include <signal.h>
 
#include <stdlib.h>
 
#include "thread_data.h"
#include "exchange_types.h"
 
pthread_rwlock_t rwlock;
 
unsigned int main_time   = 500000;
unsigned int shift_time  = 1000000;
unsigned int mirror_time = 2000000;
unsigned int count_time  = 4000000;
 
void signal_handler(int signo) {
 
    // Destroying locked lock or mutex is UB
    pthread_rwlock_destroy(&rwlock);
    exit(1);
 
}
 
void* shift_letter_case_async( void* array ) {
 
    while(1) {
 
        if( pthread_rwlock_rdlock(&rwlock) < 0 )
            handle_error("rdlock[shift]");
 
        carray_t* arr = (carray_t*) array;
        shift_letter_case( arr->array, arr->size );
 
        if( pthread_rwlock_unlock(&rwlock) < 0 )
            handle_error("unlock[shift]");
 
        usleep(shift_time);
 
    }
 
    return NULL;
 
}
 
void* mirror_array_async( void* array ) {
 
    while(1) {
 
        if( pthread_rwlock_rdlock(&rwlock) < 0 )
            handle_error("rdlock[mirror]");
 
        carray_t* arr = (carray_t*) array;
        mirror_array( arr->array, arr->size );
 
        if( pthread_rwlock_unlock(&rwlock) < 0 )
            handle_error("unlock[mirror]");
 
        usleep(mirror_time);
 
    }
 
    return NULL;
 
}
 
void* count_async( void* array ) {
 
    while(1) {
 
        if( pthread_rwlock_wrlock(&rwlock) < 0 )
            handle_error("wrlock[count]");
 
        carray_t* arr = (carray_t*) array;
        count_upper_letters( arr->array, arr->size );
 
        if( pthread_rwlock_unlock(&rwlock) < 0 )
            handle_error("unlock[count]");
 
        usleep(count_time);
 
    }
 
    return NULL;
 
}
 
int main( int argc, char** argv ) {
 
    /* Common data */
    char letters[ 'z' - 'a' + 1 ];
    size_t letter_len;
    carray_t transferer;
    /* pthread data */
    pthread_t threads[3];
 
    /* Initializing array */
    letter_len = sizeof(letters);
    for( int i = 0; i < letter_len; i++ )       
        letters[i] = 'a' + i;
 
    transferer.array = letters;
    transferer.size = letter_len;
 
    /* Initializing signal handlers */
    if ( signal(SIGINT, signal_handler) == SIG_ERR )
        handle_error("signal[SIGINT]");
    if ( signal(SIGTERM, signal_handler) == SIG_ERR )
        handle_error("signal[SIGTERM]");
 
    /* Initializing locks */
    if( pthread_rwlock_init(&rwlock, NULL) < 0 )
        handle_error("pthread_rwlock_init");
 
    /* Initializing threads */
    if( pthread_create( &threads[0], NULL, shift_letter_case_async, &transferer ) != 0 )
        handle_error("phtread_create[shift_letter_case]");
 
    if( pthread_create( &threads[1], NULL, mirror_array_async, &transferer ) != 0 )
        handle_error("phtread_create[mirror_array]");
 
    if( pthread_create( &threads[2], NULL, count_async, &transferer ) != 0 )
        handle_error("phtread_create[count]");
 
    while(1) {      
 
        if( pthread_rwlock_wrlock(&rwlock) < 0 )
            handle_error("wrlock[main]");
 
        print_array(letters, letter_len);
 
        if( pthread_rwlock_unlock(&rwlock) < 0 )
            handle_error("unlock[main]");
 
        usleep(main_time);
 
 
    }
 
    return 0;
 
}

Как быть?

@NoMasters · 01.07.2015, 07:02

Выставить какой-нибудь флаг, чтобы даль понять всем потокам, что концерт окончен.

Новые блоги и статьи Все статьи Все блоги /
Функция установки текстового статуса в реквизите формы документа Maks 01.04.2026 Алгоритм из решения ниже реализован на нетиповом документе "ВыдачаОборудованияНаСпецтехнику" разработанного в конфигурации КА2, в дополнении к предыдущему решению. На форме документа создается. . .	К слову об оптимизации kumehtar 01.04.2026 Вспоминаю начало 2000-х, университет, когда я писал на Delphi. Тогда среди программистов на форумах активно обсуждали аккуратную работу с памятью: нужно было следить за переменными, вовремя. . .	Идея фильтра интернета (сервер = слой+фильтр). Hrethgir 31.03.2026 Суть идеи заключается в том, чтобы запустить свой сервер, о чём я если честно мечтал давно и давно приобрёл книгу как это сделать. Но не было причин его запускать. Очумелые учёные напечатали на. . .	Модель здравосоХранения 6. ESG-повестка и устойчивое развитие; углублённый анализ кадрового бренда anaschu 31.03.2026 В прикрепленном документе раздумья о том, как можно поменять модель в будущем
10 пpимет, которые всегда сбываются Maks 31.03.2026 1. Чтобы, наконец, пришла маршрутка, надо закурить. Если сигарета последняя, маршрутка придет еще до второй затяжки даже вопреки расписанию. 2. Нaдоели зима и снег? Не надо переезжать. Достаточно. . .	Перемещение выделенных строк ТЧ из одного документа в другой Maks 31.03.2026 Реализация из решения ниже выполнена на примере нетипового документа "ВыдачаОборудованияНаСпецтехнику" с единственной табличной частью "ОборудованиеИКомплектующие" разработанного в конфигурации КА2. . . .	Functional First Web Framework Suave DevAlt 30.03.2026 Sauve. IO Апнулись до NET10. Из зависимостей один пакет, работает одинаково хорошо как в режиме проекта так и в интерактивном режиме. из сложностей - чисто функциональный подход. Решил. . .	Автоматическое создание документа при проведении другого документа Maks 29.03.2026 Реализация из решения ниже выполнена на нетиповых документах, разработанных в конфигурации КА2. Есть нетиповой документ "ЗаявкаНаРемонтСпецтехники" и нетиповой документ "ПланированиеСпецтехники". В. . .

@NoMasters Псевдослучайный 1946 / 1146 / 98 Регистрация: 13.09.2011 Сообщений: 3,215
	01.07.2015, 07:02
	Выставить какой-нибудь флаг, чтобы даль понять всем потокам, что концерт окончен. 2