Основы программирования в Linux
Основы программирования в Linux читать книгу онлайн
Внимание! Книга может содержать контент только для совершеннолетних. Для несовершеннолетних чтение данного контента СТРОГО ЗАПРЕЩЕНО! Если в книге присутствует наличие пропаганды ЛГБТ и другого, запрещенного контента - просьба написать на почту [email protected] для удаления материала
perror("Thread pthread_setcancelstate failed"); exit(EXIT_FAILURE); } res = pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL); if (res != 0) { perror{"Thread pthread_setcanceltype failed"); exit(EXIT_FAILURE); } printf("thread_function is runningn"); for(i = 0; i < 10; i++) { printf("Thread is still running (%d)...n", i); sleep(1); } pthread_exit(0);}Когда вы выполните эту программу, то увидите следующий вывод, демонстрирующий отмену потока:
$ <b>./thread7</b>thread_function is runningThread is still running (0)...Thread is still running (1)...Thread is still running (2)...Canceling thread...Waiting for thread to finish...$Как это работает
После того как новый поток был создан обычным способом, основной поток засыпает (чтобы дать новому потоку время для запуска) и затем отправляет запрос на отмену потока.
sleep(3);printf("Cancelling thread...n");res = pthread_cancel(a_thread);if (res != 0) { perror("Thread cancelation failed"); exit(EXIT_FAILURE);}В созданном потоке вы сначала задаете состояние отмены, чтобы разрешить отмену потока:
res = pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);if (res != 0) { perror("Thread pthread_setcancelstate failed"); exit(EXIT_FAILURE);}Далее вы задаете тип отмены
PTHREAD_CANCEL_DEFERREDres = pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL);if (res != 0) { perror("Thread pthread_setcanceltype failed"); exit(EXIT_FAILURE);}И в конце поток ждет отмену:
for (i = 0; i < 10; i++) { printf("Thread is still running (%d)...n", i); sleep(1);}Потоки в изобилии
До настоящего момента у нас всегда был обычный поток исполнения программы, создающий еще только один поток. Тем не менее мы не хотим, чтобы вы думали, что можно создать только один дополнительный поток (упражнение 12.8).
В заключительном примере этой главы thread8.c мы покажем, как создать несколько потоков в одной и той же программе и затем собрать их снова в последовательности, отличающейся от порядка их создания.
#include <stdio.h>#include <unistd.h>#include <stdlib.h>#include <pthread.h>#define NUM_THREADS 6void *thread_function(void *arg);int main() { int res; pthread_t a_thread[NUM_THREADS]; void *thread_result; int lots_of_threads; for (lots_of_threads = 0; lots_of_threads < NUM_THREADS; lots_of_threads++) { res = pthread_create(&(a_thread[lots_of_threads]), NULL, thread_function, (void*)&lots_of_threads); if (res != 0) { perror("Thread creation failed"); exit(EXIT_FAILURE); } sleep(1); } printf("Waiting for threads' to finish...n"); for(lots of_threads = NUM_THREADS - 1; lots_of_threads >= 0; lots_of_threads--) { res = pthread_join(a_thread[lots_of_threads], &thread_result); if (res == 0) { printf("Picked up a threadn"); } else { perror("pthread_join failed"); } } printf("All donen"); exit(EXIT_SUCCESS);}void *thread_function(void *arg) { int my_number = *(int*)arg; int rand_num; printf("thread_function is running. Argument was %dn", my_number); rand_num = 1 + (int)(9.0*rand() / (RAND_MAX+1.0)); sleep(rand_num); printf("Bye from %dn", my_number); pthread_exit(NULL);}Выполнив эту программу, вы получите следующий вывод:
$ <b>./thread8</b>thread_function is running. Argument was 0
