TCP/IP Mutex & Semaphore

뮤텍스(Mutex)

동일한 메모리 영역으로의 동시접근이 발생하는 상황 (ex.화장실)

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <pthread.h>

#define NUM_THREAD	100

void * thread_inc(void * arg);
void * thread_des(void * arg);
long long num=0; // long long형은 64비트 정수 자료형

pthread_mutex_t mutex; // 뮤텍스(Mutex) : 동일한 메모리 영역으로의 동시접근이 발생하는 상황 (ex.화장실)

int main(int argc, char *argv[]) 
{
	pthread_t thread_id[NUM_THREAD];
	int i;

	pthread_mutex_init(&mutex, NULL); // 뮤텍스 초기화

	printf("sizeof long long: %d \n", sizeof(long long));
	for(i=0; i<NUM_THREAD; i++)
	{
		if(i%2)
			pthread_create(&(thread_id[i]), NULL, thread_inc, NULL);
		else
			pthread_create(&(thread_id[i]), NULL, thread_des, NULL);	
	}	

	for(i=0; i<NUM_THREAD; i++)
		pthread_join(thread_id[i], NULL);

	printf("result: %lld \n", num);
	return 0;
}

void * thread_inc(void * arg) 
{
	int i;
	pthread_mutex_lock(&mutex); // 뮤텍스 락
	for(i=0; i<50000000; i++) {
		num+=1;
	}
	pthread_mutex_unlock(&mutex); // 뮤텍스 언락
	return NULL;
}
void * thread_des(void * arg)
{
	int i;
	for(i=0; i<50000000; i++) {
		pthread_mutex_lock(&mutex);
		num-=1;
		pthread_mutex_unlock(&mutex);
	}
	return NULL;
}

세마포어(Semaphore)

동일한 메모리 영역에 접근하는 쓰레드의 실행순서를 지정해야 하는 상황

#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>

void * read(void * arg);
void * accu(void * arg);

static sem_t sem_one;
static sem_t sem_two;
static int num;

int main(int argc, char *argv[])
{
	pthread_t id_t1, id_t2;
	sem_init(&sem_one, 0, 0); // sem_init(주소값, 0, 세마포어 초기값 설정)
	sem_init(&sem_two, 0, 1);

	pthread_create(&id_t1, NULL, read, NULL);
	pthread_create(&id_t2, NULL, accu, NULL);

	pthread_join(id_t1, NULL);
	pthread_join(id_t2, NULL);

	sem_destroy(&sem_one);
	sem_destroy(&sem_two);
	return 0;
}

void * read(void * arg)
{
	int i;
	for(i=0; i<5; i++)
	{
		fputs("Input num: ", stdout);

		sem_wait(&sem_two); // - 감소
		scanf("%d", &num);
		sem_post(&sem_one); // + 증가
	}
	return NULL;	
}
void * accu(void * arg)
{
	int sum=0, i;
	for(i=0; i<5; i++)
	{
		sem_wait(&sem_one); // - 감소
		sum+=num;
		sem_post(&sem_two); // + 증가
	}
	printf("Result: %d \n", sum);
	return NULL;
}