BiscuitWiki: Thread

1 pthread 이용하여 쓰레드 생성
2 mutex를 이용하여, critical section의 데이터 동기화
3 signal을 이용하여 쓰레드간 신호보내기

1 pthread 이용하여 쓰레드 생성 #

#include <pthread.h>

void *threadfunc(void *arg)
{
...
}

int main()
{  
   int n, status;
   pthread_t threadid;
   
   n = pthread_create(&threadid, NULL, threadfunc, NULL);
   
   while(1){
     // Main Thread
   }
   
   return 0;
}

2 mutex를 이용하여, critical section의 데이터 동기화 #

#include <pthread.h>

pthread_mutex_t lock;
unsigned criticalvalue = 0;

int WriteData(const int value)
{
   pthread_mutex_lock(&lock);
   criticalvalue = value;
   pthread_mutex_unlock(&lock);

   return 0;
}

int ReadData(void)
{
   pthread_mutex_lock(&lock);
   cout << "Data : " << criticalvalue << "\n";
   pthread_mutex_unlock(&lock);

   return 0;
}

3 signal을 이용하여 쓰레드간 신호보내기 #

#include <pthread.h>
#include <iostream>
#include <signal.h>

using namespace std;

bool is_data = false;
unsigned criticalvalue = 0;

pthread_mutex_t lock;


void sig_isdata(int signo)
{
   is_data = true;
}

int ReadData(void)
{
   pthread_mutex_lock(&lock);
   cout << "Data : " << criticalvalue << "\n";
   pthread_mutex_unlock(&lock);

   return 0;
}

int WriteData(const int value)
{
   pthread_mutex_lock(&lock);
   criticalvalue = value;
   pthread_mutex_unlock(&lock);

   return 0;
}

void *threadfunc(void *arg)
{
   int n = 1;
   
   while(1)
   {  
      n++;
      if(n%1000000 == 0){
         WriteData(n);
         kill(getpid(), SIGUSR1);
      }
   }
}

int main()
{  
   int n;
   pthread_t threadid;
   
   signal(SIGUSR1, (void (*)(int))sig_isdata);
   
   pthread_mutex_init(&lock, NULL);
   n = pthread_create(&threadid, NULL, threadfunc, NULL);
   
   while(1){
      if(is_data){
         ReadData();
         is_data = false;
      }
   }

   pthread_join(threadid, (void **) &status);

   return 0;
}