#include <stdio.h>
#include <memory.h>
#include <stdlib.h>
#include <pthread.h>
#include <time.h>
#include <asm/unistd.h>

#define AS        200
#define BS        300
#define CS        500


float *a;
float *b;
float *c;


void* thread_routine(void* arg)
{
   int i,j;
   int index=*(int*)arg;
   float ret=0;
   printf("tid: %d   line: %d\n",syscall(__NR_gettid),index);
   for(i=0;i<CS;i++)
   {
     ret=0;
     for(j=0;j<BS;j++)
     {
       ret+=(*(a+index*BS+j))*(*(b+j*CS+i));
       *(c+index*CS+i)=ret;
     }
   }

   return;
}

int main()
{
        int i,j,k,l,m,n,o,p,q,r,s;
        float ret=0;
        pthread_t pt[200];
        int pi=0;        
        FILE* fp;
        time_t st,et;

        int count=0;
        a=(float*)malloc(4*AS*BS);
        if(a==NULL)
        {
          printf("memory error\n");
          return -1;
        }
        b=(float*)malloc(4*BS*CS);
        if(b==NULL)
        {
          printf("memory error\n");
          return -1;
        }
        c=(float*)malloc(4*AS*CS);
        if(c==NULL)
        {
          printf("memory error\n");
          return -1;
        }
        fp=fopen("toutput","w");
        printf("%p      %p       %p\n",a,b,c);
        for(i=0;i<AS;i++)
        {
                for(j=0;j<BS;j++)
                {
                        *(a+i*BS+j)=1.414*i*j;
                }
        }
        printf("a initialized\n");
        for(k=0;k<BS;k++)
        {
                for(l=0;l<CS;l++)
                {
                        *(b+k*CS+l)=1.414*k*l;
                }
        }

        printf("b initialized\n");
        for(m=0;m<AS;m++)
        {
                for(n=0;n<CS;n++)
                {
                        *(c+m*CS+n)=0;
                }
        }

        printf("After initializing\n");
        time(&st);
/*        for(o=0;o<AS;o++)
        {
            if(pthread_create(&pt[count],NULL,thread_routine,&count)!=0)
            {
              printf("can't make thread\n");
              return -1;
            }
           count++;
        }*/
o=0;  
while(o<AS)
   {
     pthread_create(&pt[count],NULL,thread_routine,&count);
     count++;
   }
  while(pi<AS)
  {
    pthread_join(pt[pi],NULL);
    pi++;
  }
  time(&et);
  printf("time taken %ld\n",et-st);
  for(p=0;p<AS;p++)
  {
    for(q=0;q<CS;q++)
    {
      fprintf(fp,"%f ",*(c+p*CS+q));
    }
    fprintf(fp,"\n");
  }
  fclose(fp);
  return 0;
}


위의 코드는 단순히 쓰레드를 시험하는 코드입니다.

for 루프 안에서 스레드를 생성하는데요.

논리상으로는 count가 하나 증가하고 그 값이 스레드의 인자로 들어가야 하는데

결과를 보면 스레드 id는 정상적으로 증가를 하나 count의 값을 제대로 받지 못합니다.

tid : 0                      index : 0
tid : 1                      index : 1
tid : 2                      index : 2
tid : 3                      index : 3

< 정상 결과 >

tid : 0                      index : 0
tid : 1                      index : 0
tid : 2                      index : 1
tid : 3                      index : 1

< 현재 결과 > - 인덱스의 증가를 제대로 받아오지 못하는군요.

스레드를 생성하는 부분에서 뭔가 잘못됐나요?

뮤텍스도 사용해봤습니다만... 잘 안되는군요...ㅠ.ㅠ