[semaphore를 이용한 producer-consumer ] semaphore를 이용한 producer-consumer 프로그램

소개글

프로그램이 실행되면 두 thread가 실행되며, producer thread가 먼저 sem_wait(&b_mutex)를 호출하게 되고, 이 부분에서 b_empty 세마포 값을 1감소 시킨다. 그 결과 세마포 갯수는 총 buffer_size에서 -1이 된다.

목차

semaphore를 이용한 producer-consumer 프로그램
3가지 프로그램의 장단점 분석.
결론/느낀점

본문내용

함수 설명
메인 함수 : 2개의 thread를 선언/생성/job을 할당해주면 이들 thread가 종료될때까지 main의 프로그램 종료를 기다린다.
producer함수 : for문을 이용하여 11번 실행하도록 하였으며, 우선 임의초(s)만큼 sleep한후 버퍼에 데이터를 저장한다.
consumer함수 : for문을 이용하여 11번 실행하도록 하였으며, 우선 임의초(s)만큼 sleep한후 버퍼로 부터 데이터를 불러온다.
프로그램이 실행되면 두 thread가 실행되며, producer thread가 먼저 sem_wait(&b_mutex)를 호출하게 되고, 이 부분에서 b_empty 세마포 값을 1감소 시킨다. 그 결과 세마포 갯수는 총 buffer_size에서 -1이 된다. 그리고 바로 pthread_mutex_lock(&mutex_lock)을 실행시켜 임계영역 부분인(mutex_lock)을 시작하게 된다. lock이 된면 다른 producer가 실행되는 동안 consumer는 접근하지 못하게 통제된다. 버퍼에 값을 실제 집어넣는 작업은 buffer[in]=i 이부분에서 일어나는데, 우선 i를 버퍼 in번째에 입력시키고, 버퍼의 위치를 다음으로 이동시켜준다. 그리고 마지막으로 카운트 값을 증가시켜 버퍼에 데이터를 저장하였으므로 데이터 갯수를 증가시켜 준다. 이때 만약 버퍼에 가득 찬다면 화면에 "Buffer is Full"을 출력하고, pthread_mutex_unlock(&mutex_lock)을 사용해 임계영역(mutex_lock)의 lock를 해제시켜주며, 마지막으로 sem_post(&b_full)에서 b_empty 세마포값을 1증가 시킴으로 해서 다음 producer동작이 일어날 수 있도록 했다.

참고 자료

- 프로그래머를 위한 JAVA2(Second Edition)
- UNIX Systems Programming(David A. Curry)
- 응용 운영 체제 개념(Silberschats, Galvin, Gagne)
- 교수님이 제공해주신 자료(pthread)
- http://www.javanuri.com
- http://www.joinc.co.kr
- http://www.serpentine.com/~bos/threads-faq/
- http://www.bell-labs.com/topic/books/os-book/slide-dir/index.html
- http://www.ezdoum.com/upload/thread/pthread.pdf
- http://www.math.arizona.edu/swig/pthreads/threads.html
- http://users.actcom.co.il/~choo/lupg/tutorials/multi-thread/multi-thread.html
- http://kldp.org/KoreanDoc/Thread_Programming-KLDP
- http://www.joinc.co.kr/modules.php?name=Search&query=thread