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 읽어보세요.
잘못된 부분만 추리면
제대로 돌리기 위해 최소한으로 수정한다면,
struct msg_DATA { long type; DATA data; };struct msg_DATA msg = { .type = 1, }; DATA *data = &msg.data; ... make_something(data); msgsnd(..., &msg, sizeof(*data), ...); ...댓글 달기