Как программно прекратить чтение со стандартного ввода?

Кажется, вы хотите, чтобы потоки перестали блокироваться на fgetc(stdin), когда происходит какое-то событие, чтобы вместо этого обработать это событие. Если это так, вы можете select() использовать как stdin, так и какой-либо другой канал сообщений, чтобы поток мог обрабатывать ввод из обоих:

fd_set descriptor_set
FD_ZERO(&descriptor_set); 
FD_SET(STDIN_FILENO, &descriptor_set); 
FD_SET(pipefd, &descriptor_set); 

if (select(FD_SETSIZE, &descriptor_set, NULL, NULL, NULL) < 0) 
{ 
  // select() error
} 

if (FD_ISSET(STDIN_FILENO, &descriptor_set)) {
  // read byte from stdin
  read(STDIN_FILENO, &c, 1);
}

if (FD_ISSET(pipefd, &descriptor_set)) 
  // Special event. Do something else

Также обратите внимание, что только один поток в вашем процессе должен читать из stdin.

Вы можете либо «закрыть» стандартный ввод, либо подключить стандартный ввод к «/dev/null» («NUL:» в Windows) с помощью freopen(), либо вы можете подключить стандартный ввод к «/dev/zero».

Если вы закроете его, каждый вызов функции завершится ошибкой, потому что файловый поток недействителен. Если вы подключите его к нулевому источнику данных, все чтения завершатся ошибкой и немедленно вернут EOF. Если вы подключите его к нулевому источнику данных, каждое чтение будет успешным и вернет соответствующее количество нулевых байтов.

Вполне возможно, что один из них будет достаточно соответствовать вашим потребностям. Если нет, то вам, вероятно, нужно дать нам более подробное объяснение того, что вам действительно нужно.

С помощью POSIX вы можете сигнализировать потоку, чьи примитивы (например, «чтение») блокируются, и если вы настроили обработчик сигнала бездействия со сброшенным битом SA_RESTART, то примитивы завершатся ошибкой EINTR. Вот рабочая версия оригинала:

#include <pthread.h>
#include <stdio.h>
#include <signal.h>
#include <string.h>
#include <unistd.h>

static void SignalHandler(int signum)
{
}

void* reader(void *arg)
{
    char read_char;
    while((read_char = fgetc(stdin)) != EOF) {
        ;
    }
    printf("leaving reader\n");
    return NULL;
}

int main(int argc, const char * argv[])
{
    struct sigaction action;
    memset(&action, 0, sizeof(action));  // SA_RESTART bit not set
    action.sa_handler = SignalHandler;
    sigaction(SIGUSR1, &action, NULL);

    pthread_t thread;
    pthread_create(&thread, NULL, reader, NULL);

    sleep(1); // time to start reader thread
    // Do something so the fgetc in the reader thread will return
    pthread_kill(thread, SIGUSR1);
    sleep(1); // time to exit reader thread; could join it if set up

    return 0;
}

Александр опубликовал правильное решение. Его ответ отвечает именно на вопрос, который я задал. Это следует за простым самокомпилируемым кодом, основанным на его подсказках:

#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <sys/select.h>

static int pipe_fds[2];

void* user_interaction()
{
    char read_char;
    
    fd_set descriptor_set;
    FD_ZERO(&descriptor_set); 
    FD_SET(STDIN_FILENO, &descriptor_set); 
    FD_SET(pipe_fds[0], &descriptor_set);

    while(1)
    {
        if (select(FD_SETSIZE, &descriptor_set, NULL, NULL, NULL) < 0) {
            // select() error
        }

        if (FD_ISSET(STDIN_FILENO, &descriptor_set)) {
            // read byte from stdin
            read(STDIN_FILENO, &read_char, 1);
            // Re-set the selected file descriptor so it can
            // be signaled again
            FD_SET(STDIN_FILENO, &descriptor_set);
        }

        if (FD_ISSET(pipe_fds[0], &descriptor_set))
            // Special event. break
            break;
    }
    
    pthread_exit(NULL);
}

int main(void)
{
    pipe(pipe_fds);
    
    pthread_t thread;
    pthread_create(&thread, NULL, user_interaction, NULL);
    
    // Before closing write pipe endpoint you are supposed
    // to do something useful
    sleep(5);

    close(pipe_fds[1]);
    
    pthread_join(thread, NULL);
    
    pthread_exit(NULL);
}

Я попытался использовать код из этого ответа в слегка измененном виде:

void *user_interaction()
{
    char ch;
    int rv;
    fd_set set;

    FD_ZERO(&set);
    FD_SET(STDIN_FILENO, &set);
    FD_SET(pipe_fds[0], &set);

    while (1)
    {
        rv = select(pipe_fds[0] + 1, &set, NULL, NULL, NULL);
        if (rv < 0)
        {
            printf(">>> select(): error occurred, %d\n", rv);
            break;
        }
        
        if (FD_ISSET(pipe_fds[0], &set))
        {
            printf(">>> pipe_fds[0]: is ready\n");
            break;
        }

        if (FD_ISSET(STDIN_FILENO, &set))
        {
            read(STDIN_FILENO, &ch, 1);
            write(STDOUT_FILENO, &ch, 1);
        }
    }

    pthread_exit(NULL);
}

но не получил ожидаемого поведения. При выполнении, как показано ниже:
$ echo -n 1 | ./a.out

мой терминал визуализировался с 1 в бесконечном цикле, и select() никогда не сообщал о готовности канала (т.е. даже после close()ing его в основном потоке).

Немного поэкспериментировав, я понял, что вам нужно переместить FD_ZERO/FD_SET внутри цикла, чтобы select() работало так, как нужно:

void *user_interaction()
{
    char ch;
    int rv;
    fd_set set;

    while (1)
    {
        FD_ZERO(&set);
        FD_SET(STDIN_FILENO, &set);
        FD_SET(pipe_fds[0], &set);

        rv = select(pipe_fds[0] + 1, &set, NULL, NULL, NULL);
        if (rv < 0)
        {
            printf(">>> select(): error occurred, %d\n", rv);
            break;
        }
        
        if (FD_ISSET(pipe_fds[0], &set))
        {
            printf(">>> pipe_fds[0]: is ready\n");
            break;
        }

        if (FD_ISSET(STDIN_FILENO, &set))
        {
            read(STDIN_FILENO, &ch, 1);
            write(STDOUT_FILENO, &ch, 1);
        }
    }

    pthread_exit(NULL);
}