6

我正在编写一个程序，有一个主线程和一些工作线程，我想正确处理信号。我的问题如下：

主线程启动并进行所有分配

主线程设置一个 SIGINT 信号处理程序

主线程启动工作线程。工作线程不需要特殊的清理，但是它们可以在系统调用或信号量上休眠。

当收到 SIGINT 时，我的理解是只有一个线程收到它。因此，如果线程在系统调用或信号量上处于休眠状态，它们将不会被唤醒，并且我将无法 pthread_join 我的工作线程并在我的主线程中进行所有必要的清理。

以下信号处理程序可以解决我的问题吗？

void term(int sig)
{
    g_do_cleanup = 1;
    pthread_kill(worker_1_id, some_other_signal);
    ...
    pthread_kill(worker_2_id, some_other_signal);
}

我期望的是，在收到 SIGINT 后，所有线程都会收到另一个信号，退出阻塞调用，看到g_do_cleanup标志并优雅地退出。

欢迎任何关于如何正确执行此操作的评论或链接。

编辑：我不是在寻找一种方法来唤醒等待特定条件的多个线程，所以我不认为 pthread_cond_signal 方法是我正在寻找的。我想要的是：

  • 找到一种方法，使在阻塞调用中被阻塞的所有线程都从这些调用中返回。
  • 或者杀死除主线程之外的所有线程。
4

3 回答 3

4

这是我通常在主应用程序线程中所做的：


/* before starting other threads */
sigset_t sigs;
sigemptyset( &sigs );
sigaddset( &sigs, SIGTERM );
sigaddset( &sigs, SIGINT );
/* add other signals to handle */
if ( pthread_sigmask( SIG_BLOCK, &sigs, 0 )) { /* handle error */ }
/* can start threads now */
...
/* in the main event loop */
siginfo_t info;
if ( sigwaitinfo( &sigs, &info ) == -1 ) { /* handle error */ }
switch( info.si_signo )
{
  case SIGTERM:
  case SIGINT: /* raise shutdown event */ break;
  default: /* other actions - log rotation, etc. */
}
...

这种方式信号成为常规应用程序事件 - 没有特殊的信号上下文限制等。等待也可以通过超时来完成sigtimedwait，尽管 BSD 衍生产品不支持它。

于 2009-05-28T02:31:38.403 回答
2

在我看来，您想要的是一个 pthread 条件变量，这样您就可以通过从主线程中选择一个“事件”来唤醒任意数量的多个线程。

有关详细信息，请参阅PTHREAD_COND_DESTROY和PTHREAD_COND_BROADCAST的手册页。

于 2009-05-27T15:09:17.907 回答
1

你的计划似乎很好。您正在强制一个线程处理系统信号。您需要使用 pthread-sigmask() 屏蔽工作线程中除其他信号之外的信号。

我想我会用一个单独的线程来处理进程信号而不是主线程。在等待运行信号处理程序时，让它永远等待信号量或 sigwait() 或其他任何东西。将 pthread-kill 代码移出信号处理程序。只需设置开关并让信号等待线程将 other_signal 发送到工作线程并自行退出。

于 2009-05-27T20:06:40.053 回答