Сигналы

struct sigaction sa={0};
sa.sa_handler=on_term;
sigemptyset(&sa.sa_mask);
sigaction(SIGTERM,&sa,NULL);

void h(int s){
  int saved=errno;
  flag=1;
  errno=saved;
}

static void handler(int sig) {
    (void)sig;
    /* выбрать действие, допустимое в асинхронном обработчике */
}

sigemptyset(&sa.sa_mask);
sigaddset(&sa.sa_mask,SIGUSR1);

sigset_t set; sigemptyset(&set); sigaddset(&set,SIGTERM);
pthread_sigmask(SIG_BLOCK,&set,NULL);
/* затем создаём потоки */

sigprocmask(SIG_BLOCK,&set,NULL);
raise(SIGUSR1);
raise(SIGUSR1);

sigset_t cur;
/* дополните код проверкой текущей маски потока */

void h(int s){ printf("signal %d\n",s); }

static int wake_fd;
void h(int s){ char b=(char)s; (void)write(wake_fd,&b,1); }

void h(int s){
  /* перед добавлением вызова сверяем контракт функции */
}

struct pollfd fds[]={{wake_read,POLLIN,0},{server,POLLIN,0}};

stop_accepting();
request_workers_stop();
join_workers();
close_resources();

if(stop_requested) force_requested=1;
else stop_requested=1;

while(!stop){
  int rc=next_event(&ev);
  if(rc<0 && errno==EINTR) continue;
  if(rc>0) handle(&ev);
}

$ ____ -f -tt -e trace=signal,read,poll ./server

if(n<0 && errno==EINTR){
  if(stop) break;
  continue;
}

sa.sa_flags=SA_RESTART;
/* отправить сигнал во время блокирующего read и записать результат */

sigset_t set;
sigemptyset(&set);
sigaddset(&set, SIGTERM);
/* выберите схему обработки для многопоточной программы */