求教：创建互斥锁多线程遇到的问题！

cxq870719

本人新手，向各位牛人求教！
以下实例中创建3个线程，为了更好的描述线程间的并行执行，让3个线程重用一个执行函数。每个线程都有五次循环（可以看成5个小任务），每次循环之间会随机等待1~10s的时间。

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <pthread.h>
   
4. 
   
5. #define  THREAD_NUMBER                      3              /* 线程数*/
   
6. #define  REPEAT_NUMBER                      3               /* 每个线程中的小任务数*/
   
7. #define  DELAY_TIME_LEVELS              10.0          /* 小任务间的最大时间间隔*/
   
8. 
   
9. /*声明一个全局锁*/
   
10. pthread_mutex_t mutex;
    
11. 
    
12. 
    
13. /*线程函数例程*/
    
14. void *thrd_func(void *arg)
    
15. {
    
16.         int thrd_num = (int)arg;
    
17.         int delay_time = 0;
    
18.         int res = 0;
    
19.         int count = 0;
    
20. 
    
21.         /*互斥锁上锁*/
    
22.         res = pthread_mutex_lock(&mutex);
    
23. 
    
24.         if(res)
    
25.         {
    
26.                 printf("Thread %d Lock failed!\n",thrd_num);
    
27.                 pthread_exit(NULL);
    
28.         }
    
29. 
    
30.         printf("Thread %d is Starting!\n",thrd_num);
    
31. 
    
32.         for(count = 0; count < REPEAT_NUMBER; count++)
    
33.         {
    
34.             delay_time = (int)(rand()*DELAY_TIME_LEVELS/(RAND_MAX))+1;
    
35.                
    
36.              sleep(delay_time);
    
37. 
    
38.             printf("\tThread%d: job %d delay = %d\n",thrd_num,count,delay_time);
    
39.         }
    
40. 
    
41.         printf("Thread %d is finished\n",thrd_num);
    
42. 
    
43.         pthread_exit(NULL);
    
44. }
    
45. 
    
46. int main(void)
    
47. {
    
48.         int loop = 0;
    
49.         int res = 0;
    
50.        
    
51.         void *thrd_res = NULL;
    
52.        
    
53.         pthread_t thread[THREAD_NUMBER] = {0};
    
54. 
    
55.         srand(time(NULL));
    
56. 
    
57.          /*互斥锁初始化*/
    
58.         pthread_mutex_init(&mutex,NULL);
    
59. 
    
60.         for(loop = 0; loop < THREAD_NUMBER; loop++)
    
61.         {
    
62.                  /* 创建多线程*/
    
63.                 res = pthread_create(&thread[loop],NULL,thrd_func,(void*)loop);
    
64.                          
    
65.                 if(0 != res)
    
66.                 {
    
67.                        printf("Create thread %d fail!\n",loop);
    
68.                      exit(res);
    
69.                 }
    
70.         }
    
71. 
    
72.         printf("Create threads success!\nWaiting for threads to finish......\n");
    
73. 
    
74.         for(loop = 0; loop < THREAD_NUMBER; loop++)
    
75.         {
    
76.                 /* 等待多线程结束*/
    
77.                 res = pthread_join(thread[loop],&thrd_res);
    
78.                
    
79.                 if(!res)
    
80.                 {
    
81.                         printf("Thread %d joined!\n",loop);
    
82.                 }
    
83.                 else
    
84.                 {
    
85.                         printf("Thread %d join failed!\n",loop);
    
86.                 }
    
87. 
    
88.                   /*互斥锁解锁*/
    
89.                 pthread_mutex_unlock(&mutex);
    
90.         }
    
91. 
    
92.         /*消除互斥锁*/
    
93.         pthread_mutex_destroy(&mutex);
    
94. 
    
95.         return 0;
    
96. }
    

复制代码

但是运行下来是以下情况：

[root@chengxiaoquan pthread_mutex]# gcc pthread_mutex.c -o pthread_mutex -lpthread
[root@chengxiaoquan pthread_mutex]# ./pthread_mutex
Create threads success!
Waiting for threads to finish......
Thread 2 is Starting!
        Thread2: job 0 delay = 8
        Thread2: job 1 delay = 4
        Thread2: job 2 delay = 3
Thread 2 is finished


运行到这里就不动了！！！

怎么只有线程2？？？？而且pthread2并没有join，为什么呢？本人新手，向各位牛人求教！

crazyhadoop

一个线程请求了锁，也不释放，别的线程基本无解吧？你看看是不是死锁了。



/*互斥锁解锁*/
                pthread_mutex_unlock(&mutex); 放到线程函数里面是不是好点？