pthread_create의 매개변수 전달 관련 문제점
#include
#include
#include
#include
#include
#include
#include
#include
#include"data.h"
#define THRSIZ 10
//#define THRSIZ 10
int msgq[THRSIZ];
key_t key[THRSIZ];
int threadNum[THRSIZ];
pthread_mutex_t a_mutex = PTHREAD_MUTEX_INITIALIZER;
void *threadhandler(void *num)
{
int len;
int myNum; //Thread를 생성할 때 넘겨준 식별 번호
DATA data; //전송 받을 데이터 구조체
int handleCount = 0; //각 Thread가 몇개의 데이터를 처리 했는지에 대한 카운터
int no;
myNum = *((int *)num);
initDATA(&data);
printf("my thread number is %d\n",myNum);
msgrcv(msgq[myNum],&data, sizeof(DATA),0,0); //해당부분을 주석 처리 하게 되면 myNum값이 제대로 출력 됨
printf("[ %d ]data.no : %d HC : %d\n",myNum,data.no,handleCount);
sleep(1);
printf("[AFTER] my thread number is %d\n",myNum);
}
void initmsgqvariable()
{
int i=0;
int ret;
pthread_t pthread[THRSIZ];
for(i=0; i
{
threadNum[i] = i;
}
for(i=0; i {
msgq[i] = msgget(key[i],IPC_CREAT|0644);
if(msgq[i] < 0)
{
printf("Error : MSG Queue\n");
}
ret = pthread_create(&pthread[i],NULL,threadhandler,&(threadNum[i]));
if(ret < 0)
{
printf("Error : Pthread_create\n");
}
else
printf("Pthread %d is created\n",threadNum[i]);
}
usleep(500);
}
int main()
{
int i=0;
int ret;
DATA data;
for(i=0; i
{
key[i] = ftok("./WORK",i);
}
initmsgqvariable();
sleep(2);
for(i=0; i<10; i++)
{
setData(&data,i,2,3,4,"one","two","three");
ret = msgsnd(msgq[i%THRSIZ], (void *)&data, sizeof(DATA), IPC_NOWAIT);
if(ret < 0)
{
perror("MSGSND");
sleep(1);
i--;
}
}
sleep(1);
return 0;
}
다수의 MSGQ가 존재하고 그 각각의 MSGQ당 하나의 Thread가 메시지를 읽어서 처리하는 구조를 만드려고합니다.
소스코드를 보시면 메시지큐와 Thread를 생성 후 Thread에 대해서 넌 몇번 Thread다 라는 정보를 매개변수로 전달하는데 해당 값이 msgrcv 함수 이후 변화가 일어납니다. ㅠ
제 지식으로는 왜 이러는 지 알수가 없습니다.ㅠㅠ
도와주세요.....
댓글 달기