在三个线程之间发送信号答案

【问题标题】：Sending signals between three threads在三个线程之间发送信号
【发布时间】：2014-09-09 19:15:00
【问题描述】：

我必须编写一个使用 3 个线程的程序 - 一个用于读取字母，第二个用于计算字符，第三个用于输出它们。这是代码：

#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <unistd.h>
#include <linux/stat.h>
#include <pthread.h>
#include <string.h>
#include <signal.h>

int first[2];
int second[2];

void *input(void *ptr)
{
   char str[100];
   int length;

   while(1)
   {
      printf("Enter the message: ");
      fflush(stdout);
      length = read(STDIN_FILENO, str, sizeof(str));

      if(str[0] == ';')
         exit(2);

      if(length <= 0)
      {
         if(length == -1)
            perror("read");
         close(first[1]);
         exit(2);
      }

      if(write(first[1], str, length) != length)
      {
         perror("write");
         exit(2);
      }
   }
}

void *countChars(void *ptr)
{
   char str[100];
   int length, count = 0;

   while(1)
   {
      length = read(first[0], str, sizeof(str));
      if(length <= 0)
      {
         if(length == -1)
            perror("read");
         close(first[0]);
         close(second[1]);
         exit(2);
      }
      if(write(STDOUT_FILENO, str, length) != length)
      {
         perror("write");
         exit(2);
      }

      while(str[count] != '\n') count++;

      write(second[1], &count, sizeof(count));

      count = 0;
   }
}

void *output(void *ptr)
{
   int length, count = 0;

   while(1)
   {
      length = read(second[0], &count, sizeof(count));
      if(length < sizeof(count))
      {
         close(second[0]);
         exit(2);
      }

      printf("Number of characters: %d\n", count);
   }
}

int main()
{
   pthread_t t1, t2, t3;

   if(pipe(first) == -1)
   {
      printf("First pipe error");
      exit(1);
   }

   if(pipe(second) == -1)
   {
      printf("Second pipe error");
      exit(1);
   }

   pthread_create(&t1, NULL, input, NULL);
   pthread_create(&t2, NULL, countChars, NULL);
   pthread_create(&t3, NULL, output, NULL);

   pthread_join(t1, NULL);
   pthread_join(t2, NULL);
   pthread_join(t3, NULL);

   return 0;
}

它有效，但现在我必须在这里实现信号。发送 SIGUSR1 信号应该停止程序执行，直到发送 SIGUSR2 信号。

问题是当我发送信号时，只有一个线程得到它。因此我必须使用 FIFO 来通知其他线程执行了哪个信号并在其余线程中执行它。

我该怎么做？

【问题讨论】：

标签： c linux multithreading

【解决方案1】：

信号被传递给进程，而不是线程。因此，任何能够处理信号的线程都可以用来调用信号处理程序。您需要做的是弄清楚如何处理信号，然后决定如何将其传达给所有线程。您还没有真正描述“停止程序执行”是什么意思，所以我不得不猜测。

我建议使用pthread_sigmask 和sigwait 的组合。您可以使用 pthread_sigmask 禁用工作线程中 SIGUSR1 和 SIGUSR2 的自动处理。然后在第四个信号处理线程中调用sigwait 来显式处理这些信号。当信号处理线程接收到一个 SIGUSR1 时，它会设置一个全局标志。工作线程定期检查该标志并在设置时进入睡眠状态（可能在条件变量上？）。然后信号处理线程循环并再次调用sigwait。当它收到 SIGUSR2 时，它会唤醒工作线程，然后循环并再次调用 sigwait。

【讨论】：