timer - timer_create(linux), SetTimer(windows), CreateTimerQueue(windows)

C++ 2017. 9. 24. 21:12

주기적으로 호출하는 타이머 구현 방법

1. timer_create - SIGEV_THREAD 사용

타이머 1개당 스레드 1개씩 생성됨 대신 시그널을 안씀

(linux)

#include <stdio.h>

#include <thread>

#include <time.h>

#include <signal.h>

#include <sstream>

long long tid()

{

std::stringstream ss;

ss << std::this_thread::get_id();

return std::stoull(ss.str());

}

void on_timer(union sigval sv)

{

//타이머 1개당 스레드 1개임

printf("on_timer : %d, tid: %lld\n", sv.sival_int, tid());

}

timer_t create_timer(int sec)

{

struct sigevent se;

se.sigev_notify = SIGEV_THREAD;

//se.sigev_value.sival_ptr = sec;

se.sigev_value.sival_int = sec;

se.sigev_notify_function = on_timer;

se.sigev_notify_attributes = NULL;

timer_t timer_id = {0};

if (timer_create(CLOCK_REALTIME, &se, &timer_id) != 0) {

return {0};

}

struct itimerspec ts;

ts.it_value.tv_sec = sec;

ts.it_value.tv_nsec = 0;

ts.it_interval.tv_sec = ts.it_value.tv_sec;

ts.it_interval.tv_nsec = ts.it_value.tv_nsec;

if (timer_settime(timer_id, 0, &ts, 0) != 0) {

return {0};

}

return timer_id;

}

int main(void) {

timer_t timer_id1 = create_timer(1);

printf("timer_id : %lld, tid: %lld\n", reinterpret_cast<long long int>(timer_id1), tid());

timer_t timer_id2 = create_timer(2);

printf("timer_id : %lld, tid: %lld\n", reinterpret_cast<long long int>(timer_id2), tid());

char ch = getchar();

printf("getchar : %d\n", ch);

timer_delete(timer_id1);

timer_delete(timer_id2);

return 0;

}

실행

timer_id : 30272848, tid: 139638915491648

timer_id : 30273984, tid: 139638915491648

on_timer : 1, tid: 139638895920896

on_timer : 2, tid: 139638887528192

on_timer : 1, tid: 139638887528192

on_timer : 2, tid: 139638895920896

on_timer : 1, tid: 139638895920896

on_timer : 2, tid: 139638887528192

on_timer : 1, tid: 139638895920896

on_timer : 2, tid: 139638887528192

on_timer : 1, tid: 139638887528192

2. timer_create - SIGEV_SIGNAL 사용

시그널 사용. 항상 main thread 만 사용됨

(linux)

#include <stdio.h>

#include <signal.h>

#include <time.h>

#include <cstring>

#include <sstream>

#include <thread>

const int signo = SIGRTMIN; // 사용할 시그널

long long tid()

{

std::stringstream ss;

ss << std::this_thread::get_id();

return std::stoull(ss.str());

}

void on_timer(int sig, siginfo_t* info, void* ucontext)

{

// timer_create를 별도로 해도 항상 main thread에서 실행됨

printf("on_timer : %d, tid: %lld\n", info->si_value.sival_int, tid());

}

timer_t create_timer(int sec)

{

struct sigevent se;

memset(&se, 0x00, sizeof(se));

se.sigev_notify = SIGEV_SIGNAL;

se.sigev_signo = signo;

//se.sigev_value.sival_ptr = sec;

se.sigev_value.sival_int = sec;

timer_t timer_id = {0};

if (timer_create(CLOCK_REALTIME, &se, &timer_id) != 0) {

return {0};

}

struct itimerspec its;

its.it_value.tv_sec = sec;

its.it_value.tv_nsec = 0;

its.it_interval.tv_sec = its.it_value.tv_sec;

its.it_interval.tv_nsec = its.it_value.tv_nsec;

if (timer_settime(timer_id, 0, &its, NULL) != 0) {

timer_delete(timer_id);

return {0};

}

return timer_id;

}

bool set_timer_signal()

{

struct sigaction sa;

memset(&sa, 0x00, sizeof(sa));

sa.sa_flags = SA_SIGINFO;

sa.sa_sigaction = on_timer;

sigemptyset(&sa.sa_mask);

return (sigaction(signo, &sa, NULL) != -1);

}

int main(void) {

set_timer_signal();

timer_t timer_id1 = create_timer(1);

printf("timer_id : %lld, tid: %lld\n", reinterpret_cast<long long int>(timer_id1), tid());

timer_t timer_id2 = create_timer(2);

printf("timer_id : %lld, tid: %lld\n", reinterpret_cast<long long int>(timer_id2), tid());

while (true) {

if (getchar() > 0) {

break;

} else {

printf("interrupted getchar\n"); // getchar return -1

}

timer_delete(timer_id1);

timer_delete(timer_id2);

return 0;

}

실행

timer_id : 7994400, tid: 139659796342592

timer_id : 7995472, tid: 139659796342592