메세지 큐에 대한 초보적 질문입니다 ㅠ
글쓴이: zzion / 작성시간: 월, 2008/05/12 - 4:06오후
os 를 공부하면서 프로세스간 통신에서 메세지 큐를 보고있는데요,,
공부를 하며 간단한 프로그램을 짜보았습니다.
쓰레드를 2개 만들어서 하나는 메세지큐를 이용해 보내고
다른 하나는 받아서 printf 로 출력 하도록 했는데요,,,
msgsnd 를 이용해 보낸후 그다음 처리가 어떻게 되나요? ㅠ
무슨 말인가 하면,, 제 경우에 for loop으로 msgsnd 를 10개 하려 하는데 한번만 하고 중지합니다; thread 종료도 되지 않구요;;
자연히 리시버는 1개반 받네요;
프로그래밍 초보에게 빛을 주세요! ㅠ 다음은 짜본 소스입니다.
#include 'stdio.h>
#include 'stdlib.h>
#include 'string.h>
#include 'unistd.h>
#include 'sys/types.h>
#include 'sys/ipc.h>
#include 'sys/msg.h>
#include 'pthread.h>
// 공유할 데이터를 위한 구조체 및 선언
struct data
{
long data_type;
int data_num;
char data_buff[1024];
};
struct data b_data;
// 첫번째 thread : 메세지 전송
void *thread_1()
{
int msqid;
int ndx = 0;
int send;
// 메세지 큐 생성
msqid = msgget((key_t)1234, IPC_CREAT|0666);
if (msqid == -1)
{
perror("msgget error : ");
exit(1);
}
for ( ndx = 0; ndx < 10; ndx++)
{
b_data.data_type = 0; // data type 을 0로 통일
b_data.data_num = ndx;
//메세지 기록 : help me!!
sprintf( b_data.data_buff, "type=%d, ndx=%d, help me!!", b_data.data_type, ndx);
send = msgsnd(msqid, &b_data, sizeof(b_data) - sizeof(long), 0);
if (send == -1 )
{
perror("msgsnd() 실패");
exit(1);
}
}
return NULL;
}
// 두번째 thread : 메세지 받기
void *thread_2()
{
int msqid;
int ndx;
int receive;
struct msqid_ds msqstat;
// 메세지 큐 생성
msqid = msgget((key_t)1234, IPC_CREAT|0666);
if (msqid == -1)
{
perror("msgget error : ");
exit(1);
}
if (msgctl( msqid, IPC_STAT, &msqstat) == -1 )
{
perror( "msgctl() 실패");
exit(1);
}
for ( ndx = 0; ndx < msqstat.msg_qnum; ndx++)
{
receive = msgrcv(msqid, &b_data, sizeof(b_data) - sizeof(long), 0, 0);
if ( receive == -1 )
{
perror( "msgrcv() 실패");
exit(1);
}
printf( "%d - %s\n", b_data.data_num, b_data.data_buff);
}
return NULL;
}
int main (int argc, const char * argv[])
{
int thr_id;
pthread_t p_thread[2];
int status;
// thread 생성
thr_id = pthread_create(&p_thread[0], NULL, thread_1, NULL);
//sleep(10);
thr_id = pthread_create(&p_thread[1], NULL, thread_2, NULL);
// thread 종료
pthread_join(p_thread[0], (void **) &status);
pthread_join(p_thread[1], (void **) &status);
return 0;
}ps // 여기 맨날 보기만 하다 처음 글쓰는데,,, 꺽인괄호 처리방법도 모르겠네요 ㅠ 인클루드 파일을 '> 로 묶었습니다.
Forums:
제가 찾았습니다...
아직 완벽히 해결은 못했는데요,,
메세지 큐의 type은 0 을 제외한 정수랩니다;; 일단 거기서 틀렸고 다른곳도 문제가 있는것 같은데 열심히 찾고 있네요 ㅠ
(아 그리고 위 소스에 메세지큐를 보내는 구조체부분도 조금 잘못되었더래요;)
이러면서 많이 배우네요~ㅎ 시간은 너무 많이 걸리지만 ㅠ
일단 돌아가게만...
mac osx에서는 잘 돌아가네요.
전역변수에도 주의하셔야겠어요.
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #include <pthread.h> // 공유할 데이터를 위한 구조체 및 선언 struct data { long data_type; char data_buff[1024]; }; // 첫번째 thread : 메세지 전송 void *thread_1() { int msqid; int ndx = 0; int send; struct data b_data; // 메세지 큐 생성 msqid = msgget((key_t)1234, IPC_CREAT|0666); if (msqid == -1) { perror("msgget error : "); exit(1); } for ( ndx = 0; ndx < 10; ndx++) { b_data.data_type = 234; // data type 을 0로 통일 /*b_data.data_num = ndx; */ //메세지 기록 : help me!! sprintf( b_data.data_buff, "type=%d, ndx=%d, help me!!", b_data.data_type, ndx); send = msgsnd(msqid, &b_data, sizeof(b_data) - sizeof(long), 0); if (send == -1 ) { perror("msgsnd() 실패"); exit(1); } } return NULL; } // 두번째 thread : 메세지 받기 void *thread_2() { int msqid; int ndx; int receive; struct msqid_ds msqstat; struct data b_data; // 메세지 큐 생성 msqid = msgget((key_t)1234, IPC_CREAT|0666); if (msqid == -1) { perror("msgget error : "); exit(1); } if (msgctl( msqid, IPC_STAT, &msqstat) == -1 ) { perror( "msgctl() 실패"); exit(1); } for ( ndx = 0; ndx < 10; ndx++) { receive = msgrcv(msqid, &b_data, sizeof(b_data) - sizeof(long), 0, 0); if ( receive == -1 ) { perror( "msgrcv() 실패"); exit(1); } printf( "%s\n", b_data.data_buff); } return NULL; } int main (int argc, const char * argv[]) { int thr_id; pthread_t p_thread[2]; int status; // thread 생성 thr_id = pthread_create(&p_thread[0], NULL, thread_1, NULL); //sleep(10); thr_id = pthread_create(&p_thread[1], NULL, thread_2, NULL); // thread 종료 pthread_join(p_thread[0], (void **) &status); pthread_join(p_thread[1], (void **) &status); return 0; }댓글 달기