pthread_create의 매개변수 전달 관련 문제점
글쓴이: bluesaiha / 작성시간: 수, 2012/08/22 - 10:13오전
#include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<pthread.h> #include<string.h> #include<sys/msg.h> #include<sys/ipc.h> #include<sys/types.h> #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<THRSIZ; i++) { threadNum[i] = i; } for(i=0; i<THRSIZ; 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<THRSIZ; 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 함수 이후 변화가 일어납니다. ㅠ
제 지식으로는 왜 이러는 지 알수가 없습니다.ㅠㅠ
도와주세요.....
파일 첨부합니다
File attachments:
첨부 | 파일 크기 |
---|---|
![]() | 1.48 KB |
Forums:
매개변수 전달은 이상없고, msgsnd(),
매개변수 전달은 이상없고,
msgsnd(), msgrcv() 를 잘못 사용하셨습니다.
메모리 침범이 발생해서 스택이 오염되었고, 그 와중에 번호를 저장한 배열이 영향을 받았습니다.
제가 어떻게 잘못 쓴건지 알 수 있을까요...?
답변 감사드립니다. 작성해주신 소스는 열심히 보겠습니다.
/***************************************************/
코드를 보면 아 이런식으로 하면 되는건가 정도만 이해가 되고
왜 제가 짠 소스는 안되는지 잘 모르겠습니다.ㅠㅠ
왜 안됬던 건가요?
man page 읽어보세요. 잘못된 부분만
man page 읽어보세요.
잘못된 부분만 추리면
제대로 돌리기 위해 최소한으로 수정한다면,
댓글 달기