这个简单的多线程程序有问题么？

xfsoul

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>


void *smp_line(void *args)
{
   char *s = (char *)args;
   int i;

   pthread_detach(pthread_self());
   for ( ; ; )
      printf("%s", s);

   return NULL;

}


int main()
{
   pthread_t t1, t2;
   char *s1 = "AAAAA";
   char *s2 = "BBBBB";

   if (pthread_create(&t1, NULL, smp_line(s1), NULL)) {
      fprintf(stderr, "Create thread t1 failed!\n");
      abort();
   }

   if (pthread_create(&t2, NULL, smp_line(s2), NULL)) {
      fprintf(stderr, "Create thread t2 failed!\n");
      abort();
   }


   exit(0);
}

在FreeBSD 6.1下编译运行，为什么会一直输出“AAAAAAAAAAAAAAAAAAAA....”呢，我指望它交错输出“AAAAA”和“BBBBB”呢。

[ 本帖最后由 xfsoul 于 2006-5-21 14:52 编辑 ]

vity

本人也不怎么会，只是提两个小小疑问：
1，想得到预定的结果，线程是不是需要同步？
2, 线程共享进程的某些资源，而printf 输出到 stdout,是不是存在竞争关系？

xfsoul

这两个线程并没有共享资源亚。

mingyanguo

把循环的次数弄的多一点看看。
你的pthread_create有语法问题吧。

xfsoul

pthread_create没有问题啊，可以用函数名代替函数指针的嘛。
为什么就看不到两个线程并发执行的效果呢？

antijp

smp_line(some_arg) is a function call expression.

smp_line is a primary expression.

antijp

By the way, if smp_line doesn't contain a deadloop, pthread_create will report error or coredump.

xfsoul

PTHREAD_CREATE(3)      FreeBSD Library Functions Manual      PTHREAD_CREATE(3)

NAME
     pthread_create -- create a new thread

LIBRARY
     Reentrant C Library (libc_r, -lc_r)
     POSIX Threads Library (libpthread, -lpthread)
     1:1 Threading Library (libthr, -lthr)

SYNOPSIS
     #include <pthread.h>

     int
     pthread_create(pthread_t *thread, const pthread_attr_t *attr,
         void *(*start_routine)(void *), void *arg);

你看man手册，第三个参数是一个回调函数啊，所以我传递一个函数指针给它，怎么会有问题呢？

xfsoul

我把代码改了一下，运行几遍，终于看到运行输出会变化－－也就是看到线程切换了吧。
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>
#include <sched.h>


#define NUM 100

int a = 0, b = 0;



void *thread1(void *args)
{

   int i;

   pthread_detach(pthread_self());

   for (i = 0; i < NUM; ++i) {
      ++a;
   }
   return NULL;

}


void *thread2(void *args)
{
   int i;

   pthread_detach(pthread_self());

   for (i = 0; i < NUM; ++i) {
      ++b;
   }

   return NULL;

}


int main()
{
   pthread_t t1, t2;
   int i;

   if (pthread_create(&t1, NULL, thread1, NULL)) {
      fprintf(stderr, "Create thread t1 failed!\n");
      abort();
   }

   if (pthread_create(&t2, NULL, thread2, NULL)) {
      fprintf(stderr, "Create thread t2 failed!\n");
      abort();
   }

   for (i = 0; i < NUM; ++i) {
      printf("Now a == %d; b == %d\n", a, b);
   }

   exit(0);
}

xfsoul

现在看到三个线程并行的很好了：
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>
#include <sched.h>


#define NUM 100

int a = 0, b = 0;



void rand_cal()
{
   printf("In thread %d: (a, b) == (%d, %d)\n", (int)pthread_self(), a, b);
}


void *thread1(void *args)
{

   int i;

   pthread_detach(pthread_self());

   for (i = 0; i < NUM; ++i) {
      rand_cal();
      ++a;
   }
   return NULL;

}

void *thread2(void *args)
{  
   int i;
   
   pthread_detach(pthread_self());
   
   for (i = 0; i < NUM; ++i) {
      rand_cal();
      ++b;
   }
   
   return NULL;

}


int main()
{  
   pthread_t t1, t2;
   int i;
   
   if (pthread_create(&t1, NULL, thread1, NULL)) {
      fprintf(stderr, "Create thread t1 failed!\n");
      abort();
   }
   
   if (pthread_create(&t2, NULL, thread2, NULL)) {
      fprintf(stderr, "Create thread t2 failed!\n");
      abort();
   }
   
   for (i = 0; i < NUM; ++i) {
      rand_cal();
      printf("Now a == %d; b == %d\n", a, b);
   }
   
   exit(0);
}