向线程池中线程函数传递结构体参数的问题

冷寒生

1. pthread_mutex_t mutex;
   
2. 
   
3. struct TEST {
   
4.     char str[10];
   
5.     int num;
   
6. };
   
7. 
   
8. void dispatch_threadpool_to_me(void *arg) {
   
9.     pthread_mutex_lock( &mutex );
   
10.     TEST test;
    
11.     /*为传入的结构体变量复制一个副本*/
    
12.     memcpy( &test, ( TEST* )arg, sizeof( TEST ) );
    
13.     pthread_mutex_unlock( &mutex );
    
14.     sleep(4);
    
15.     printf( "%s,%d\n", test.str, test.num );
    
16. }
    
17. 
    
18. 
    
19. int main(int argc, char **argv) {
    
20.   threadpool tp;
    
21.   TEST test;
    
22. 
    
23.   /*初始化互斥量*/
    
24.   if ( pthread_mutex_init( &mutex, NULL ) == 0 )
    
25.   {
    
26.       printf( "pthread_mutex_init ok\n" );
    
27.   }
    
28.   else
    
29.   {
    
30.       return 0;
    
31.   }
    
32.   /*线程池最大工作线程为10个*/
    
33.   tp = create_threadpool(10);
    
34. 
    
35.   for ( int i = 0; i < 100; i++ )
    
36.   {
    
37.       sprintf( test.str, "%d", i );
    
38.       test.num = i;
    
39.       /*投入线程*/
    
40.       dispatch_threadpool(tp, dispatch_threadpool_to_me, (void *) &test );
    
41.   }
    
42.   /*销毁线程池*/
    
43.   destroy_threadpool( tp );
    
44. 
    
45. }

复制代码

打印结果：

0,0
1,1
2,2
3,3
4,4
5,5
6,6
7,7
8,8
9,9
20,20
20,20
20,20
20,20
20,20
20,20
20,20
20,20
20,20
20,20


这段代码的问题出在dispatch_threadpool_to_me线程函数的printf中，现象为printf为重复打印 i 的值。但是我已经使用互斥量来保证每个线程函数中都有一个独立的结构体副本，为什么还会出现这样的问题呢？

duanjigang

用同一个结构体，肯定会有问题，第N个线程可能还没打印，第N+1个已经把它修改了。
100个线程就100哥TEST对象吧