Обратные вызовы pthread прерывают ввод пользователя
Вопрос
Я написал свой собственный модуль stop_watch. Это создаст поток и засыпает на несколько секунд. По истечении секунд он вызовет функцию обратного вызова в main.c и сообщит пользователю, что время истекло. Р>
Это сделано для того, чтобы у пользователя было всего 3 секунды для ввода цифры, и ему нужно будет ввести 5 цифр. Если время истекло, программа должна остановиться. Р>
2 проблемы. 1) если они введут цифру в нужное время. Как я могу отменить тему. Я думал об использовании thread_kill или thread_cancel? 2) Как я могу завершить цикл do_ while? Поскольку scanf будет блокироваться во время ожидания входа пользователя. Р>
Большое спасибо за любые предложения,
Мой код ниже:
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include "stop_watch.h"
struct data_struct *g_data_struct;
void timeout_cb(int id)
{
printf("Digit timeout\n");
free(g_data_struct);
}
int main()
{
pthread_t thread_id;
unsigned int digit = 0;
g_data_struct = (struct data_struct*) calloc(1, sizeof(*g_data_struct));
if(!g_data_struct)
{
printf("=== failed to allocate memory ===\n");
return 0;
}
/* start timer for 3 seconds */
g_data_struct->seconds = 3;
g_data_struct->func_ptr = timeout_cb;
thread_id = start_stopwatch(g_data_struct);
do
{
printf("Enter digit: ");
scanf("%d", &digit);
}while(1);
pthread_join(thread_id, NULL);
printf("=== End of Program - all threads in ===\n");
free(g_data_struct);
return 0;
}
#include <stdio.h>
#include <pthread.h>
#include "stop_watch.h"
pthread_t thread_id;
static id = 10;
/* start sleeping and call the callback when seconds have expired */
static void* g_start_timer(void *args)
{
void (*function_pointer)(int id);
int seconds = ((struct data_struct*) args)->seconds;
function_pointer = ((struct data_struct*) args)->func_ptr;
sleep(seconds);
(void) (*function_pointer)(id);
pthread_exit(NULL);
return 0;
}
/* Will sleep in its own thread for a period of seconds */
int start_stopwatch(struct data_struct *g_data_struct)
{
int rc = 0;
int seconds = g_data_struct->seconds;
printf("=== start_stopwatch(): %d\n", seconds);
rc = pthread_create(&thread_id, NULL, g_start_timer, (void *) g_data_struct);
if(rc)
{
printf("=== Failed to create thread\n");
return 1;
}
return thread_id;
}
Кстати, этот вопрос о C99 GCC.
Решение
Я бы не рекомендовал использовать для этого отдельную тему. Но так как это похоже на упражнение, чтобы научиться использовать потоки, я пойду с этим.
Вы можете установить глобальный логический флаг, который указывает, была ли введена цифра. В g_start_timer, непосредственно перед вызовом function_pointer, проверьте, был ли установлен флаг. Если это так, не вызывайте функцию.
Если вы хотите, чтобы поток умер раньше, до истечения периода ожидания, вы можете использовать мьютекс с блокировкой попытки.
РЕДАКТИРОВАТЬ: Поскольку вы говорите, что это не упражнение, я упомяну, как я бы это сделал. Либо используйте функцию, которая может прервать ожидание ввода в stdin, например, select () или poll (). Или используйте alarm () для прерывания. Вот пример использования будильника:
#include <stdio.h>
#include <signal.h>
#include <unistd.h>
#include <errno.h>
void alarm_signal(int signum)
{
}
int main()
{
char c;
unsigned int v = 0;
struct sigaction act;
puts("Enter digit: ");
/* Register dummy handler for alarm */
act.sa_handler = &alarm_signal;
act.sa_flags = 0;
sigemptyset(&act.sa_mask);
sigaction(SIGALRM, &act, NULL);
/* Set timer for 3 seconds */
alarm(3);
/* Read the digits */
errno = 0;
while(0 != read(STDIN_FILENO, &c, 1))
{
if(c < '0' || c > '9')
break;
v = v*10 + c - '0';
}
if(errno == EINTR)
puts("Timed out");
else
printf("Value is %d\n", v);
return 0;
}
Другие советы
Конечно, вы можете использовать thread_cancel, чтобы отменить тему. Что касается функции scanf, вы можете подумать об использовании каналов для имитации ввода с терминала.