По частоте вздоха - PullRequest
Новая
       36

По частоте вздоха

1 голос
/ 15 июня 2011

У меня есть таймер с фиксированным временным интервалом 1 s, setitimer(SIGPROF, &timeslice, NULL);. Когда я запускаю процесс с одним потоком, sighandler вызывается один раз в секунду. Однако, если в процессе есть два или более потоков, они будут выполнять два вызова sighandler в секунду. Почему это так? или как получить таймер с фиксированной частотой, не зависящей от числа запущенных потоков.

Рабочий код прилагается. Распечатка показывает, что sighandler вызывается дважды в секунду ... (это не тот случай, когда NUM_THREADS изменяется на единицу) 

#include <sys/syscall.h>
#include <unistd.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/time.h>//itimerval
#include <signal.h>//sigaction, SIGPROF...
#include <pthread.h>//pthread_create()/join()
#include <stdint.h>//uint32_t
#include <stdlib.h>//exit()
using namespace std;

#ifndef NUM_THREADS
#define NUM_THREADS 20
#endif

struct sigaction old_act_;

int init_timer(int which, int musec) {
    struct itimerval timeslice;
    timeslice.it_interval.tv_sec = musec / 1000000;
    timeslice.it_interval.tv_usec = musec % 1000000;
    timeslice.it_value.tv_sec = musec / 1000000;
    timeslice.it_value.tv_usec = musec % 1000000;
    setitimer(which, &timeslice, NULL);
    return 0;
}

void remove_timer(int which)
{
    struct itimerval timeslice;
    timeslice.it_interval.tv_sec = 0;
    timeslice.it_interval.tv_usec = 0;
    timeslice.it_value.tv_sec = 0;
    timeslice.it_value.tv_usec = 0;
    setitimer(which, &timeslice, NULL);
}

void install_handler(int signo, void(*handler)(int))
{
    sigset_t set;
    struct sigaction act;
    act.sa_handler = handler;
    act.sa_flags = SA_RESTART;
    sigaction(signo, &act, &old_act_);
    sigemptyset(&set);
    sigaddset(&set, signo);
    sigprocmask(SIG_UNBLOCK, &set, NULL);
    return;
}

void uninstall_handler(int signo, bool to_block_signal)
{
    sigaction(signo, &old_act_, 0);
    if(to_block_signal)
    {
        // block the signal
        sigset_t set;
        sigemptyset(&set);
        sigaddset(&set, signo);
        sigprocmask(SIG_BLOCK, &set, NULL);
    }
}

void handler(int signo)
{
    pid_t tid = syscall(SYS_gettid);
    pid_t pid = syscall(SYS_getpid);
    struct timeval now;
    gettimeofday(&now, NULL);
    printf("sig %d, pid %d, tid %d, time = %u.%06u\n", signo, static_cast<int>(pid), static_cast<int>(tid), static_cast<uint32_t>(now.tv_sec), static_cast<uint32_t>(now.tv_usec));
}

void * threadRun(void * threadId)
{
    for(uint64_t i = 0; i < 10000000000; i++)
    {
        //sleep(1);
    }
}

int main()
{
    int tick_musec = 1000000;
    init_timer(ITIMER_PROF, tick_musec);
    install_handler(SIGPROF, handler);

    pthread_t threads[NUM_THREADS];
    long t;
    for (t = 0; t < NUM_THREADS; t++) {
        printf("In main: creating thread %ld\n", t);
        if (pthread_create(&threads[t], NULL, threadRun, (void *) t)) {
            printf("ERROR; return from pthread_create()\n");
            exit(-1);
        }
    }
    void * status;
    for (t = 0; t < NUM_THREADS; t++) {
        if(pthread_join(threads[t], &status)) {
          printf("ERROR; return from pthread_join()\n");
          exit(-1);
        }
        printf("Main: completed join with thread %ld having a status of %ld\n", t, (long) status);
    }

    remove_timer(ITIMER_PROF);
    uninstall_handler(SIGPROF, true);
    printf("Main: program completed. Exiting.\n");
    return 0;
}

Ниже приводится вывод при работе на машине с 4 двухъядерными процессорами. 

sig 27, pid 21542, tid 21544, core 6, time = 1308168237.023219
sig 27, pid 21542, tid 21544, core 6, time = 1308168237.276228
sig 27, pid 21542, tid 21549, core 6, time = 1308168237.528200
sig 27, pid 21542, tid 21545, core 7, time = 1308168237.781441
sig 27, pid 21542, tid 21551, core 6, time = 1308168238.037210
sig 27, pid 21542, tid 21554, core 6, time = 1308168238.294218
sig 27, pid 21542, tid 21551, core 6, time = 1308168238.951221
sig 27, pid 21542, tid 21546, core 0, time = 1308168239.064665
sig 27, pid 21542, tid 21561, core 1, time = 1308168239.335642
sig 27, pid 21542, tid 21558, core 1, time = 1308168240.122650
sig 27, pid 21542, tid 21555, core 6, time = 1308168240.148192
sig 27, pid 21542, tid 21556, core 1, time = 1308168240.445638
sig 27, pid 21542, tid 21543, core 7, time = 1308168240.702424
sig 27, pid 21542, tid 21559, core 1, time = 1308168240.958635
sig 27, pid 21542, tid 21555, core 6, time = 1308168241.210182
sig 27, pid 21542, tid 21550, core 7, time = 1308168241.464426
sig 27, pid 21542, tid 21553, core 0, time = 1308168241.725650
sig 27, pid 21542, tid 21555, core 6, time = 1308168241.982178
sig 27, pid 21542, tid 21547, core 7, time = 1308168242.234422
sig 27, pid 21542, tid 21560, core 0, time = 1308168242.503647
sig 27, pid 21542, tid 21546, core 0, time = 1308168242.766902
sig 27, pid 21542, tid 21550, core 7, time = 1308168243.018414
sig 27, pid 21542, tid 21552, core 0, time = 1308168243.270643
sig 27, pid 21542, tid 21550, core 7, time = 1308168243.556412

Редактировать: Я вроде решил проблему (см. Также ответ @ n.m.). Причина, по которой sighandler работает чаще на многопроцессорных компьютерах, заключается в том, что SIGPROF отправляется на основе времени процессора, а не реального времени. Время ЦП может быть больше, чем в реальном времени, например, если время ЦП составляет 2 секунды, это может означать, что один процесс имеет два потока, одновременно работающих на 2 ЦП в течение 1 секунды.

1 Ответ

0 голосов
/ 15 июня 2011

Вы можете использовать pthread_sigmask(...), чтобы заблокировать SIGPROF в созданных темах.Фактически, рекомендуется иметь только один поток, обрабатывающий все сигналы.

...